StatefulStage(TIn, TOut).TerminationEmit Method

StatefulStageTIn, TOutTerminationEmit Method

Can be used from OnUpstreamFinish(IContextTOut) to push final elements downstream before completing the stream successfully. Note that if this is used from OnUpstreamFailure(Exception, IContext) the failure will be absorbed and the stream will be completed successfully.

Namespace: Akka.Streams.Stage
Assembly: Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.129 (1.2.3.129)

Syntax

Copy

public ISyncDirective TerminationEmit(
	IEnumerator<TOut> enumerator,
	IContext<TOut> context
)

member TerminationEmit : 
        enumerator : IEnumerator<'TOut> * 
        context : IContext<'TOut> -> ISyncDirective

Parameters

enumerator: Type: System.Collections.GenericIEnumeratorTOut
TBD
context: Type: Akka.Streams.StageIContextTOut
TBD

Return Value

Type: ISyncDirective
TBD

Exceptions

Exception	Condition
IllegalStateException	This exception is thrown when the specified enumerator is empty.

Reference

StatefulStageTIn, TOut Class

Akka.Streams.Stage Namespace