From 33f8ffa079e6d3b8cd67baf470494e509e02ebc2 Mon Sep 17 00:00:00 2001
From: Yevhen Vasyliev <ye.vasyliev@gmail.com>
Date: Sun, 17 May 2026 10:04:08 +0300
Subject: [PATCH] feat: make `OutputToReadStream` compatible with Vert.x 4

---
 .../io/cloudonix/vertx/javaio/OutputToReadStream.java     | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/main/java/io/cloudonix/vertx/javaio/OutputToReadStream.java b/src/main/java/io/cloudonix/vertx/javaio/OutputToReadStream.java
index af95383..da96779 100644
--- a/src/main/java/io/cloudonix/vertx/javaio/OutputToReadStream.java
+++ b/src/main/java/io/cloudonix/vertx/javaio/OutputToReadStream.java
@@ -71,7 +71,13 @@ public OutputToReadStream(Vertx vertx) {
 	 */
 	public Future<Void> pipeFromInput(InputStream source, WriteStream<Buffer> sink) {
 		Promise<Void> promise = Promise.promise();
-		pipeTo(sink).andThen(promise);
+		pipeTo(sink).onComplete(ar -> {
+			if (ar.succeeded()) {
+				promise.complete(ar.result());
+			} else {
+				promise.fail(ar.cause());
+			}
+		});
 		ForkJoinPool.commonPool().submit(() -> {
 			try (final InputStream is = source; final OutputStream os = this){
 				source.transferTo(this);