| 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 |