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 Description

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

Method Summary

All Methods Instance Methods Concrete Methods
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 akka.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, 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 Detail

KillableGraphStageLogic

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

Method Detail
- 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()
```