in src/main/java/org/apache/maven/shared/utils/cli/StreamPumper.java [73:101]
public void run() {
try {
for (String line = in.readLine(); line != null; line = in.readLine()) {
try {
if (exception == null) {
consumeLine(line);
}
} catch (Exception t) {
exception = t;
}
}
} catch (IOException e) {
exception = e;
} finally {
try {
in.close();
} catch (final IOException e2) {
if (this.exception == null) {
this.exception = e2;
}
}
synchronized (this) {
setDone();
this.notifyAll();
}
}
}