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
withStageLogging
.
-
-
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 TimerGraphStageLogicWithLogging(Shape _shape)
-
Method Summary
-
Methods inherited from class org.apache.pekko.stream.stage.TimerGraphStageLogic
afterPostStop, cancelTimer, isTimerActive, onTimer, scheduleAtFixedRate, scheduleAtFixedRate, scheduleOnce, scheduleOnce, schedulePeriodically, schedulePeriodically, schedulePeriodicallyWithInitialDelay, schedulePeriodicallyWithInitialDelay, scheduleWithFixedDelay, scheduleWithFixedDelay
-
Methods 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, 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, tryPull
-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
-
Methods inherited from interface org.apache.pekko.stream.stage.StageLogging
_log_$eq, log, logSource
-
-
-
-
Constructor Detail
-
TimerGraphStageLogicWithLogging
public TimerGraphStageLogicWithLogging(Shape _shape)
-
-