Uses of Interface
io.reactiverse.pgclient.pubsub.PgSubscriber

Packages that use PgSubscriber

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

Uses of PgSubscriber in io.reactiverse.pgclient.pubsub

Methods in io.reactiverse.pgclient.pubsub that return PgSubscriber

Modifier and Type	Method and Description
PgSubscriber	PgSubscriber.closeHandler(io.vertx.core.Handler<Void> handler) Set an handler called when the subscriber is closed.
PgSubscriber	PgSubscriber.connect(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler) Connect the subscriber to Postgres.
PgSubscriber	PgSubscriber.reconnectPolicy(Function<Integer,Long> policy) Set the reconnect policy that is executed when the subscriber is disconnected.
static PgSubscriber	PgSubscriber.subscriber(io.vertx.core.Vertx vertx, PgConnectOptions options) Create a subscriber.

Uses of PgSubscriber in io.reactiverse.reactivex.pgclient.pubsub

Methods in io.reactiverse.reactivex.pgclient.pubsub that return PgSubscriber

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

Methods in io.reactiverse.reactivex.pgclient.pubsub with parameters of type PgSubscriber

Modifier and Type	Method and Description
static PgSubscriber	PgSubscriber.newInstance(PgSubscriber arg)

Constructors in io.reactiverse.reactivex.pgclient.pubsub with parameters of type PgSubscriber

Constructor and Description
PgSubscriber(PgSubscriber delegate)

Uses of PgSubscriber in io.reactiverse.rxjava.pgclient.pubsub

Methods in io.reactiverse.rxjava.pgclient.pubsub that return PgSubscriber

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

Methods in io.reactiverse.rxjava.pgclient.pubsub with parameters of type PgSubscriber

Modifier and Type	Method and Description
static PgSubscriber	PgSubscriber.newInstance(PgSubscriber arg)

Constructors in io.reactiverse.rxjava.pgclient.pubsub with parameters of type PgSubscriber

Constructor and Description
PgSubscriber(PgSubscriber delegate)