@Test @SuppressWarnings("unchecked") public void shouldInitializeEmptyHeaders() { webSocketClient.execute(TEST_URI, session -> Mono.empty()) .subscribe(); ArgumentCaptor<WebSocketConnectOptions> optionsCaptor = ArgumentCaptor.forClass(WebSocketConnectOptions.class); verify(mockHttpClient).webSocket(optionsCaptor.capture(), any(Handler.class)); assertThat(optionsCaptor.getValue().getPort()).isEqualTo(TEST_URI.getPort()); assertThat(optionsCaptor.getValue().getHost()).isEqualTo(TEST_URI.getHost()); assertThat(optionsCaptor.getValue().getURI()).isEqualTo(TEST_URI.getPath()); assertThat(optionsCaptor.getValue().getHeaders()).isEmpty(); }
@Override public Mono<Void> execute(URI uri, WebSocketHandler handler) { return execute(uri, new HttpHeaders(), handler); }
VertxWebSocketClient implements WebSocketClient { @Override public Mono<Void> execute(URI uri, WebSocketHandler handler) { return execute(uri, new HttpHeaders(), handler); } }
VertxWebSocketClient implements WebSocketClient { @Override public Mono<Void> execute(URI uri, WebSocketHandler handler) { return execute(uri, new HttpHeaders(), handler); } VertxWebSocketClient(Vertx vertx);  VertxWebSocketClient(Vertx vertx, HttpClientOptions options); }
VertxWebSocketClient implements WebSocketClient { @Override public Mono<Void> execute(URI uri, WebSocketHandler handler) { return execute(uri, new HttpHeaders(), handler); } VertxWebSocketClient(Vertx vertx);  VertxWebSocketClient(Vertx vertx, HttpClientOptions options); @Override Mono<Void> execute(URI uri, WebSocketHandler handler); @Override Mono<Void> execute(URI uri, HttpHeaders headers, WebSocketHandler handler); }
VertxWebSocketClient implements WebSocketClient { @Override public Mono<Void> execute(URI uri, WebSocketHandler handler) { return execute(uri, new HttpHeaders(), handler); } VertxWebSocketClient(Vertx vertx);  VertxWebSocketClient(Vertx vertx, HttpClientOptions options); @Override Mono<Void> execute(URI uri, WebSocketHandler handler); @Override Mono<Void> execute(URI uri, HttpHeaders headers, WebSocketHandler handler);  }