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
| Edit this page 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 |
Edit this page