Replace deprecated Vert.x Pump use in REST Client

geoand · Jan 13, 2025 · 1417c2c · 1417c2c
1 parent c672a0f
commit 1417c2c
Showing 1 changed file with 23 additions and 25 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
@@ -308,33 +308,31 @@ public void handle(AsyncResult<AsyncFile> asyncFileOpened) {
                                                                 return;
                                                             }
                                                             final AsyncFile tmpAsyncFile = asyncFileOpened.result();
-                                                            final Pump downloadPump = Pump.pump(clientResponse,
-                                                                    tmpAsyncFile);
-                                                            downloadPump.start();
-
-                                                            clientResponse.resume();
-                                                            clientResponse.endHandler(new Handler<>() {
-                                                                public void handle(Void event) {
-                                                                    tmpAsyncFile.flush(new Handler<>() {
-                                                                        public void handle(AsyncResult<Void> flushed) {
-                                                                            if (flushed.failed()) {
-                                                                                reportFinish(flushed.cause(),
-                                                                                        requestContext);
-                                                                                requestContext.resume(flushed.cause());
-                                                                                return;
-                                                                            }
-
-                                                                            if (loggingScope != LoggingScope.NONE) {
-                                                                                clientLogger.logRequest(
-                                                                                        httpClientRequest, null, false);
-                                                                            }
-
-                                                                            requestContext.setTmpFilePath(tmpFilePath);
-                                                                            requestContext.resume();
+                                                            clientResponse.pipeTo(tmpAsyncFile,
+                                                                    new Handler<>() {
+                                                                        @Override
+                                                                        public void handle(AsyncResult<Void> event) {
+                                                                            tmpAsyncFile.flush(new Handler<>() {
+                                                                                public void handle(AsyncResult<Void> flushed) {
+                                                                                    if (flushed.failed()) {
+                                                                                        reportFinish(flushed.cause(),
+                                                                                                requestContext);
+                                                                                        requestContext.resume(flushed.cause());
+                                                                                        return;
+                                                                                    }
+
+                                                                                    if (loggingScope != LoggingScope.NONE) {
+                                                                                        clientLogger.logRequest(
+                                                                                                httpClientRequest, null, false);
+                                                                                    }
+
+                                                                                    requestContext.setTmpFilePath(tmpFilePath);
+                                                                                    requestContext.resume();
+                                                                                }
+                                                                            });
                                                                         }
                                                                     });
-                                                                }
-                                                            });
+                                                            clientResponse.resume();
                                                         }
                                                     });
                                         }