@Get(value = "/users/demo», produces = MediaType.APPLICATION_JSON)
public Flowable<User> getDemoUsers() {
    var jooqQuery = dslContext.select(USERS.ID, USERS.EMAIL)
                              .from(USERS)
                              .where(USERS.EMAIL.contains("@demo"))
                              .orderBy(USERS.ID);
    var query = jooqQuery.getSQL();
    var values = jooqQuery.getBindValues();


    return Flowable.fromFuture(connection.inTransaction(c -> connection.sendPreparedStatement(query, values)))
                   .flatMap(result -> Flowable.fromIterable(() -> result.getRows().iterator()))
                   .map(r -> new User(r.getLong(USERS.ID.getName()), r.getString(USERS.EMAIL.getName())))
                   .doOnError(error -> {
                       throw new RuntimeException(error);
                   });
}