Class TimerGraphStageLogic

TBD

Inheritance
Object
GraphStageLogic
TimerGraphStageLogic
Implements
Inherited Members
Namespace: Akka.Streams.Stage
Assembly: Akka.Streams.dll
Syntax
public abstract class TimerGraphStageLogic : GraphStageLogic, IStageLogging

Constructors

| Improve this Doc View Source

TimerGraphStageLogic(Shape)

TBD

Declaration
protected TimerGraphStageLogic(Shape shape)
Parameters
Type Name Description
Shape shape

TBD

Methods

| Improve this Doc View Source

AfterPostStop()

TBD

Declaration
protected override void AfterPostStop()
Overrides
| Improve this Doc View Source

CancelTimer(Object)

Cancel timer, ensuring that the OnTimer(Object) is not subsequently called.

Declaration
protected void CancelTimer(object timerKey)
Parameters
Type Name Description
Object timerKey

key of the timer to cancel
| Improve this Doc View Source

IsTimerActive(Object)

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.

Declaration
protected bool IsTimerActive(object timerKey)
Parameters
Type Name Description
Object timerKey

TBD
Returns
Type Description
Boolean

TBD
| Improve this Doc View Source

OnTimer(Object)

Will be called when the scheduled timer is triggered.

Declaration
protected abstract void OnTimer(object timerKey)
Parameters
Type Name Description
Object timerKey

TBD
| Improve this Doc View Source

ScheduleOnce(Object, TimeSpan)

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

Declaration
protected void ScheduleOnce(object timerKey, TimeSpan delay)
Parameters
Type Name Description
Object timerKey

TBD
TimeSpan delay

TBD
| Improve this Doc View Source

ScheduleRepeatedly(Object, TimeSpan)

Schedule timer to call OnTimer(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.

Declaration
protected void ScheduleRepeatedly(object timerKey, TimeSpan interval)
Parameters
Type Name Description
Object timerKey

TBD
TimeSpan interval

TBD
| Improve this Doc View Source

ScheduleRepeatedly(Object, TimeSpan, TimeSpan)

Schedule timer to call OnTimer(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.

Declaration
protected void ScheduleRepeatedly(object timerKey, TimeSpan initialDelay, TimeSpan interval)
Parameters
Type Name Description
Object timerKey

TBD
TimeSpan initialDelay

TBD
TimeSpan interval

TBD

Implements

Extension Methods