eclipse-vertx#5049 fix Pipe's race condition

Fix issue: eclipse-vertx#5049 Signed-off-by: Nils Renaud <renaud.nils@gmail.com>
NilsRenaud · Dec 22, 2023 · 3bb8d6c · 3bb8d6c
1 parent e66fe44
commit 3bb8d6c
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/java/io/vertx/core/streams/impl/PipeImpl.java b/src/main/java/io/vertx/core/streams/impl/PipeImpl.java
@@ -84,7 +84,6 @@ public void to(WriteStream<T> ws, Handler<AsyncResult<Void>> completionHandler)
         ws.drainHandler(drainHandler);
       }
     });
-    src.resume();
     result.future().onComplete(ar -> {
       try {
         src.handler(null);
@@ -109,6 +108,7 @@ public void to(WriteStream<T> ws, Handler<AsyncResult<Void>> completionHandler)
         handleFailure(err, completionHandler);
       }
     });
+    src.resume();
   }
 
   private void handleSuccess(Handler<AsyncResult<Void>> completionHandler) {