Package org.apache.pekko.stream.stage
package org.apache.pekko.stream.stage
-
ClassDescriptionJava API: A GraphStage represents a reusable graph stream processing operator.Java API: callbacks for an input port where termination logic is predefined (completing when upstream completes, failing when upstream fails).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).Java API: callbacks for an output port where termination logic is predefined (completing when downstream cancels).An asynchronous callback holder that is attached to a
GraphStageLogic.INTERNAL APIINTERNAL APIGraphStage<S extends Shape>A GraphStage represents a reusable graph stream processing operator.Represents the processing logic behind aGraphStage.Input handler that terminates the state upon receiving completion if the given condition holds at that time.Output handler that terminates the state upon receiving completion if the given condition holds at that time.Input handler that terminates the operator upon receiving completion.Output handler that terminates the operator upon cancellation.Input handler that does not terminate the operator upon receiving completion.Output handler that does not terminate the operator upon cancellation.Minimal actor to work with other actors and watch them in a synchronous waysInput handler that does not terminate the operator upon receiving completion nor failure.Java API:GraphStageLogicwithStageLogging.Scala API: A GraphStage represents a reusable graph stream processing operator.Collection of callbacks for an input port of aGraphStageCollection of callbacks for an output port of aGraphStageSimple way to obtain apekko.event.LoggingAdapterwhen used together with anpekko.stream.Materializer.Provides timer related facilities to aGraphStageLogic.Java API:TimerGraphStageLogicwithStageLogging.