commit | a1ddbcc758cd034aacb32af59ef3a33d0b62651b | [log] [tgz] |
---|---|---|
author | Gary Gregory <garydgregory@gmail.com> | Fri Feb 09 18:04:49 2024 -0500 |
committer | Gary Gregory <garydgregory@gmail.com> | Fri Feb 09 18:04:49 2024 -0500 |
tree | 36707e67201372f45af62b95b449f19fb3789615 | |
parent | 5b2cf0d7409e3b811e828e85c320f8687bd8b0e5 [diff] |
Simplify
diff --git a/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java b/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java index 3f3ae68..d68c720 100644 --- a/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java +++ b/src/main/java/org/apache/commons/io/input/ReadAheadInputStream.java
@@ -181,7 +181,7 @@ private boolean isReading; // Whether there is a reader waiting for data. - private final AtomicBoolean isWaiting = new AtomicBoolean(false); + private final AtomicBoolean isWaiting = new AtomicBoolean(); private final ExecutorService executorService;
diff --git a/src/test/java/org/apache/commons/io/input/BoundedReaderTest.java b/src/test/java/org/apache/commons/io/input/BoundedReaderTest.java index 71d1aad..a17f7e5 100644 --- a/src/test/java/org/apache/commons/io/input/BoundedReaderTest.java +++ b/src/test/java/org/apache/commons/io/input/BoundedReaderTest.java
@@ -55,7 +55,7 @@ @Test public void testCloseTest() throws IOException { - final AtomicBoolean closed = new AtomicBoolean(false); + final AtomicBoolean closed = new AtomicBoolean(); try (Reader sr = new BufferedReader(new StringReader("01234567890")) { @Override public void close() throws IOException {
diff --git a/src/test/java/org/apache/commons/io/output/ThresholdingOutputStreamTest.java b/src/test/java/org/apache/commons/io/output/ThresholdingOutputStreamTest.java index f69f22c..cc03f8d 100644 --- a/src/test/java/org/apache/commons/io/output/ThresholdingOutputStreamTest.java +++ b/src/test/java/org/apache/commons/io/output/ThresholdingOutputStreamTest.java
@@ -41,7 +41,7 @@ @Test public void testThresholdZero() throws IOException { - final AtomicBoolean reached = new AtomicBoolean(false); + final AtomicBoolean reached = new AtomicBoolean(); try (final ThresholdingOutputStream out = new ThresholdingOutputStream(0) { @Override protected void thresholdReached() throws IOException {