Make ObservableInputStream.getObservers() public.

Author: Gary Gregory

src/changes/changes.xml

@@ -160,6 +160,9 @@ The <action> type attribute can be add,update,fix,remove.
       <action dev="ggregory" type="add" due-to="Gary Gregory">
         Add and use ObservableInputStream.ObservableInputStream(InputStream, Observer...).
       </action>
+      <action dev="ggregory" type="add" due-to="Gary Gregory">
+        Make ObservableInputStream.getObservers() public.
+      </action>
       <!-- UPDATES -->
       <action dev="ggregory" type="update" due-to="Dependabot">
         Update junit-jupiter from 5.6.2 to 5.7.0 #153.

src/main/java/org/apache/commons/io/input/ObservableInputStream.java

@@ -174,8 +174,9 @@ public void consume() throws IOException {
      * Gets all currently registered observers.
      *
      * @return a list of the currently registered observers
+     * @since 2.9.0
      */
-    protected List<Observer> getObservers() {
+    public List<Observer> getObservers() {
         return observers;
     }
 

src/test/java/org/apache/commons/io/input/ObservableInputStreamTest.java

@@ -17,8 +17,8 @@
 package org.apache.commons.io.input;
 
 import static org.junit.jupiter.api.Assertions.assertEquals;
-import static org.junit.jupiter.api.Assertions.assertNotEquals;
 import static org.junit.jupiter.api.Assertions.assertFalse;
+import static org.junit.jupiter.api.Assertions.assertNotEquals;
 import static org.junit.jupiter.api.Assertions.assertTrue;
 
 import java.io.ByteArrayInputStream;
@@ -74,7 +74,7 @@ public void data(final byte[] pBuffer, final int pOffset, final int pLength) thr
     @Test
     public void testDataByteCalled_add() throws Exception {
         final byte[] buffer = MessageDigestCalculatingInputStreamTest
-                .generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
+            .generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
         final LastByteKeepingObserver lko = new LastByteKeepingObserver();
         try (final ObservableInputStream ois = new ObservableInputStream(new ByteArrayInputStream(buffer))) {
             assertEquals(-1, lko.lastByteSeen);
@@ -106,7 +106,7 @@ public void testDataByteCalled_add() throws Exception {
     @Test
     public void testDataByteCalled_ctor() throws Exception {
         final byte[] buffer = MessageDigestCalculatingInputStreamTest
-                .generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
+            .generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
         final LastByteKeepingObserver lko = new LastByteKeepingObserver();
         try (final ObservableInputStream ois = new ObservableInputStream(new ByteArrayInputStream(buffer), lko)) {
             assertEquals(-1, lko.lastByteSeen);
@@ -137,7 +137,7 @@ public void testDataByteCalled_ctor() throws Exception {
     @Test
     public void testDataBytesCalled() throws Exception {
         final byte[] buffer = MessageDigestCalculatingInputStreamTest
-                .generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
+            .generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
         final ByteArrayInputStream bais = new ByteArrayInputStream(buffer);
         final ObservableInputStream ois = new ObservableInputStream(bais);
         final LastBytesKeepingObserver lko = new LastBytesKeepingObserver();
@@ -171,11 +171,9 @@ public void testDataBytesCalled() throws Exception {
     }
 
     @Test
-    public void testTimestamped() {
-        final byte[] buffer = MessageDigestCalculatingInputStreamTest
-            .generateRandomByteStream(IOUtils.DEFAULT_BUFFER_SIZE);
-    final ByteArrayInputStream bais = new ByteArrayInputStream(buffer);
-    final ObservableInputStream ois = new ObservableInputStream(bais);
-        
+    public void testGetObservers() {
+        final LastBytesKeepingObserver observer = new LastBytesKeepingObserver();
+        final ObservableInputStream ois = new ObservableInputStream(new NullInputStream(), observer);
+        assertEquals(observer, ois.getObservers().get(0));
     }
 }