Package akka.stream.stage

Class TimerGraphStageLogicWithLogging

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.stage.TimerGraphStageLogic

akka.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 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
TimerGraphStageLogicWithLogging(Shape _shape)

Method Summary

Methods inherited from class akka.stream.stage.TimerGraphStageLogic

afterPostStop, cancelTimer, isTimerActive, onTimer, scheduleAtFixedRate, scheduleAtFixedRate, scheduleOnce, scheduleOnce, schedulePeriodically, schedulePeriodically, schedulePeriodicallyWithInitialDelay, schedulePeriodicallyWithInitialDelay, scheduleWithFixedDelay, scheduleWithFixedDelay

Methods inherited from class akka.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 akka.stream.stage.StageLogging

_log_$eq, log, logSource

Constructor Detail

TimerGraphStageLogicWithLogging

public TimerGraphStageLogicWithLogging(Shape _shape)