Click or drag to resize
Akka.NETAbstractStageTIn, TOut, TPushDirective, TPullDirective, TContextOnPush Method (TIn, IContext)

This method is called when an element from upstream is available and there is demand from downstream, i.e. in OnPush(TIn, TContext) you are allowed to call Push(Object) to emit one element downstreams, or you can absorb the element by calling Pull. Note that you can only emit zero or one element downstream from OnPull(TContext).

To emit more than one element you have to push the remaining elements from OnPull(TContext), one-by-one. OnPush(TIn, TContext) is not called again until OnPull(TContext) has requested more elements with Pull.

Namespace:  Akka.Streams.Stage
Assembly:  Akka.Streams (in Akka.Streams.dll) Version: 1.2.3.42 (1.2.3.42)
Syntax
public override sealed IDirective OnPush(
	TIn element,
	IContext context
)

Parameters

element
Type: TIn
TBD
context
Type: Akka.Streams.StageIContext
TBD

Return Value

Type: IDirective
TBD
See Also