import rx.Observable;
import java.util.concurrent.TimeUnit;
public final class StreamingServer extends AbstractServerExample {
public static void main(final String[] args) {
HttpServer<ByteBuf, ByteBuf> server;
<BUG>server = HttpServer.newServer()
.start((req, resp) -></BUG>
resp.writeStringAndFlushOnEach(
Observable.interval(10, TimeUnit.MILLISECONDS)
.onBackpressureDrop()

import rx.Observable;
import java.util.concurrent.TimeUnit;
public final class StreamingServer extends AbstractServerExample {
public static void main(final String[] args) {
HttpServer<ByteBuf, ByteBuf> server;
server = HttpServer.newServer()
.enableWireLogging(LogLevel.DEBUG)
.start((req, resp) ->
resp.writeStringAndFlushOnEach(
Observable.interval(10, TimeUnit.MILLISECONDS)
.onBackpressureDrop()
