Package akka.stream.stage
-
Interface Summary Interface Description AsyncCallback<T> Dispatch an asynchronous notification.InHandler Called when the input port has a new element available.OutHandler Called when the output port has received a pull, and therefore ready to emit an element, i.e.StageLogging Override to customise reported log source -
Class Summary Class Description 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).GraphStage<S extends Shape> A GraphStage represents a reusable graph stream processing operator.GraphStageLogic INTERNAL APIGraphStageLogic.ConditionalTerminateInput GraphStageLogic.ConditionalTerminateOutput GraphStageLogic.EagerTerminateInput$ GraphStageLogic.EagerTerminateOutput$ GraphStageLogic.IgnoreTerminateInput$ GraphStageLogic.IgnoreTerminateOutput$ GraphStageLogic.StageActor GraphStageLogic.StageActorRef$ GraphStageLogic.StageActorRefNotInitializedException$ GraphStageLogic.TotallyIgnorantInput$ GraphStageLogic$ Input handler that terminates the operator upon receiving completion.GraphStageLogicWithLogging Java API:GraphStageLogic
withStageLogging
.GraphStageWithMaterializedValue<S extends Shape,M> Grants access to the materializer before preStart of the graph stage logic is invoked.TimerGraphStageLogic Will be called when the scheduled timer is triggered.TimerGraphStageLogicWithLogging Java API:TimerGraphStageLogic
withStageLogging
.TimerMessages TimerMessages.Scheduled TimerMessages.Scheduled$ TimerMessages.Timer TimerMessages.Timer$ TimerMessages$ -
Exception Summary Exception Description GraphStageLogic.StageActorRefNotInitializedException