test/java/net/httpclient/HttpInputStreamTest.java

@@ -31,10 +31,11 @@
 import jdk.incubator.http.HttpRequest;
 import jdk.incubator.http.HttpResponse;
 import java.nio.ByteBuffer;
 import java.nio.charset.Charset;
 import java.util.Locale;
+import java.util.List;
 import java.util.Optional;
 import java.util.concurrent.ArrayBlockingQueue;
 import java.util.concurrent.BlockingQueue;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CompletionStage;

@@ -184,14 +185,17 @@
                 this.subscription = s;
                 s.request(Math.max(2, buffers.remainingCapacity() + 1));
             }
 
             @Override
-            public synchronized void onNext(ByteBuffer t) {
+            public synchronized void onNext(List<ByteBuffer> t) {
+                if (t.size() > 1) 
+                    System.out.println ("XXX " + t.size());
                 try {
                     if (DEBUG) System.err.println("next buffer received");
-                    buffers.put(t);
+                    for (ByteBuffer b : t)
+                        buffers.put(b);
                     if (DEBUG) System.err.println("buffered offered");
                 } catch (Exception ex) {
                     failed = ex;
                     try {
                         close();

@@ -207,11 +211,11 @@
             }
 
             @Override
             public synchronized void onComplete() {
                 subscription = null;
-                onNext(LAST);
+                onNext(List.of(LAST));
             }
 
             @Override
             public void close() throws IOException {
                 synchronized (this) {