actorRef

Send the elements from the stream to an ActorRef.

Sink stages

Signature

def actorRef[T](ref: ActorRef, onCompleteMessage: Any): Sink[T, NotUsed]

Description

Send the elements from the stream to an ActorRef. No backpressure so care must be taken to not overflow the inbox.

cancels when the actor terminates

backpressures never

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.