import static io.netty.handler.codec.http.HttpResponseStatus.*;
public final class HttpLoadBalancingClient extends AbstractClientExample {
public static void main(String[] args) {
final Observable<SocketAddress> hosts = Observable.just(startNewServer(OK), startNewServer(OK),
startNewServer(SERVICE_UNAVAILABLE));
<BUG>HttpClient.newClient(HttpLoadBalancer.create(hosts))
.createGet("/hello")</BUG>
.doOnNext(resp -> logger.info(resp.toString()))
.flatMap((HttpClientResponse<ByteBuf> resp) ->
resp.getContent()

import static io.netty.handler.codec.http.HttpResponseStatus.*;
public final class HttpLoadBalancingClient extends AbstractClientExample {
public static void main(String[] args) {
final Observable<SocketAddress> hosts = Observable.just(startNewServer(OK), startNewServer(OK),
startNewServer(SERVICE_UNAVAILABLE));
HttpClient.newClient(HttpLoadBalancer.create(hosts))
.enableWireLogging(LogLevel.DEBUG)
.createGet("/hello")
.doOnNext(resp -> logger.info(resp.toString()))
.flatMap((HttpClientResponse<ByteBuf> resp) ->
resp.getContent()
