Package org.apache.pekko.stream.stage
Class TimerGraphStageLogicWithLogging
java.lang.Object
org.apache.pekko.stream.stage.GraphStageLogic
org.apache.pekko.stream.stage.TimerGraphStageLogic
org.apache.pekko.stream.stage.TimerGraphStageLogicWithLogging
- All Implemented Interfaces:
StageLogging
- Direct Known Subclasses:
RestartWithBackoffLogic
public abstract class TimerGraphStageLogicWithLogging
extends TimerGraphStageLogic
implements StageLogging
Java API:
TimerGraphStageLogic with StageLogging.-
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 -
Method Summary
Methods inherited from class org.apache.pekko.stream.stage.TimerGraphStageLogic
afterPostStop, cancelTimer, isTimerActive, onTimer, scheduleAtFixedRate, scheduleAtFixedRate, scheduleOnce, scheduleOnce, scheduleWithFixedDelay, scheduleWithFixedDelayMethods inherited from class org.apache.pekko.stream.stage.GraphStageLogic
abortEmitting, abortReading, 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, preStart, pull, push, read, read, readN, readN, setHandler, setHandler, setHandlers, setKeepGoing, stageActor, stageActorName, subFusingMaterializer, toString, totallyIgnorantInput, tryPullMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitMethods inherited from interface org.apache.pekko.stream.stage.StageLogging
_log_$eq, log, logSource
-
Constructor Details
-
TimerGraphStageLogicWithLogging
-