Interface | Description |
---|---|
AsyncCallback<T> |
An asynchronous callback holder that is attached to a
GraphStageLogic . |
AsyncDirective | |
CallbackWrapper<T> |
INTERNAL API
This trait wraps callback for
GraphStage stage instances and handle gracefully cases when stage is
not yet initialized or already finished. |
CallbackWrapper.CallbackState | |
Context<Out> |
Passed to the callback methods of
PushPullStage and StatefulStage . |
DetachedContext<Out> |
Passed to the callback methods of
DetachedStage . |
Directive |
Return type from
Context methods. |
DownstreamDirective | |
InHandler |
Collection of callbacks for an input port of a
GraphStage |
LifecycleContext | |
OutHandler |
Collection of callbacks for an output port of a
GraphStage |
Stage<In,Out> | Deprecated
Please use GraphStage instead.
|
StageLogging |
Simple way to obtain a
LoggingAdapter when used together with an ActorMaterializer . |
StatefulStage.AndThen | |
SyncDirective | |
TerminationDirective | |
UpstreamDirective |
Class | Description |
---|---|
AbstractInHandler |
Java API: callbacks for an input port where termination logic is predefined
(completing when upstream completes, failing when upstream fails).
|
AbstractInOutHandler |
Java API: callback combination for output and input ports where termination logic is predefined
(completing when upstream completes, failing when upstream fails, completing when downstream cancels).
|
AbstractOutHandler |
Java API: callbacks for an output port where termination logic is predefined
(completing when downstream cancels).
|
AbstractStage<In,Out,PushD extends Directive,PullD extends Directive,Ctx extends Context<Out>,LifeCtx extends LifecycleContext> | Deprecated
Please use GraphStage instead.
|
AbstractStage.PushPullGraphStage<In,Out,Ext> | |
AbstractStage.PushPullGraphStageWithMaterializedValue<In,Out,Ext,Mat> | |
AbstractStage$ | Deprecated
Please use GraphStage instead.
|
CallbackWrapper.Initialized | |
CallbackWrapper.NotInitialized | |
CallbackWrapper.Stopped | |
DetachedStage<In,Out> | Deprecated
Please use GraphStage instead.
|
FreeDirective | |
GraphStage<S extends Shape> |
A GraphStage represents a reusable graph stream processing stage.
|
GraphStageLogic |
Represents the processing logic behind a
GraphStage . |
GraphStageLogic.ConditionalTerminateInput |
Input handler that terminates the state upon receiving completion if the
given condition holds at that time.
|
GraphStageLogic.ConditionalTerminateOutput |
Output handler that terminates the state upon receiving completion if the
given condition holds at that time.
|
GraphStageLogic.EagerTerminateInput$ |
Input handler that terminates the stage upon receiving completion.
|
GraphStageLogic.EagerTerminateOutput$ |
Output handler that terminates the stage upon cancellation.
|
GraphStageLogic.IgnoreTerminateInput$ |
Input handler that does not terminate the stage upon receiving completion.
|
GraphStageLogic.IgnoreTerminateOutput$ |
Output handler that does not terminate the stage upon cancellation.
|
GraphStageLogic.StageActor |
Minimal actor to work with other actors and watch them in a synchronous ways
|
GraphStageLogic.StageActorRef$ | |
GraphStageLogic.StageActorRefNotInitializedException$ | |
GraphStageLogic.TotallyIgnorantInput$ |
Input handler that does not terminate the stage upon receiving completion
nor failure.
|
GraphStageLogic$ | |
GraphStageLogicWithLogging |
Java API:
GraphStageLogic with StageLogging . |
GraphStageWithMaterializedValue<S extends Shape,M> | |
PushPullStage<In,Out> | Deprecated
Please use GraphStage instead.
|
PushStage<In,Out> | Deprecated
Please use GraphStage instead.
|
StageState<In,Out> |
The behavior of
StatefulStage is defined by these two methods, which
has the same semantics as corresponding methods in PushPullStage . |
StatefulStage<In,Out> | Deprecated
StatefulStage is deprecated, please use GraphStage instead.
|
StatefulStage.Become | |
StatefulStage.Become$ | |
StatefulStage.Finish$ | |
StatefulStage.Stay$ | |
StatefulStage$ | Deprecated
StatefulStage is deprecated, please use GraphStage instead.
|
TimerGraphStageLogic | |
TimerGraphStageLogicWithLogging |
Java API:
TimerGraphStageLogic with StageLogging . |
TimerMessages | |
TimerMessages.Scheduled | |
TimerMessages.Scheduled$ | |
TimerMessages.Timer | |
TimerMessages.Timer$ | |
TimerMessages$ |
Exception | Description |
---|---|
GraphStageLogic.StageActorRefNotInitializedException |