Org.Apache.REEF.Wake.RX.AbstractRxStage< T > Class Template Reference

An Rx stage that implements metering More...

Inherits Org.Apache.REEF.Wake.RX.IRxStage< T >.

Inherited by Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >, and Org.Apache.REEF.Wake.RX.Impl.RxThreadPoolStage< T >.

Public Member Functions
	AbstractRxStage (string meterName)
	Constructs an abstract rxstage More...
virtual void	OnNext (T value)
	Updates the meter More...
abstract void	OnCompleted ()
abstract void	OnError (Exception error)
virtual void	Dispose ()

Detailed Description

An Rx stage that implements metering

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.AbstractRxStage ( string  meterName )

inline

Constructs an abstract rxstage

Parameters

meterName

the name of the meter

Member Function Documentation

virtual void Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.Dispose ( )

inlinevirtual

Reimplemented in Org.Apache.REEF.Wake.RX.Impl.RxThreadPoolStage< T >, and Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.

abstract void Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.OnCompleted ( )

pure virtual

Implemented in Org.Apache.REEF.Wake.RX.Impl.RxThreadPoolStage< T >, and Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.

abstract void Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.OnError ( Exception  error )

pure virtual

Implemented in Org.Apache.REEF.Wake.RX.Impl.RxThreadPoolStage< T >, and Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.

virtual void Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.OnNext ( T  value )

inlinevirtual

Updates the meter

Parameters

value

the event

Reimplemented in Org.Apache.REEF.Wake.RX.Impl.RxThreadPoolStage< T >, and Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.

---

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

• lang/cs/Org.Apache.REEF.Wake/RX/AbstractRxStage.cs