PgStream<Row> |
PgPreparedQuery.createStream(int fetch,
Tuple args)
Execute the prepared query with a cursor and createStream the result.
|
PgStream<T> |
PgStream.endHandler(io.vertx.core.Handler<Void> endHandler) |
PgStream<T> |
PgStream.exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
PgStream<T> |
PgStream.handler(io.vertx.core.Handler<T> handler) |
static <T> PgStream<T> |
PgStream.newInstance(PgStream arg) |
static <T> PgStream<T> |
PgStream.newInstance(PgStream arg,
io.vertx.lang.rx.TypeArg<T> __typeArg_T) |
PgStream<T> |
PgStream.pause() |
PgStream<T> |
PgStream.resume() |