Merge pull request #45569 from geoand/rest-client-close

Close stream when client responds with an entity
quarkusio · Jan 14, 2025 · 947988b · 947988b
2 parents 25891df + 7841f90
commit 947988b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/...n/java/org/jboss/resteasy/reactive/client/handlers/ClientResponseCompleteRestHandler.java b/...n/java/org/jboss/resteasy/reactive/client/handlers/ClientResponseCompleteRestHandler.java
@@ -120,6 +120,9 @@ public static ResponseImpl mapToResponse(RestClientRequestContext context,
                     if (entity != null) {
                         builder.entity(entity);
                     }
+                    if (entity != null) {
+                        entityStream.close();
+                    }
                 }
             }
         } else {

diff --git a/...e/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java b/...e/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java
@@ -358,7 +358,7 @@ public void handle(AsyncResult<Buffer> ar) {
                                         try {
                                             if (buffer.length() > 0) {
                                                 requestContext.setResponseEntityStream(
-                                                        new ByteBufInputStream(buffer.getByteBuf()));
+                                                        new ByteBufInputStream(buffer.getByteBuf(), true));
                                             } else {
                                                 requestContext.setResponseEntityStream(null);
                                             }