Packages

object PubSub

Sources and sinks to integrate akka.actor.typed.pubsub.Topic with streams allowing for local or distributed publishing and subscribing of elements through a stream.

Source
PubSub.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. PubSub
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

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 clone(): AnyRef
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
  6. final def eq(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  7. def equals(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef → Any
  8. final def getClass(): Class[_ <: AnyRef]
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  9. def hashCode(): Int
    Definition Classes
    AnyRef → Any
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  10. final def isInstanceOf[T0]: Boolean
    Definition Classes
    Any
  11. final def ne(arg0: AnyRef): Boolean
    Definition Classes
    AnyRef
  12. final def notify(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  13. final def notifyAll(): Unit
    Definition Classes
    AnyRef
    Annotations
    @HotSpotIntrinsicCandidate() @native()
  14. def sink[T](topicActor: ActorRef[Command[T]]): Sink[T, NotUsed]

    Create a sink that will publish each message to the given topic.

    Create a sink that will publish each message to the given topic. Note that there is no backpressure from the topic, so care must be taken to not publish messages at a higher rate than that can be handled by subscribers. If the topic does not have any subscribers when a message is published or the topic actor is stopped, the message is sent to dead letters.

    T

    the type of the messages that can be published

    topicActor

    The actor ref for an akka.actor.typed.pubsub.Topic actor representing a specific topic.

    Annotations
    @ApiMayChange()
  15. def source[T](topicActor: ActorRef[Command[T]], bufferSize: Int, overflowStrategy: OverflowStrategy): Source[T, NotUsed]

    Create a source that will subscribe to a topic and stream messages published to the topic.

    Create a source that will subscribe to a topic and stream messages published to the topic. Can be materialized multiple times, each materialized stream will contain messages published after it was started.

    Note that it is not possible to propagate the backpressure from the running stream to the pub sub topic, if the stream is backpressuring published messages are buffered up to a limit and if the limit is hit the configurable OverflowStrategy decides what happens. It is not possible to use the Backpressure strategy.

    T

    The type of the published messages

    topicActor

    The actor ref for an akka.actor.typed.pubsub.Topic actor representing a specific topic.

    bufferSize

    The maximum number of messages to buffer if the stream applies backpressure

    overflowStrategy

    Strategy to use once the buffer is full.

    Annotations
    @ApiMayChange()
  16. final def synchronized[T0](arg0: => T0): T0
    Definition Classes
    AnyRef
  17. def toString(): String
    Definition Classes
    AnyRef → Any
  18. final def wait(arg0: Long, arg1: Int): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])
  19. final def wait(arg0: Long): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException]) @native()
  20. final def wait(): Unit
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.InterruptedException])

Deprecated Value Members

  1. def finalize(): Unit
    Attributes
    protected[lang]
    Definition Classes
    AnyRef
    Annotations
    @throws(classOf[java.lang.Throwable]) @Deprecated
    Deprecated

    (Since version 9)

Inherited from AnyRef

Inherited from Any

Ungrouped