[commons-io] branch master updated: Add BrokenInputStream.INSTANCE.

[ggregory]

This is an automated email from the ASF dual-hosted git repository.

ggregory pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/commons-io.git


The following commit(s) were added to refs/heads/master by this push:
     new b8b0766  Add BrokenInputStream.INSTANCE.
b8b0766 is described below

commit b8b07666737afc667af0aaff7016ceb2cdf75fb4
Author: Gary Gregory <gardgreg...@gmail.com>
AuthorDate: Mon Jul 12 14:11:08 2021 -0400

    Add BrokenInputStream.INSTANCE.
---
 src/changes/changes.xml                                            | 3 +++
 src/main/java/org/apache/commons/io/input/BrokenInputStream.java   | 7 +++++++
 .../org/apache/commons/io/input/ObservableInputStreamTest.java     | 6 +++---
 3 files changed, 13 insertions(+), 3 deletions(-)

diff --git a/src/changes/changes.xml b/src/changes/changes.xml
index 7d7a78e..2ac90cf 100644
--- a/src/changes/changes.xml
+++ b/src/changes/changes.xml
@@ -69,6 +69,9 @@ The <action> type attribute can be add,update,fix,remove.
       <action dev="ggregory" type="add" due-to="Gary Gregory">
         Add UncheckedFilterInputStream.
       </action>
+      <action dev="ggregory" type="add" due-to="Gary Gregory">
+        Add BrokenInputStream.INSTANCE.
+      </action>
       <!-- UPDATE -->
       <action dev="ggregory" type="update" due-to="Dependabot">
         Bump Maven Javadoc plugin from 3.2.0 to 3.3.0.
diff --git a/src/main/java/org/apache/commons/io/input/BrokenInputStream.java 
b/src/main/java/org/apache/commons/io/input/BrokenInputStream.java
index d9e97f6..d96cea0 100644
--- a/src/main/java/org/apache/commons/io/input/BrokenInputStream.java
+++ b/src/main/java/org/apache/commons/io/input/BrokenInputStream.java
@@ -32,6 +32,13 @@ import java.io.InputStream;
 public class BrokenInputStream extends InputStream {
 
     /**
+     * The singleton instance.
+     *
+     * @since 2.12.0
+     */
+    public static final BrokenInputStream INSTANCE = new BrokenInputStream();
+    
+    /**
      * The exception that is thrown by all methods of this class.
      */
     private final IOException exception;
diff --git 
a/src/test/java/org/apache/commons/io/input/ObservableInputStreamTest.java 
b/src/test/java/org/apache/commons/io/input/ObservableInputStreamTest.java
index e2bf724..30d63ed 100644
--- a/src/test/java/org/apache/commons/io/input/ObservableInputStreamTest.java
+++ b/src/test/java/org/apache/commons/io/input/ObservableInputStreamTest.java
@@ -129,21 +129,21 @@ public class ObservableInputStreamTest {
 
     @Test
     public void testBrokenInputStreamRead() throws IOException {
-        try (final ObservableInputStream ois = new ObservableInputStream(new 
BrokenInputStream())) {
+        try (final ObservableInputStream ois = new 
ObservableInputStream(BrokenInputStream.INSTANCE)) {
             assertThrows(IOException.class, () -> ois.read());
         }
     }
 
     @Test
     public void testBrokenInputStreamReadBuffer() throws IOException {
-        try (final ObservableInputStream ois = new ObservableInputStream(new 
BrokenInputStream())) {
+        try (final ObservableInputStream ois = new 
ObservableInputStream(BrokenInputStream.INSTANCE)) {
             assertThrows(IOException.class, () -> ois.read(new byte[1]));
         }
     }
 
     @Test
     public void testBrokenInputStreamReadSubBuffer() throws IOException {
-        try (final ObservableInputStream ois = new ObservableInputStream(new 
BrokenInputStream())) {
+        try (final ObservableInputStream ois = new 
ObservableInputStream(BrokenInputStream.INSTANCE)) {
             assertThrows(IOException.class, () -> ois.read(new byte[2], 0, 1));
         }
     }