Packages

class PgChannel extends ReadStream[String]

A channel to Postgres that tracks the subscription to a given Postgres channel using the LISTEN/UNLISTEN commands.

When paused the channel discards the messages.

Linear Supertypes
ReadStream[String], StreamBase, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PgChannel
  2. ReadStream
  3. StreamBase
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new PgChannel(_asJava: AnyRef)

Value Members

  1. final def !=(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0
    Definition Classes
    Any
  5. def asJava: AnyRef
    Definition Classes
    PgChannel → ReadStream → StreamBase
  6. def clone(): AnyRef
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )
  7. def endHandler(endHandler: Handler[Unit]): PgChannel

    Set an handler to be called when no more notifications will be received.

    Set an handler to be called when no more notifications will be received. * @param endHandler the handler

    returns

    a reference to this, so the API can be used fluently

    Definition Classes
    PgChannel → ReadStream
  8. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  9. def equals(arg0: Any): Boolean
    Definition Classes
    AnyRef → Any
  10. def exceptionHandler(handler: Handler[Throwable]): PgChannel
    Definition Classes
    PgChannel → ReadStream → StreamBase
  11. def fetch(arg0: Long): ReadStream[String]
    Definition Classes
    PgChannel → ReadStream
  12. def finalize(): Unit
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  13. final def getClass(): Class[_]
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  14. def handler(handler: Handler[String]): PgChannel

    Set or unset an handler to be called when a the channel is notified by Postgres.

    Set or unset an handler to be called when a the channel is notified by Postgres.

    • when the handler is set, the subscriber sends a LISTEN command if needed
    • when the handler is unset, the subscriber sends a UNLISTEN command if needed * @param handler the handler
    returns

    a reference to this, so the API can be used fluently

    Definition Classes
    PgChannel → ReadStream
  15. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @native()
  16. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  17. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  18. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  19. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @native()
  20. def pause(): PgChannel

    Pause the channel, all notifications are discarded.

    Pause the channel, all notifications are discarded. * @return a reference to this, so the API can be used fluently

    Definition Classes
    PgChannel → ReadStream
  21. def pipe(): Pipe[String]
    Definition Classes
    PgChannel → ReadStream
  22. def pipeTo(dst: WriteStream[String], handler: Handler[AsyncResult[Unit]]): Unit
    Definition Classes
    PgChannel → ReadStream
  23. def pipeTo(dst: WriteStream[String]): Unit
    Definition Classes
    PgChannel → ReadStream
  24. def pipeToFuture(dst: WriteStream[String]): Future[Unit]
    Definition Classes
    PgChannel → ReadStream
  25. def resume(): PgChannel

    Resume the channel.

    Resume the channel. * @return a reference to this, so the API can be used fluently

    Definition Classes
    PgChannel → ReadStream
  26. def subscribeHandler(handler: Handler[Unit]): PgChannel

    Set an handler called when the the channel get subscribed.

    Set an handler called when the the channel get subscribed. * @param handler the handler

    returns

    a reference to this, so the API can be used fluently

  27. final def synchronized[T0](arg0: ⇒ T0): T0
    Definition Classes
    AnyRef
  28. def toString(): String
    Definition Classes
    AnyRef → Any
  29. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  30. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  31. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @native() @throws( ... )

Inherited from ReadStream[String]

Inherited from StreamBase

Inherited from AnyRef

Inherited from Any

Ungrouped