| Package | Description | 
|---|---|
| io.vertx.rxjava.pgclient.pubsub | 
| Modifier and Type | Field and Description | 
|---|---|
static io.vertx.lang.rx.TypeArg<PgSubscriber> | 
PgSubscriber.__TYPE_ARG  | 
| Modifier and Type | Method and Description | 
|---|---|
PgSubscriber | 
PgSubscriber.closeHandler(Handler<Void> handler)
Set an handler called when the subscriber is closed. 
 | 
PgSubscriber | 
PgSubscriber.connect()
Connect the subscriber to Postgres. 
 | 
PgSubscriber | 
PgSubscriber.connect(Handler<AsyncResult<Void>> handler)
Connect the subscriber to Postgres. 
 | 
static PgSubscriber | 
PgSubscriber.newInstance(PgSubscriber arg)  | 
PgSubscriber | 
PgSubscriber.reconnectPolicy(java.util.function.Function<Integer,Long> policy)
Set the reconnect policy that is executed when the subscriber is disconnected. 
 | 
static PgSubscriber | 
PgSubscriber.subscriber(Vertx vertx,
          PgConnectOptions options)
Create a subscriber. 
 | 
Copyright © 2024 Eclipse. All rights reserved.