test/java/net/httpclient/HttpInputStreamTest.java

*** 31,40 ****
--- 31,41 ----
  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,197 ****
                  this.subscription = s;
                  s.request(Math.max(2, buffers.remainingCapacity() + 1));
              }
  
              @Override
!             public synchronized void onNext(ByteBuffer t) {
                  try {
                      if (DEBUG) System.err.println("next buffer received");
!                     buffers.put(t);
                      if (DEBUG) System.err.println("buffered offered");
                  } catch (Exception ex) {
                      failed = ex;
                      try {
                          close();
--- 185,201 ----
                  this.subscription = s;
                  s.request(Math.max(2, buffers.remainingCapacity() + 1));
              }
  
              @Override
!             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");
!                     for (ByteBuffer b : t)
!                         buffers.put(b);
                      if (DEBUG) System.err.println("buffered offered");
                  } catch (Exception ex) {
                      failed = ex;
                      try {
                          close();
*** 207,217 ****
              }
  
              @Override
              public synchronized void onComplete() {
                  subscription = null;
!                 onNext(LAST);
              }
  
              @Override
              public void close() throws IOException {
                  synchronized (this) {
--- 211,221 ----
              }
  
              @Override
              public synchronized void onComplete() {
                  subscription = null;
!                 onNext(List.of(LAST));
              }
  
              @Override
              public void close() throws IOException {
                  synchronized (this) {