public class PgChannel extends Object implements io.vertx.rxjava.core.streams.ReadStream<String>
LISTEN/UNLISTEN
commands.
When paused the channel discards the messages.
NOTE: This class has been automatically generated from the original
non RX-ified interface using Vert.x codegen.Modifier and Type | Field and Description |
---|---|
static io.vertx.lang.rx.TypeArg<PgChannel> |
__TYPE_ARG |
Modifier and Type | Method and Description |
---|---|
PgChannel |
endHandler(io.vertx.core.Handler<Void> endHandler)
Set an handler to be called when no more notifications will be received.
|
boolean |
equals(Object o) |
PgChannel |
exceptionHandler(io.vertx.core.Handler<Throwable> handler) |
io.vertx.rxjava.core.streams.ReadStream<String> |
fetch(long arg0) |
PgChannel |
getDelegate() |
PgChannel |
handler(io.vertx.core.Handler<String> handler)
Set or unset an handler to be called when a the channel is notified by Postgres.
|
int |
hashCode() |
static PgChannel |
newInstance(PgChannel arg) |
PgChannel |
pause()
Pause the channel, all notifications are discarded.
|
PgChannel |
resume()
Resume the channel.
|
PgChannel |
subscribeHandler(io.vertx.core.Handler<Void> handler)
Set an handler called when the the channel get subscribed.
|
Observable<String> |
toObservable() |
String |
toString() |
public static final io.vertx.lang.rx.TypeArg<PgChannel> __TYPE_ARG
public PgChannel(PgChannel delegate)
public PgChannel getDelegate()
getDelegate
in interface io.vertx.rxjava.core.streams.ReadStream<String>
getDelegate
in interface io.vertx.rxjava.core.streams.StreamBase
public Observable<String> toObservable()
toObservable
in interface io.vertx.rxjava.core.streams.ReadStream<String>
public io.vertx.rxjava.core.streams.ReadStream<String> fetch(long arg0)
fetch
in interface io.vertx.rxjava.core.streams.ReadStream<String>
public PgChannel subscribeHandler(io.vertx.core.Handler<Void> handler)
handler
- the handlerpublic PgChannel handler(io.vertx.core.Handler<String> handler)
LISTEN
command if neededUNLISTEN
command if neededhandler
in interface io.vertx.rxjava.core.streams.ReadStream<String>
handler
- the handlerpublic PgChannel pause()
pause
in interface io.vertx.rxjava.core.streams.ReadStream<String>
public PgChannel resume()
resume
in interface io.vertx.rxjava.core.streams.ReadStream<String>
public PgChannel endHandler(io.vertx.core.Handler<Void> endHandler)
endHandler
in interface io.vertx.rxjava.core.streams.ReadStream<String>
endHandler
- the handlerpublic PgChannel exceptionHandler(io.vertx.core.Handler<Throwable> handler)
exceptionHandler
in interface io.vertx.rxjava.core.streams.ReadStream<String>
exceptionHandler
in interface io.vertx.rxjava.core.streams.StreamBase
Copyright © 2019 Eclipse. All rights reserved.