Package | Description |
---|---|
io.reactiverse.pgclient.pubsub | |
io.reactiverse.reactivex.pgclient.pubsub | |
io.reactiverse.rxjava.pgclient.pubsub |
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.
|
Modifier and Type | Method and Description |
---|---|
PgSubscriber |
PgSubscriber.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static PgSubscriber |
PgSubscriber.newInstance(PgSubscriber arg) |
Constructor and Description |
---|
PgSubscriber(PgSubscriber delegate) |
Modifier and Type | Method and Description |
---|---|
PgSubscriber |
PgSubscriber.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static PgSubscriber |
PgSubscriber.newInstance(PgSubscriber arg) |
Constructor and Description |
---|
PgSubscriber(PgSubscriber delegate) |
Copyright © 2019 Eclipse. All rights reserved.