HTTP/1.1 async protocol handler to read message data more greedily

Author: ok2c

httpcore5/src/main/java/org/apache/hc/core5/http/impl/nio/AbstractHttp1StreamDuplexer.java

@@ -278,17 +278,16 @@ public final void onInput(final ByteBuffer src) throws HttpException, IOExceptio
         }
 
         boolean endOfStream = false;
-        if (incomingMessage == null) {
-            final int bytesRead = inbuf.fill(ioSession);
-            if (bytesRead > 0) {
-                inTransportMetrics.incrementBytesTransferred(bytesRead);
-            }
-            endOfStream = bytesRead == -1;
-        }
 
         do {
             if (incomingMessage == null) {
 
+                final int bytesRead = inbuf.fill(ioSession);
+                if (bytesRead > 0) {
+                    inTransportMetrics.incrementBytesTransferred(bytesRead);
+                }
+                endOfStream = bytesRead == -1;
+
                 final IncomingMessage messageHead = parseMessageHead(endOfStream);
                 if (messageHead != null) {
                     this.version = messageHead.getVersion();