Click or drag to resize
Akka.NETSinkActorRefWithAckTIn Method
Sends the elements of the stream to the given IActorRef that sends back back-pressure signal. First element is always onInitMessage, then stream is waiting for acknowledgement message ackMessage from the given actor which means that it is ready to process elements.It also requires ackMessage message after each stream element to make backpressure work. 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 - result of onFailureMessage function will be sent to the destination actor.

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> ActorRefWithAck<TIn>(
	IActorRef actorRef,
	Object onInitMessage,
	Object ackMessage,
	Object onCompleteMessage,
	Func<Exception, Object> onFailureMessage = null
)

Parameters

actorRef
Type: Akka.ActorIActorRef
TBD
onInitMessage
Type: SystemObject
TBD
ackMessage
Type: SystemObject
TBD
onCompleteMessage
Type: SystemObject
TBD
onFailureMessage (Optional)
Type: SystemFuncException, Object
TBD

Type Parameters

TIn
TBD

Return Value

Type: SinkTIn, NotUsed
TBD
See Also