Fix intermittent timeout in EventbusBridge testHookCreateSocketRejected

The TransportClient close handler can fire before the BridgeClient sets its
closeHandler callback via onSuccess, causing the close event to be silently
dropped. Track a pending close and replay it when the handler is set.

Signed-off-by: Thomas Segismont <tsegismont@gmail.com>

Author: tsegismont

vertx-web/src/test/java/io/vertx/ext/web/tests/handler/EventbusBridgeTest.java

@@ -1399,6 +1399,7 @@ Future<TransportClient> connect(WebSocketClient client, String address) {
         return client.connect("/eventbus/400/8ne8e94a/websocket").map(ws -> new TransportClient() {
           private Handler<JsonObject> handler;
           private Handler<Void> closeHandler;
+          private boolean closePending;
 
           {
             ws.handler(buff -> {
@@ -1422,6 +1423,8 @@ Future<TransportClient> connect(WebSocketClient client, String address) {
             ws.closeHandler(v -> {
               if (closeHandler != null) {
                 closeHandler.handle(v);
+              } else {
+                closePending = true;
               }
             });
           }
@@ -1434,6 +1437,10 @@ public void handler(Handler<JsonObject> handler) {
           @Override
           public void closeHandler(Handler<Void> handler) {
             this.closeHandler = handler;
+            if (closePending && handler != null) {
+              closePending = false;
+              handler.handle(null);
+            }
           }
 
           @Override
@@ -1464,6 +1471,7 @@ Future<TransportClient> connect(WebSocketClient client, String address) {
         return client.connect(address).map(ws -> new TransportClient() {
           private Handler<JsonObject> handler;
           private Handler<Void> closeHandler;
+          private boolean closePending;
 
           {
             ws.handler(buff -> {
@@ -1477,6 +1485,8 @@ Future<TransportClient> connect(WebSocketClient client, String address) {
             ws.closeHandler(v -> {
               if (closeHandler != null) {
                 closeHandler.handle(v);
+              } else {
+                closePending = true;
               }
             });
           }
@@ -1489,6 +1499,10 @@ public void handler(Handler<JsonObject> handler) {
           @Override
           public void closeHandler(Handler<Void> handler) {
             this.closeHandler = handler;
+            if (closePending && handler != null) {
+              closePending = false;
+              handler.handle(null);
+            }
           }
 
           @Override