Remove usage of Handler/AsyncResult idiom.

vert-x3 · Sep 12, 2024 · abfdb3b · abfdb3b
1 parent c0b7aa9
commit abfdb3b
Showing 1 changed file with 3 additions and 1 deletion.
diff --git 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<Vertx> res = clusteredVertx(options);
+      res.onComplete(ar -> {
         try {
           if (ar.failed()) {
             ar.cause().printStackTrace();