import io.reactivex.netty.protocol.http.client.HttpClientResponse;
import java.net.SocketAddress;
public final class HelloSseClient extends AbstractClientExample {
public static void main(String[] args) {
SocketAddress serverAddress = getServerAddress(HelloSseServer.class, args);
<BUG>HttpClient.newClient(serverAddress)
.createGet("/sse")</BUG>
.doOnNext(resp -> logger.info(resp.toString()))
.flatMap(HttpClientResponse::getContentAsServerSentEvents)
.take(10)

import io.reactivex.netty.protocol.http.client.HttpClientResponse;
import java.net.SocketAddress;
public final class HelloSseClient extends AbstractClientExample {
public static void main(String[] args) {
SocketAddress serverAddress = getServerAddress(HelloSseServer.class, args);
HttpClient.newClient(serverAddress)
.enableWireLogging(LogLevel.DEBUG)
.createGet("/sse")
.doOnNext(resp -> logger.info(resp.toString()))
.flatMap(HttpClientResponse::getContentAsServerSentEvents)
.take(10)
