Click or drag to resize
Akka.NETSink.ActorRef<TIn> 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 Status. Failure 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 Sink<TIn, TMat>.

Namespace:  Akka.Streams.Dsl
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax
public static Sink<TIn, NotUsed> ActorRef<TIn>(
	IActorRef actorRef,
	Object onCompleteMessage
)

Parameters

actorRef
Type: Akka.Actor.IActorRef
TBD
onCompleteMessage
Type: System.Object
TBD

Type Parameters

TIn
TBD

Return Value

Type: Sink<TIn, NotUsed>
TBD
See Also