akka.stream.stage

Class TimerGraphStageLogic

java.lang.Object

akka.stream.stage.GraphStageLogic

akka.stream.stage.TimerGraphStageLogic

Direct Known Subclasses:

TimerGraphStageLogicWithLogging

public abstract class TimerGraphStageLogic
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
TimerGraphStageLogic(Shape _shape)

Method Summary

Modifier and Type	Method and Description
protected void	afterPostStop() INTERNAL API
protected void	cancelTimer(java.lang.Object timerKey) Cancel timer, ensuring that the onTimer(java.lang.Object) is not subsequently called.
protected boolean	isTimerActive(java.lang.Object timerKey) Inquire whether the timer is still active.
protected void	onTimer(java.lang.Object timerKey) Will be called when the scheduled timer is triggered.
protected void	scheduleOnce(java.lang.Object timerKey, scala.concurrent.duration.FiniteDuration delay) Schedule timer to call onTimer(java.lang.Object) after given delay.
protected void	schedulePeriodically(java.lang.Object timerKey, scala.concurrent.duration.FiniteDuration interval) Schedule timer to call onTimer(java.lang.Object) periodically with the given interval.
protected void	schedulePeriodicallyWithInitialDelay(java.lang.Object timerKey, scala.concurrent.duration.FiniteDuration initialDelay, scala.concurrent.duration.FiniteDuration interval) Schedule timer to call onTimer(java.lang.Object) periodically with the given interval after the specified initial delay.

Methods inherited from class akka.stream.stage.GraphStageLogic

abortEmitting, abortReading, 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, preStart, 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

TimerGraphStageLogic

public TimerGraphStageLogic(Shape _shape)

Method Detail

onTimer

protected void onTimer(java.lang.Object timerKey)
                throws java.lang.Exception

Will be called when the scheduled timer is triggered.

Parameters:

timerKey - key of the scheduled timer

Throws:

java.lang.Exception

afterPostStop

protected void afterPostStop()

Description copied from class: GraphStageLogic

INTERNAL API

Overrides:

afterPostStop in class GraphStageLogic

schedulePeriodicallyWithInitialDelay

protected final void schedulePeriodicallyWithInitialDelay(java.lang.Object timerKey,
                                                          scala.concurrent.duration.FiniteDuration initialDelay,
                                                          scala.concurrent.duration.FiniteDuration interval)

Schedule timer to call onTimer(java.lang.Object) periodically with the given interval after the specified initial delay. Any existing timer with the same key will automatically be canceled before adding the new timer.

Parameters:

timerKey - (undocumented)

initialDelay - (undocumented)

interval - (undocumented)

scheduleOnce

protected final void scheduleOnce(java.lang.Object timerKey,
                                  scala.concurrent.duration.FiniteDuration delay)

Schedule timer to call onTimer(java.lang.Object) after given delay. Any existing timer with the same key will automatically be canceled before adding the new timer.

Parameters:

timerKey - (undocumented)

delay - (undocumented)

cancelTimer

protected final void cancelTimer(java.lang.Object timerKey)

Cancel timer, ensuring that the onTimer(java.lang.Object) is not subsequently called.

Parameters:

timerKey - key of the timer to cancel

isTimerActive

protected final boolean isTimerActive(java.lang.Object timerKey)

Inquire whether the timer is still active. Returns true unless the timer does not exist, has previously been canceled or if it was a single-shot timer that was already triggered.

Parameters:

timerKey - (undocumented)

Returns:

(undocumented)

schedulePeriodically

protected final void schedulePeriodically(java.lang.Object timerKey,
                                          scala.concurrent.duration.FiniteDuration interval)

Schedule timer to call onTimer(java.lang.Object) periodically with the given interval. Any existing timer with the same key will automatically be canceled before adding the new timer.

Parameters:

timerKey - (undocumented)

interval - (undocumented)