src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/Http1Response.java

*** 25,34 ****
--- 25,35 ----
  
  package jdk.incubator.http;
  
  import java.io.IOException;
  import java.nio.ByteBuffer;
+ import java.util.List;
  import java.util.concurrent.CompletableFuture;
  import java.util.concurrent.Executor;
  import jdk.incubator.http.internal.common.Log;
  import static jdk.incubator.http.HttpClient.Version.HTTP_1_1;
  
*** 116,133 ****
  
      public CompletableFuture<T> readBody(
              HttpResponse.BodyProcessor<T> p,
              boolean return2Cache,
              Executor executor) {
!         final BlockingPushPublisher<ByteBuffer> publisher = new BlockingPushPublisher<>();
          return readBody(p, return2Cache, publisher, executor);
      }
  
      private CompletableFuture<T> readBody(
              HttpResponse.BodyProcessor<T> p,
              boolean return2Cache,
!             AbstractPushPublisher<ByteBuffer> publisher,
              Executor executor) {
          this.return2Cache = return2Cache;
          final jdk.incubator.http.HttpResponse.BodyProcessor<T> pusher = p;
          final CompletableFuture<T> cf = p.getBody().toCompletableFuture();
  
--- 117,134 ----
  
      public CompletableFuture<T> readBody(
              HttpResponse.BodyProcessor<T> p,
              boolean return2Cache,
              Executor executor) {
!         final BlockingPushPublisher<List<ByteBuffer>> publisher = new BlockingPushPublisher<>();
          return readBody(p, return2Cache, publisher, executor);
      }
  
      private CompletableFuture<T> readBody(
              HttpResponse.BodyProcessor<T> p,
              boolean return2Cache,
!             AbstractPushPublisher<List<ByteBuffer>> publisher,
              Executor executor) {
          this.return2Cache = return2Cache;
          final jdk.incubator.http.HttpResponse.BodyProcessor<T> pusher = p;
          final CompletableFuture<T> cf = p.getBody().toCompletableFuture();