| SinkActorRefTIn Method |
Sends the elements of the stream to the given
IActorRef.
If the target actor terminates the stream will be canceled.
When the stream is completed successfully the given
onCompleteMessage
will be sent to the destination actor.
When the stream is completed with failure a
StatusFailure
message will be sent to the destination actor.
It will request at most
MaxInputBufferSize number of elements from
upstream, but there is no back-pressure signal from the destination actor,
i.e. if the actor is not consuming the messages fast enough the mailbox
of the actor will grow. For potentially slow consumer actors it is recommended
to use a bounded mailbox with zero
PushTimeOut or use a rate
limiting stage in front of this
SinkTIn, TMat.
Namespace:
Akka.Streams.Dsl
Assembly:
Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)
Syntax public static Sink<TIn, NotUsed> ActorRef<TIn>(
IActorRef actorRef,
Object onCompleteMessage
)
static member ActorRef :
actorRef : IActorRef *
onCompleteMessage : Object -> Sink<'TIn, NotUsed>
Parameters
- actorRef
- Type: Akka.ActorIActorRef
TBD - onCompleteMessage
- Type: SystemObject
TBD
Type Parameters
- TIn
- TBD
Return Value
Type:
SinkTIn,
NotUsedTBD
See Also