ReleasableResource used

Signed-off-by: David Kral <[email protected]>
helidon-io · Sep 21, 2023 · 3dde247 · 3dde247
1 parent 3a9c14a
commit 3dde247
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/webclient/http2/src/main/java/io/helidon/webclient/http2/Http2ClientRequestImpl.java b/webclient/http2/src/main/java/io/helidon/webclient/http2/Http2ClientRequestImpl.java
@@ -192,7 +192,7 @@ private Http2ClientResponseImpl invokeWithServices(Http2CallChainBase callChain,
                                            serviceResponse.inputStream().orElse(null),
                                            mediaContext(),
                                            resolvedUri,
-                                           (Http2ClientStream) serviceResponse.connection(),
+                                           serviceResponse.connection(),
                                            complete,
                                            callChain::closeResponse);
 

diff --git a/webclient/http2/src/main/java/io/helidon/webclient/http2/Http2ClientResponseImpl.java b/webclient/http2/src/main/java/io/helidon/webclient/http2/Http2ClientResponseImpl.java
@@ -36,13 +36,14 @@
 import io.helidon.webclient.api.ClientResponseEntity;
 import io.helidon.webclient.api.ClientUri;
 import io.helidon.webclient.api.HttpClientConfig;
+import io.helidon.webclient.api.ReleasableResource;
 
 class Http2ClientResponseImpl implements Http2ClientResponse {
     private final HttpClientConfig httpClientConfig;
     private final Status responseStatus;
     private final ClientRequestHeaders requestHeaders;
     private final ClientResponseHeaders responseHeaders;
-    private final Http2ClientStream stream;
+    private final ReleasableResource stream;
     private final CompletableFuture<Void> complete;
     private final Runnable closeResponseRunnable;
     private final CompletableFuture<ClientResponseTrailers> responseTrailers;
@@ -60,7 +61,7 @@ class Http2ClientResponseImpl implements Http2ClientResponse {
                             InputStream inputStream, // input stream is nullable - no response entity
                             MediaContext mediaContext,
                             ClientUri lastEndpointUri,
-                            Http2ClientStream stream,
+                            ReleasableResource stream,
                             CompletableFuture<Void> complete,
                             Runnable closeResponseRunnable) {
         this.httpClientConfig = httpClientConfig;
@@ -129,7 +130,7 @@ public ReadableEntity entity() {
     }
 
     Http2ClientStream stream() {
-        return stream;
+        return (Http2ClientStream) stream;
     }
 
     private BufferData readBytes(int estimate) {