Class PushStage<TIn, TOut>
PushStage<TIn, TOut> is a PushPullStage<TIn, TOut> that always perform transitive pull by calling Pull() from OnPull(IContext<TOut>).
Implements
IStage<TIn, TOut>
Inherited Members
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
[Obsolete("Please use GraphStage instead. [1.1.0]")]
public abstract class PushStage<TIn, TOut> : PushPullStage<TIn, TOut>, IStage<TIn, TOut>Type Parameters
| Name | Description |
|---|---|
| TIn | TBD |
| TOut | TBD |
Methods
| Improve this Doc View SourceOnPull(IContext<TOut>)
Always pulls from upstream.
Declaration
public sealed override ISyncDirective OnPull(IContext<TOut> context)Parameters
| Type | Name | Description |
|---|---|---|
| IContext<TOut> | context | TBD |
Returns
| Type | Description |
|---|---|
| ISyncDirective | TBD |
Overrides
Akka.Streams.Stage.AbstractStage<TIn, TOut, Akka.Streams.Stage.ISyncDirective, Akka.Streams.Stage.ISyncDirective, Akka.Streams.Stage.IContext<TOut>>.OnPull(Akka.Streams.Stage.IContext<TOut>)
Improve this Doc