Executeblocking with DB...

vertx.executeBlocking(execute -> {
    Observable.from(res.result().getRows()).subscribe(row -> {

    // Do something with row here...

    }, err -> {
        logger.error("Error while reading resultset.", err);

        err.printStackTrace();
        execute.fail(err);
    }, () -> {
        execute.complete();
    });
    }, blockingResult -> {
    con.close();
    isRunning.set(false);
});