import io.reactivex.netty.protocol.http.server.HttpServer;
import static rx.Observable.*;
public final class HelloWorldServer extends AbstractServerExample {
public static void main(final String[] args) {
HttpServer<ByteBuf, ByteBuf> server;
<BUG>server = HttpServer.newServer()
.start((req, resp) -></BUG>
resp.writeString(just("Hello World!"))
);
if (shouldWaitForShutdown(args)) {

import io.reactivex.netty.protocol.http.server.HttpServer;
import static rx.Observable.*;
public final class HelloWorldServer extends AbstractServerExample {
public static void main(final String[] args) {
HttpServer<ByteBuf, ByteBuf> server;
server = HttpServer.newServer()
.enableWireLogging(LogLevel.DEBUG)
.start((req, resp) ->
resp.writeString(just("Hello World!"))
);
if (shouldWaitForShutdown(args)) {
