Skip to content

Commit b1d6fbb

Browse files
committed
missed a file
1 parent 06707b0 commit b1d6fbb

File tree

1 file changed

+22
-0
lines changed

1 file changed

+22
-0
lines changed
Lines changed: 22 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,22 @@
1+
package com.marklogic.quickstart.util;
2+
3+
import java.io.BufferedReader;
4+
import java.io.InputStream;
5+
import java.io.InputStreamReader;
6+
import java.util.function.Consumer;
7+
8+
public class StreamGobbler extends Thread {
9+
private InputStream inputStream;
10+
private Consumer<String> consumeInputLine;
11+
12+
public StreamGobbler(InputStream inputStream, Consumer<String> consumeInputLine) {
13+
this.inputStream = inputStream;
14+
this.consumeInputLine = consumeInputLine;
15+
}
16+
17+
@Override
18+
public void run() {
19+
System.out.println("gobbler running");
20+
new BufferedReader(new InputStreamReader(inputStream)).lines().forEach(consumeInputLine);
21+
}
22+
}

0 commit comments

Comments
 (0)