This:
final HttpServer server = vertx.createHttpServer();
final Flowable<HttpServerRequest> requestFlowable = server.requestStream().toFlowable();
or
that:
final Flowable<HttpServerRequest> requestFlowable = vertx.createHttpServer()
.requestStream().toFlowable();
I lean towards #2