@@ -111,7 +111,7 @@ public void finished() throws IOException {
111111 /**
112112 * Creates a new ObservableInputStream for the given InputStream.
113113 *
114- * @param inputStream the input stream to proxy .
114+ * @param inputStream the input stream to observe .
115115 */
116116 public ObservableInputStream (final InputStream inputStream ) {
117117 this (inputStream , new ArrayList <>());
@@ -120,8 +120,8 @@ public ObservableInputStream(final InputStream inputStream) {
120120 /**
121121 * Creates a new ObservableInputStream for the given InputStream.
122122 *
123- * @param inputStream the input stream to proxy .
124- * @param observers List of callbacks.
123+ * @param inputStream the input stream to observe .
124+ * @param observers List of observer callbacks.
125125 */
126126 private ObservableInputStream (final InputStream inputStream , final List <Observer > observers ) {
127127 super (inputStream );
@@ -131,8 +131,8 @@ private ObservableInputStream(final InputStream inputStream, final List<Observer
131131 /**
132132 * Creates a new ObservableInputStream for the given InputStream.
133133 *
134- * @param inputStream the input stream to proxy .
135- * @param observers List of callbacks.
134+ * @param inputStream the input stream to observe .
135+ * @param observers List of observer callbacks.
136136 * @since 2.9.0
137137 */
138138 public ObservableInputStream (final InputStream inputStream , final Observer ... observers ) {
@@ -142,7 +142,7 @@ public ObservableInputStream(final InputStream inputStream, final Observer... ob
142142 /**
143143 * Adds an Observer.
144144 *
145- * @param observer the observer to add
145+ * @param observer the observer to add.
146146 */
147147 public void add (final Observer observer ) {
148148 observers .add (observer );
@@ -178,7 +178,7 @@ public void consume() throws IOException {
178178 /**
179179 * Gets all currently registered observers.
180180 *
181- * @return a list of the currently registered observers
181+ * @return a list of the currently registered observers.
182182 * @since 2.9.0
183183 */
184184 public List <Observer > getObservers () {
0 commit comments