Close stream when client responds with an entity

This shouldn't have an effect given the type of buffers we currently use, but if we change things in the future, this call will be necessary
bschuhmann · Jan 14, 2025 · 7841f90 · 7841f90
1 parent 90dd16b
commit 7841f90
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);
                                             }