AbstractStage(TIn, TOut, TPushDirective, TPullDirective, TContext).OnPush Method (TIn, IContext)

AbstractStageTIn, 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

Copy

public override sealed IDirective OnPush(
	TIn element,
	IContext context
)

abstract OnPush : 
        element : 'TIn * 
        context : IContext -> IDirective 
override OnPush : 
        element : 'TIn * 
        context : IContext -> IDirective

Parameters

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

Return Value

Type: IDirective
TBD

Reference

AbstractStageTIn, TOut, TPushDirective, TPullDirective, TContext Class

OnPush Overload

Akka.Streams.Stage Namespace