Skip to content

Commit 81e5676

Browse files
committed
add constructor with BufferedReader in StandardInputSupplier
1 parent 4b40daa commit 81e5676

File tree

2 files changed

+4
-6
lines changed

2 files changed

+4
-6
lines changed

src/main/java/io/github/benas/unixstream/StandardInputSupplier.java

Lines changed: 2 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,8 @@
22

33
import java.io.BufferedReader;
44
import java.io.IOException;
5-
import java.io.InputStreamReader;
65
import java.util.function.Supplier;
76

8-
import static java.lang.System.in;
9-
107
/**
118
* Supplier that generates an infinite stream from the standard input.
129
*
@@ -16,8 +13,8 @@ class StandardInputSupplier implements Supplier<String> {
1613

1714
private BufferedReader bufferedReader;
1815

19-
StandardInputSupplier() {
20-
bufferedReader = new BufferedReader(new InputStreamReader(in));
16+
StandardInputSupplier(BufferedReader bufferedReader) {
17+
this.bufferedReader = bufferedReader;
2118
}
2219

2320
@Override

src/main/java/io/github/benas/unixstream/UnixStream.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,6 +12,7 @@
1212
import java.util.function.Predicate;
1313
import java.util.stream.Stream;
1414

15+
import static java.lang.System.in;
1516
import static java.nio.file.Files.isDirectory;
1617
import static java.nio.file.Files.lines;
1718
import static java.nio.file.Files.walk;
@@ -36,7 +37,7 @@ public interface UnixStream<T> extends Stream<T> {
3637
* @throws IOException thrown if an error occurs during reading the standard input
3738
*/
3839
static UnixStream<String> cat() throws IOException {
39-
return new UnixStreamImpl<>(Stream.generate(new StandardInputSupplier()));
40+
return new UnixStreamImpl<>(Stream.generate(new StandardInputSupplier(new BufferedReader(new InputStreamReader(in)))));
4041
}
4142

4243
/**

0 commit comments

Comments
 (0)