Merge pull request quarkusio#45529 from geoand/rest-client-is

Remove unused context parameter in VertxClientInputStream
yrodiere · Jan 13, 2025 · c672a0f · c672a0f
2 parents bbe14b6 + c7b1aa3
commit c672a0f
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 14 deletions.
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
@@ -347,7 +347,7 @@ public void handle(AsyncResult<Void> flushed) {
                             //TODO: make timeout configureable
                             requestContext
                                     .setResponseEntityStream(
-                                            new VertxClientInputStream(clientResponse, 100000, requestContext));
+                                            new VertxClientInputStream(clientResponse, 100000));
                             requestContext.resume();
                         } else {
                             clientResponse.body(new Handler<>() {

diff --git a/...ime/src/main/java/org/jboss/resteasy/reactive/client/handlers/VertxClientInputStream.java b/...ime/src/main/java/org/jboss/resteasy/reactive/client/handlers/VertxClientInputStream.java
@@ -6,7 +6,6 @@
 import java.util.ArrayDeque;
 import java.util.Deque;
 
-import org.jboss.resteasy.reactive.client.impl.RestClientRequestContext;
 import org.jboss.resteasy.reactive.common.core.BlockingNotAllowedException;
 
 import io.netty.buffer.ByteBuf;
@@ -18,27 +17,16 @@
 
 class VertxClientInputStream extends InputStream {
 
-    public static final String MAX_REQUEST_SIZE_KEY = "io.quarkus.max-request-size";
     private final VertxBlockingInput exchange;
 
     private boolean closed;
     private boolean finished;
     private ByteBuf pooled;
-    private final RestClientRequestContext vertxResteasyReactiveRequestContext;
 
-    public VertxClientInputStream(HttpClientResponse response, long timeout,
-            RestClientRequestContext vertxResteasyReactiveRequestContext) {
-        this.vertxResteasyReactiveRequestContext = vertxResteasyReactiveRequestContext;
+    public VertxClientInputStream(HttpClientResponse response, long timeout) {
         this.exchange = new VertxBlockingInput(response, timeout);
     }
 
-    public VertxClientInputStream(HttpClientResponse request, long timeout, ByteBuf existing,
-            RestClientRequestContext vertxResteasyReactiveRequestContext) {
-        this.vertxResteasyReactiveRequestContext = vertxResteasyReactiveRequestContext;
-        this.exchange = new VertxBlockingInput(request, timeout);
-        this.pooled = existing;
-    }
-
     @Override
     public int read() throws IOException {
         byte[] b = new byte[1];