actorRef
Send the elements from the stream to an ActorRef
.
Sink operators
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.