This project has retired. For details please refer to its Attic page.
Apache REEF: Org.Apache.REEF.Wake.RX.Impl.RxTimerStage Class Reference
Apache REEF  0.15.0
Retainable Evaluator Execution Framework
Public Member Functions | List of all members
Org.Apache.REEF.Wake.RX.Impl.RxTimerStage Class Reference

Timer stage that provides events to the observer periodically More...

Inherits Org.Apache.REEF.Wake.IStage, and Org.Apache.REEF.Wake.RX.IStaticObservable.

Public Member Functions

 RxTimerStage (IObserver< PeriodicEvent > observer, long period)
 Constructs a Rx timer stage More...
 
 RxTimerStage (IObserver< PeriodicEvent > observer, long initialDelay, long period)
 Constructs a Rx timer stage More...
 
void Dispose ()
 Closes the stage More...
 

Detailed Description

Timer stage that provides events to the observer periodically

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.RX.Impl.RxTimerStage.RxTimerStage ( IObserver< PeriodicEvent observer,
long  period 
)
inline

Constructs a Rx timer stage

Parameters
observerthe observer
periodthe period in milli-seconds
Org.Apache.REEF.Wake.RX.Impl.RxTimerStage.RxTimerStage ( IObserver< PeriodicEvent observer,
long  initialDelay,
long  period 
)
inline

Constructs a Rx timer stage

Parameters
observerthe observer
initialDelaythe initial delay in milli-seconds
periodthe period in milli-seconds

Member Function Documentation

void Org.Apache.REEF.Wake.RX.Impl.RxTimerStage.Dispose ( )
inline

Closes the stage


The documentation for this class was generated from the following file: