Click or drag to resize
Akka.NETStatefulStageTIn, TOutOnPush Method
Overload List
  NameDescription
Public methodOnPush(TIn, TContext)

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.

(Inherited from AbstractStageTIn, TOut, TPushDirective, TPullDirective, TContext.)
Public methodOnPush(TIn, IContextTOut)
Invokes current state.
(Overrides AbstractStageTIn, TOut, TPushDirective, TPullDirective, TContextOnPush(TIn, TContext).)
Top
See Also