From abfdb3b6a7ac966b52ee30bf65dbc63da2b65587 Mon Sep 17 00:00:00 2001 From: Julien Viet Date: Thu, 12 Sep 2024 17:26:09 +0200 Subject: [PATCH] Remove usage of Handler/AsyncResult idiom. --- .../java/io/vertx/core/eventbus/ZKFaultToleranceTest.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/test/java/io/vertx/core/eventbus/ZKFaultToleranceTest.java b/src/test/java/io/vertx/core/eventbus/ZKFaultToleranceTest.java index 2f65249..69c9b0b 100644 --- a/src/test/java/io/vertx/core/eventbus/ZKFaultToleranceTest.java +++ b/src/test/java/io/vertx/core/eventbus/ZKFaultToleranceTest.java @@ -16,6 +16,7 @@ package io.vertx.core.eventbus; +import io.vertx.core.Future; import io.vertx.core.Vertx; import io.vertx.core.VertxOptions; import io.vertx.core.buffer.Buffer; @@ -41,7 +42,8 @@ protected void startNodes(int numNodes, VertxOptions options) { for (int i = 0; i < numNodes; i++) { int index = i; options.getEventBusOptions().setHost("localhost").setPort(0); - clusteredVertx(options, ar -> { + Future res = clusteredVertx(options); + res.onComplete(ar -> { try { if (ar.failed()) { ar.cause().printStackTrace();