--- old/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/Http1Response.java	2017-08-12 14:14:32.000000000 +0100
+++ new/src/jdk.incubator.httpclient/share/classes/jdk/incubator/http/Http1Response.java	2017-08-12 14:14:31.000000000 +0100
@@ -27,6 +27,7 @@
 
 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;
@@ -114,21 +115,19 @@
         return clen;
     }
 
-    public CompletableFuture<T> readBody(
-            HttpResponse.BodyProcessor<T> p,
-            boolean return2Cache,
-            Executor executor) {
-        final BlockingPushPublisher<ByteBuffer> publisher = new BlockingPushPublisher<>();
+    public CompletableFuture<T> readBody(HttpResponse.BodyProcessor<T> p,
+                                         boolean return2Cache,
+                                         Executor executor) {
+        BlockingPushPublisher<List<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) {
+    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 HttpResponse.BodyProcessor<T> pusher = p;
         final CompletableFuture<T> cf = p.getBody().toCompletableFuture();
 
         int clen0;