Uses of Interface
io.reactiverse.pgclient.PgStream

Packages that use PgStream

Package	Description
io.reactiverse.pgclient
io.reactiverse.reactivex.pgclient
io.reactiverse.rxjava.pgclient

Uses of PgStream in io.reactiverse.pgclient

Methods in io.reactiverse.pgclient that return PgStream

Modifier and Type	Method and Description
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)
PgStream<T>	PgStream.pause()
PgStream<T>	PgStream.resume()

Uses of PgStream in io.reactiverse.reactivex.pgclient

Methods in io.reactiverse.reactivex.pgclient that return PgStream

Modifier and Type	Method and Description
PgStream	PgStream.getDelegate()

Methods in io.reactiverse.reactivex.pgclient with parameters of type PgStream

Modifier and Type	Method and Description
static <T> PgStream<T>	PgStream.newInstance(PgStream arg)
static <T> PgStream<T>	PgStream.newInstance(PgStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Constructors in io.reactiverse.reactivex.pgclient with parameters of type PgStream

Constructor and Description
PgStream(PgStream delegate)
PgStream(PgStream delegate, io.vertx.lang.rx.TypeArg<T> typeArg_0)

Uses of PgStream in io.reactiverse.rxjava.pgclient

Methods in io.reactiverse.rxjava.pgclient that return PgStream

Modifier and Type	Method and Description
PgStream	PgStream.getDelegate()

Methods in io.reactiverse.rxjava.pgclient with parameters of type PgStream

Modifier and Type	Method and Description
static <T> PgStream<T>	PgStream.newInstance(PgStream arg)
static <T> PgStream<T>	PgStream.newInstance(PgStream arg, io.vertx.lang.rx.TypeArg<T> __typeArg_T)

Constructors in io.reactiverse.rxjava.pgclient with parameters of type PgStream

Constructor and Description
PgStream(PgStream delegate)
PgStream(PgStream delegate, io.vertx.lang.rx.TypeArg<T> typeArg_0)