Class StageState<TIn, TOut>
The behavior of StatefulStage<TIn, TOut> is defined by these two methods, which has the same semantics as corresponding methods in PushPullStage<TIn, TOut>.
Inherited Members
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
public abstract class StageState<TIn, TOut>
Type Parameters
Name | Description |
---|---|
TIn | TBD |
TOut | TBD |
Methods
| Improve this Doc View SourceOnPull(IContext<TOut>)
TBD
Declaration
public virtual ISyncDirective OnPull(IContext<TOut> context)
Parameters
Type | Name | Description |
---|---|---|
IContext<TOut> | context | TBD |
Returns
Type | Description |
---|---|
ISyncDirective | TBD |
OnPush(TIn, IContext<TOut>)
TBD
Declaration
public abstract ISyncDirective OnPush(TIn element, IContext<TOut> context)
Parameters
Type | Name | Description |
---|---|---|
TIn | element | TBD |
IContext<TOut> | context | TBD |
Returns
Type | Description |
---|---|
ISyncDirective | TBD |