StatefulStage(TIn, TOut).EmitAndFinish Method

StatefulStageTIn, TOutEmitAndFinish Method

Can be used from OnPush(TIn, IContextTOut) or OnPull(IContextTOut) to push more than one element downstream and after that finish (complete downstream, cancel upstreams).

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

Syntax

Copy

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

member EmitAndFinish : 
        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 either currently in the emitting state or the specified enumerator is empty.

Reference

StatefulStageTIn, TOut Class

Akka.Streams.Stage Namespace