Package org.apache.pekko.stream

Class KillSwitches.KillableGraphStageLogic

java.lang.Object

org.apache.pekko.stream.stage.GraphStageLogic

org.apache.pekko.stream.KillSwitches.KillableGraphStageLogic

Enclosing class:

KillSwitches

public abstract static class KillSwitches.KillableGraphStageLogic
extends GraphStageLogic

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.pekko.stream.stage.GraphStageLogic

GraphStageLogic.ConditionalTerminateInput, GraphStageLogic.ConditionalTerminateOutput, GraphStageLogic.EagerTerminateInput$, GraphStageLogic.EagerTerminateOutput$, GraphStageLogic.IgnoreTerminateInput$, GraphStageLogic.IgnoreTerminateOutput$, GraphStageLogic.StageActor, GraphStageLogic.StageActorRef$, GraphStageLogic.StageActorRefNotInitializedException, GraphStageLogic.StageActorRefNotInitializedException$, GraphStageLogic.SubSinkInlet<T>, GraphStageLogic.SubSourceOutlet<T>, GraphStageLogic.TotallyIgnorantInput$

Constructor Summary

Constructors

Constructor	Description
KillableGraphStageLogic(scala.concurrent.Future<Done> terminationSignal, Shape _shape)

Method Summary

Modifier and Type	Method	Description
void	preStart()	Invoked before any external events are processed, at the startup of the operator.
scala.concurrent.Future<Done>	terminationSignal()

Methods inherited from class org.apache.pekko.stream.stage.GraphStageLogic

abortEmitting, abortReading, afterPostStop, beforePreStart, cancel, cancel, cancelStage, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getEagerStageActor, getHandler, getHandler, getStageActor, grab, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, isAvailable, isAvailable, isClosed, isClosed, materializer, outCount, passAlong, passAlong$default$3, passAlong$default$4, passAlong$default$5, postStop, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageActorName, subFusingMaterializer, toString, totallyIgnorantInput, tryPull

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

KillableGraphStageLogic

public KillableGraphStageLogic(scala.concurrent.Future<Done> terminationSignal,
 Shape _shape)

Method Details

preStart

public void preStart()

Description copied from class: GraphStageLogic

Invoked before any external events are processed, at the startup of the operator.

Overrides:

preStart in class GraphStageLogic

terminationSignal

public scala.concurrent.Future<Done> terminationSignal()