This:
final HttpServer server = vertx.createHttpServer();
final Flowable<HttpServerRequest> requestFlowable = server.requestStream().toFlowable();
or
that:
final Flowable<HttpServerRequest> requestFlowable = vertx.createHttpServer()
.requestStream().toFlowable();
Yes, #2 is probably cleaner