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

Packages that use PgSubscriber

Package	Description
io.reactiverse.reactivex.pgclient.pubsub

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

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

Modifier and Type	Field and Description
static io.vertx.lang.rx.TypeArg<PgSubscriber>	PgSubscriber.__TYPE_ARG

Methods in io.reactiverse.reactivex.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.
static PgSubscriber	PgSubscriber.newInstance(PgSubscriber arg)
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.reactivex.core.Vertx vertx, PgConnectOptions options) Create a subscriber.