A channel to Postgres that tracks the subscription to a given Postgres channel using the <code>LISTEN/UNLISTEN</code> commands.
When paused the channel discards the messages.
| package |
Default |
|---|
__construct()
endHandler( $arg0) : $this
callable
$thisa reference to this, so the API can be used fluently
exceptionHandler( $arg0) : $this
callable
$this
fetch( $arg0) : $this
integer
$thisa reference to this, so the API can be used fluently
handler( $arg0) : $this
LISTEN command if neededUNLISTEN command if neededcallable
$thisa reference to this, so the API can be used fluently
pause() : $this
$thisa reference to this, so the API can be used fluently
pipe() : \io\vertx\jphp\pgclient\pubsub\Pipe<String>
The stream will be resumed when the pipe will be wired to a WriteStream.
\io\vertx\jphp\pgclient\pubsub\Pipea pipe
pipeTo( $arg0, $arg1 = null) : void
param $dst [WriteStream
Pipe this ReadStream to the WriteStream.
Elements emitted by this stream will be written to the write stream until this stream ends or fails.
Once this stream has ended or failed, the write stream will be ended and the handler will be
called with the result.
param $dst [WriteStream
WriteStream
callable
resume() : $this
$thisa reference to this, so the API can be used fluently
subscribeHandler( $arg0) : $this
callable
$thisa reference to this, so the API can be used fluently