| AbstractGraphStageWithMaterializedValue<S extends Shape,M> |
Java API: A GraphStage represents a reusable graph stream processing operator.
|
| 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).
|
| ConcurrentAsyncCallbackState |
INTERNAL API
|
| ConcurrentAsyncCallbackState.Event<E> |
|
| ConcurrentAsyncCallbackState.Event$ |
|
| ConcurrentAsyncCallbackState.Initialized$ |
|
| ConcurrentAsyncCallbackState.Pending<E> |
|
| ConcurrentAsyncCallbackState.Pending$ |
|
| ConcurrentAsyncCallbackState$ |
INTERNAL API
|
| GraphStage<S extends Shape> |
A GraphStage represents a reusable graph stream processing operator.
|
| 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 operator upon receiving completion.
|
| GraphStageLogic.EagerTerminateOutput$ |
Output handler that terminates the operator upon cancellation.
|
| GraphStageLogic.IgnoreTerminateInput$ |
Input handler that does not terminate the operator upon receiving completion.
|
| GraphStageLogic.IgnoreTerminateOutput$ |
Output handler that does not terminate the operator 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 operator upon receiving completion
nor failure.
|
| GraphStageLogic$ |
|
| GraphStageLogicWithLogging |
|
| GraphStageWithMaterializedValue<S extends Shape,M> |
Scala API: A GraphStage represents a reusable graph stream processing operator.
|
| TimerGraphStageLogic |
|
| TimerGraphStageLogicWithLogging |
|
| TimerMessages |
|
| TimerMessages.Scheduled |
|
| TimerMessages.Scheduled$ |
|
| TimerMessages.Timer |
|
| TimerMessages.Timer$ |
|
| TimerMessages$ |
|