fail blocking read on read error

required for quarkusio/quarkus#4455
michalszynkiewicz · Oct 25, 2019 · d0ee454 · d0ee454
1 parent fbcff72
commit d0ee454
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/vertx/src/main/java/io/undertow/vertx/VertxHttpExchange.java b/vertx/src/main/java/io/undertow/vertx/VertxHttpExchange.java
@@ -374,10 +374,16 @@ public int readBytesAvailable() {
     @Override
     public ByteBuf readBlocking() throws IOException {
         synchronized (request.connection()) {
+            if (readError != null) {
+                throw new IOException(readError);
+            }
             while (input1 == null && !eof) {
                 try {
                     waitingForRead = true;
                     request.connection().wait();
+                    if (readError != null) {
+                        throw new IOException(readError);
+                    }
                 } catch (InterruptedException e) {
                     throw new InterruptedIOException(e.getMessage());
                 } finally {