actorRef

Materialize an ActorRef; sending messages to it will emit them on the stream.

Source operators

Signature

def actorRef[T](bufferSize: Int, overflowStrategy: OverflowStrategy): Source[T, ActorRef]

Description

Materialize an ActorRef, sending messages to it will emit them on the stream. The actor contains a buffer but since communication is one way, there is no back pressure. Handling overflow is done by either dropping elements or failing the stream; the strategy is chosen by the user.

emits when there is demand and there are messages in the buffer or a message is sent to the ActorRef

completes when the ActorRef is sent akka.actor.Status.Success

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.