Package | Description |
---|---|
io.vertx.rxjava3.pgclient | |
io.vertx.rxjava3.pgclient.pubsub |
Modifier and Type | Field and Description |
---|---|
static TypeArg<PgConnection> |
PgConnection.__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
PgConnection |
PgConnection.cancelRequest(io.vertx.core.Handler<io.vertx.core.AsyncResult<Void>> handler)
Send a request cancellation message to tell the server to cancel processing request in this connection.
|
static PgConnection |
PgConnection.cast(SqlConnection sqlConnection)
Cast a to
PgConnection . |
PgConnection |
PgConnection.closeHandler(io.vertx.core.Handler<Void> handler) |
PgConnection |
PgConnection.exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
static PgConnection |
PgConnection.newInstance(io.vertx.pgclient.PgConnection arg) |
PgConnection |
PgConnection.notificationHandler(io.vertx.core.Handler<io.vertx.pgclient.PgNotification> handler)
Set an handler called when the connection receives notification on a channel.
|
Modifier and Type | Method and Description |
---|---|
static io.reactivex.rxjava3.core.Single<PgConnection> |
PgConnection.connect(Vertx vertx)
Like
connect(io.vertx.rxjava3.core.Vertx, io.vertx.pgclient.PgConnectOptions) with options build from the environment variables. |
static io.reactivex.rxjava3.core.Single<PgConnection> |
PgConnection.connect(Vertx vertx,
io.vertx.pgclient.PgConnectOptions options)
Connects to the database and returns the connection if that succeeds.
|
static io.reactivex.rxjava3.core.Single<PgConnection> |
PgConnection.connect(Vertx vertx,
String connectionUri)
Like
connect(io.vertx.rxjava3.core.Vertx, io.vertx.pgclient.PgConnectOptions) with options build from connectionUri . |
static io.reactivex.rxjava3.core.Single<PgConnection> |
PgConnection.rxConnect(Vertx vertx)
Like
connect(io.vertx.rxjava3.core.Vertx, io.vertx.pgclient.PgConnectOptions) with options build from the environment variables. |
static io.reactivex.rxjava3.core.Single<PgConnection> |
PgConnection.rxConnect(Vertx vertx,
io.vertx.pgclient.PgConnectOptions options)
Connects to the database and returns the connection if that succeeds.
|
static io.reactivex.rxjava3.core.Single<PgConnection> |
PgConnection.rxConnect(Vertx vertx,
String connectionUri)
Like
connect(io.vertx.rxjava3.core.Vertx, io.vertx.pgclient.PgConnectOptions) with options build from connectionUri . |
Modifier and Type | Method and Description |
---|---|
PgConnection |
PgSubscriber.actualConnection() |
Copyright © 2021 Eclipse. All rights reserved.