public abstract class HandleOrPassOnStage<T extends U,U>
extends org.apache.pekko.stream.stage.GraphStageLogic
Modifier and Type | Class and Description |
---|---|
class |
HandleOrPassOnStage.State |
org.apache.pekko.stream.stage.GraphStageLogic.ConditionalTerminateInput, org.apache.pekko.stream.stage.GraphStageLogic.ConditionalTerminateOutput, org.apache.pekko.stream.stage.GraphStageLogic.EagerTerminateInput$, org.apache.pekko.stream.stage.GraphStageLogic.EagerTerminateOutput$, org.apache.pekko.stream.stage.GraphStageLogic.IgnoreTerminateInput$, org.apache.pekko.stream.stage.GraphStageLogic.IgnoreTerminateOutput$, org.apache.pekko.stream.stage.GraphStageLogic.StageActor, org.apache.pekko.stream.stage.GraphStageLogic.StageActorRef$, org.apache.pekko.stream.stage.GraphStageLogic.StageActorRefNotInitializedException, org.apache.pekko.stream.stage.GraphStageLogic.StageActorRefNotInitializedException$, org.apache.pekko.stream.stage.GraphStageLogic.SubSinkInlet<T>, org.apache.pekko.stream.stage.GraphStageLogic.SubSourceOutlet<T>, org.apache.pekko.stream.stage.GraphStageLogic.TotallyIgnorantInput$
Constructor and Description |
---|
HandleOrPassOnStage(org.apache.pekko.stream.FlowShape<T,U> shape) |
Modifier and Type | Method and Description |
---|---|
void |
become(HandleOrPassOnStage.State state) |
abortEmitting, abortReading, afterPostStop, attributes_$eq, attributes, beforePreStart, cancel, cancel, cancelStage, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getEagerStageActor, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, inHandler, interpreter_$eq, interpreter, isAvailable, isAvailable, isClosed, isClosed, lastCancellationCause_$eq, lastCancellationCause, materializer, onFeedbackDispatched, org$apache$pekko$stream$stage$GraphStageLogic$$asyncCallbacksInProgress, org$apache$pekko$stream$stage$GraphStageLogic$$completedOrFailed, org$apache$pekko$stream$stage$GraphStageLogic$$completedOrFailed, org$apache$pekko$stream$stage$GraphStageLogic$$created, org$apache$pekko$stream$stage$GraphStageLogic$$created, org$apache$pekko$stream$stage$GraphStageLogic$$streamDetachedException, originalStage_$eq, originalStage, outCount, outHandler, passAlong, passAlong$default$3, passAlong$default$4, passAlong$default$5, portToConn, postStop, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageActorName, stageId_$eq, stageId, subFusingMaterializer, toString, totallyIgnorantInput, tryPull
public void become(HandleOrPassOnStage.State state)