Extract io exception checking in a method

jline · May 29, 2018 · 24b5660 · 24b5660
1 parent 5bb4939
commit 24b5660
Showing 1 changed file with 9 additions and 9 deletions.
diff --git a/terminal/src/main/java/org/jline/utils/NonBlockingPumpInputStream.java b/terminal/src/main/java/org/jline/utils/NonBlockingPumpInputStream.java
@@ -55,13 +55,9 @@ private int wait(ByteBuffer buffer, long timeout) throws IOException {
             notifyAll();
             try {
                 wait(timeout);
-                if (ioException != null) {
-                    throw ioException;
-                }
+                checkIoException();
             } catch (InterruptedException e) {
-                if (ioException != null) {
-                    throw ioException;
-                }
+                checkIoException();
                 throw new InterruptedIOException();
             }
             if (!isInfinite) {
@@ -100,9 +96,7 @@ public synchronized int available() {
 
     @Override
     public synchronized int read(long timeout, boolean isPeek) throws IOException {
-        if (ioException != null) {
-            throw ioException;
-        }
+        checkIoException();
         // Blocks until more input is available or the reader is closed.
         int res = wait(readBuffer, timeout);
         if (res >= 0) {
@@ -117,6 +111,12 @@ public synchronized void setIoException(IOException exception) {
         notifyAll();
     }
 
+    protected synchronized void checkIoException() throws IOException {
+        if (ioException != null) {
+            throw ioException;
+        }
+    }
+
     synchronized void write(byte[] cbuf, int off, int len) throws IOException {
         while (len > 0) {
             // Blocks until there is new space available for buffering or the