akka.stream.stage

Class StageState<In,Out>

java.lang.Object

akka.stream.stage.StageState<In,Out>

Direct Known Subclasses:

StatefulStage.State

public abstract class StageState<In,Out>
extends java.lang.Object

The behavior of StatefulStage is defined by these two methods, which has the same semantics as corresponding methods in PushPullStage.

Constructor Summary

Constructors

Constructor and Description
StageState()

Method Summary

Modifier and Type	Method and Description
SyncDirective	onPull(Context<Out> ctx)
abstract SyncDirective	onPush(In elem, Context<Out> ctx)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StageState

public StageState()

Method Detail

onPush

public abstract SyncDirective onPush(In elem,
                                     Context<Out> ctx)

onPull

public SyncDirective onPull(Context<Out> ctx)