From c7b1aa31f6fa8364fd91af2ee5b0b74f3be822e3 Mon Sep 17 00:00:00 2001
From: Georgios Andrianakis <geoand@gmail.com>
Date: Mon, 13 Jan 2025 14:30:34 +0200
Subject: [PATCH] Remove unused context parameter in VertxClientInputStream

---
 .../client/handlers/ClientSendRequestHandler.java  |  2 +-
 .../client/handlers/VertxClientInputStream.java    | 14 +-------------
 2 files changed, 2 insertions(+), 14 deletions(-)

diff --git a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java
index ea066ae352e12..c1f5b38ee4844 100644
--- a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/ClientSendRequestHandler.java
+++ b/independent-projects/resteasy-reactive/client/runtime/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/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/VertxClientInputStream.java b/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/VertxClientInputStream.java
index 69fa50754a8a0..19d4427b6fc66 100644
--- a/independent-projects/resteasy-reactive/client/runtime/src/main/java/org/jboss/resteasy/reactive/client/handlers/VertxClientInputStream.java
+++ b/independent-projects/resteasy-reactive/client/runtime/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];