StatefulStage(TIn, TOut).Emit Method (IEnumerator(TOut), IContext(TOut), StageState(TIn, TOut))

StatefulStageTIn, TOutEmit Method (IEnumeratorTOut, IContextTOut, StageStateTIn, TOut)

Can be used from OnPush(TIn, IContextTOut) or OnPull(IContextTOut) to push more than one element downstream and after that change behavior.

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

Syntax

Copy

public ISyncDirective Emit(
	IEnumerator<TOut> enumerator,
	IContext<TOut> context,
	StageState<TIn, TOut> nextState
)

member Emit : 
        enumerator : IEnumerator<'TOut> * 
        context : IContext<'TOut> * 
        nextState : StageState<'TIn, 'TOut> -> ISyncDirective

Parameters

enumerator: Type: System.Collections.GenericIEnumeratorTOut
TBD
context: Type: Akka.Streams.StageIContextTOut
TBD
nextState: Type: Akka.Streams.StageStageStateTIn, TOut
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

Emit Overload

Akka.Streams.Stage Namespace