akka.stream

Class KillSwitches.KillableGraphStageLogic

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.KillSwitches.KillableGraphStageLogic

Enclosing class:

KillSwitches

public abstract static class KillSwitches.KillableGraphStageLogic
extends GraphStageLogic

Nested Class Summary

Nested classes/interfaces inherited from class akka.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 and Description
KillableGraphStageLogic(scala.concurrent.Future<Done> terminationSignal, Shape _shape)

Method Summary

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

Methods inherited from class akka.stream.stage.GraphStageLogic

abortEmitting, abortReading, afterPostStop, beforePreStart, cancel, complete, completeStage, conditionalTerminateInput, conditionalTerminateOutput, createAsyncCallback, eagerTerminateInput, eagerTerminateOutput, emit, emit, emit, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, emitMultiple, fail, failStage, getAsyncCallback, getHandler, getHandler, getStageActor, grab, handlers, hasBeenPulled, ignoreTerminateInput, ignoreTerminateOutput, inCount, interpreter, isAvailable, isAvailable, isClosed, isClosed, materializer, outCount, passAlong, portToConn, postStop, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageId, subFusingMaterializer, totallyIgnorantInput, tryPull

Methods inherited from class java.lang.Object

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

Constructor Detail

KillableGraphStageLogic

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

Method Detail

terminationSignal

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

preStart

public void preStart()

Description copied from class: GraphStageLogic

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

Overrides:

preStart in class GraphStageLogic