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

Stage that executes the observer synchronously More...

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

Public Member Functions
	RxSyncStage (IObserver< T > observer)
	Constructs a Rx synchronous stage More...
override void	OnNext (T value)
	Provides the observer with the new value More...
override void	OnError (Exception error)
	Notifies the observer that the provider has experienced an error condition. More...
override void	OnCompleted ()
	Notifies the observer that the provider has finished sending push-based notifications. More...
override void	Dispose ()
	Closes the stage More...
Public Member Functions inherited from Org.Apache.REEF.Wake.RX.AbstractRxStage< T >
	AbstractRxStage (string meterName)
	Constructs an abstract rxstage More...

Detailed Description

Stage that executes the observer synchronously

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.RxSyncStage ( IObserver< T >  observer )

inline

Constructs a Rx synchronous stage

Parameters

observer

the observer

Member Function Documentation

override void Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.Dispose ( )

inlinevirtual

Closes the stage

Reimplemented from Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.

override void Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.OnCompleted ( )

inlinevirtual

Notifies the observer that the provider has finished sending push-based notifications.

Implements Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.

override void Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.OnError ( Exception  error )

inlinevirtual

Notifies the observer that the provider has experienced an error condition.

Parameters

error

the error

Implements Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.

override void Org.Apache.REEF.Wake.RX.Impl.RxSyncStage< T >.OnNext ( T  value )

inlinevirtual

Provides the observer with the new value

Parameters

value

the new value

Reimplemented from Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.

---

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

• lang/cs/Org.Apache.REEF.Wake/RX/Impl/RxSyncStage.cs