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
- Alphabetic
- By Inheritance
- PubSub
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @HotSpotIntrinsicCandidate() @native()
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- final def ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- final def notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- final def notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @HotSpotIntrinsicCandidate() @native()
- 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.Topicactor representing a specific topic.
- Annotations
- @ApiMayChange()
- 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
OverflowStrategydecides what happens. It is not possible to use theBackpressurestrategy.- T
The type of the published messages
- topicActor
The actor ref for an
akka.actor.typed.pubsub.Topicactor 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()
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])