Package | Description |
---|---|
io.reactiverse.pgclient.pubsub | |
io.reactiverse.reactivex.pgclient.pubsub | |
io.reactiverse.rxjava.pgclient.pubsub |
Modifier and Type | Method and Description |
---|---|
PgChannel |
PgSubscriber.channel(String name)
Return a channel for the given
name . |
PgChannel |
PgChannel.endHandler(io.vertx.core.Handler<Void> endHandler)
Set an handler to be called when no more notifications will be received.
|
PgChannel |
PgChannel.exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
PgChannel |
PgChannel.handler(io.vertx.core.Handler<String> handler)
Set or unset an handler to be called when a the channel is notified by Postgres.
|
PgChannel |
PgChannel.pause()
Pause the channel, all notifications are discarded.
|
PgChannel |
PgChannel.resume()
Resume the channel.
|
PgChannel |
PgChannel.subscribeHandler(io.vertx.core.Handler<Void> handler)
Set an handler called when the the channel get subscribed.
|
Modifier and Type | Method and Description |
---|---|
PgChannel |
PgChannel.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static PgChannel |
PgChannel.newInstance(PgChannel arg) |
Constructor and Description |
---|
PgChannel(PgChannel delegate) |
Modifier and Type | Method and Description |
---|---|
PgChannel |
PgChannel.getDelegate() |
Modifier and Type | Method and Description |
---|---|
static PgChannel |
PgChannel.newInstance(PgChannel arg) |
Constructor and Description |
---|
PgChannel(PgChannel delegate) |
Copyright © 2019 Eclipse. All rights reserved.