Stage that executes the observer with a thread pool More...

Public Member Functions
	RxThreadPoolStage (IObserver< T > observer, int numThreads)
	Constructs a Rx thread pool 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 with a thread pool

Constructor & Destructor Documentation

Org.Apache.REEF.Wake.RX.Impl.RxThreadPoolStage< T >.RxThreadPoolStage	(	IObserver< T >	observer,
		int	numThreads
	)

inline

Constructs a Rx thread pool stage

Parameters

observer	the observer to execute
numThreads	the number of threads

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

inlinevirtual

Closes the stage

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

inlinevirtual

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

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

inlinevirtual

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

Parameters

error the error

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

inlinevirtual

Provides the observer with the new value

Parameters

value the new value

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