fix demos

Author: lucifer4j

src/main/java/io/vertx/ext/eventbus/bridge/tcp/impl/HttpJsonRPCStreamEventBusBridgeImpl.java

@@ -35,6 +35,9 @@ public void handle(HttpServerRequest socket) {
       () -> new BridgeEventImpl<>(BridgeEventType.SOCKET_CREATED, null, socket),
       // on success
       () -> {
+        // TODO: make these maps persistent across requests otherwise replies won't work because
+        //  http client cannot reply again in the same request after receiving a response and has
+        //  to make a new request.
         final Map<String, MessageConsumer<?>> registry = new ConcurrentHashMap<>();
 
         socket.exceptionHandler(t -> {

src/main/resources/ws.html

@@ -17,9 +17,15 @@
     ws.onclose = console.log;
     ws.onerror = console.error;
 
-    function sendMsg() {
-      var message = document.getElementById("payload").value;
-      ws.send(message);
+    async function sendMsg() {
+      let message = document.getElementById("payload").value;
+      await fetch("http://localhost:8080/jsonrpc", {
+        method: 'POST',
+        headers: {
+          'Content-Type': 'application/json',
+        },
+        body: message,
+      });
     }
   </script>
   <title>Websockets Bridge Example</title>

src/test/java/io/vertx/ext/eventbus/bridge/tcp/InteropWebSocketServer.java

@@ -8,6 +8,7 @@
 import io.vertx.core.http.HttpHeaders;
 import io.vertx.core.http.HttpServerRequest;
 import io.vertx.core.http.HttpServerResponse;
+import io.vertx.core.http.HttpServerResponse;
 import io.vertx.core.json.JsonObject;
 import io.vertx.ext.bridge.PermittedOptions;
 import io.vertx.ext.web.client.WebClient;