import java.net.SocketAddress;
import java.nio.charset.Charset;
public class WebSocketEchoClient extends AbstractClientExample {
public static void main(String[] args) {
SocketAddress socketAddress = getServerAddress(WebSocketEchoServer.class, args);
<BUG>HttpClient.newClient(socketAddress)
.createGet("/ws")</BUG>
.requestWebSocketUpgrade()
.doOnNext(resp -> logger.info(resp.toString()))
.flatMap(WebSocketResponse::getWebSocketConnection)

import java.net.SocketAddress;
import java.nio.charset.Charset;
public class WebSocketEchoClient extends AbstractClientExample {
public static void main(String[] args) {
SocketAddress socketAddress = getServerAddress(WebSocketEchoServer.class, args);
HttpClient.newClient(socketAddress)
.enableWireLogging(LogLevel.DEBUG)
.createGet("/ws")
.requestWebSocketUpgrade()
.doOnNext(resp -> logger.info(resp.toString()))
.flatMap(WebSocketResponse::getWebSocketConnection)
