http2client should not cache the InputStream eg:HTTP 1.1 Chunked_transfer_encoding (#2420)

hdfg159 · web-flow · commit 80e6ecb69eba · 2024-05-17T09:18:49.000-03:00
diff --git a/java11/src/main/java/feign/http2client/Http2Client.java b/java11/src/main/java/feign/http2client/Http2Client.java
@@ -22,8 +22,8 @@
 import feign.Request.ProtocolVersion;
 import feign.Response;
 import feign.Util;
-import java.io.ByteArrayInputStream;
 import java.io.IOException;
+import java.io.InputStream;
 import java.lang.ref.SoftReference;
 import java.net.URI;
 import java.net.URISyntaxException;
@@ -97,9 +97,9 @@ public Response execute(Request request, Options options) throws IOException {
     }
 
     HttpClient clientForRequest = getOrCreateClient(options);
-    HttpResponse<byte[]> httpResponse;
+    HttpResponse<InputStream> httpResponse;
     try {
-      httpResponse = clientForRequest.send(httpRequest, BodyHandlers.ofByteArray());
+      httpResponse = clientForRequest.send(httpRequest, BodyHandlers.ofInputStream());
     } catch (final InterruptedException e) {
       Thread.currentThread().interrupt();
       throw new IOException(e);
@@ -119,19 +119,17 @@ public CompletableFuture<Response> execute(
     }
 
     HttpClient clientForRequest = getOrCreateClient(options);
-    CompletableFuture<HttpResponse<byte[]>> future =
-        clientForRequest.sendAsync(httpRequest, HttpResponse.BodyHandlers.ofByteArray());
+    CompletableFuture<HttpResponse<InputStream>> future =
+        clientForRequest.sendAsync(httpRequest, HttpResponse.BodyHandlers.ofInputStream());
     return future.thenApply(httpResponse -> toFeignResponse(request, httpResponse));
   }
 
-  protected Response toFeignResponse(Request request, HttpResponse<byte[]> httpResponse) {
+  protected Response toFeignResponse(Request request, HttpResponse<InputStream> httpResponse) {
     final OptionalLong length = httpResponse.headers().firstValueAsLong("Content-Length");
 
     return Response.builder()
         .protocolVersion(enumForName(ProtocolVersion.class, httpResponse.version()))
-        .body(
-            new ByteArrayInputStream(httpResponse.body()),
-            length.isPresent() ? (int) length.getAsLong() : null)
+        .body(httpResponse.body(), length.isPresent() ? (int) length.getAsLong() : null)
         .reason(httpResponse.headers().firstValue("Reason-Phrase").orElse(null))
         .request(request)
         .status(httpResponse.statusCode())
