Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
Stage that executes the observer with a thread pool More...
Inherits Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.
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... | |
Stage that executes the observer with a thread pool
|
inline |
Constructs a Rx thread pool stage
observer | the observer to execute |
numThreads | the number of threads |
|
inlinevirtual |
Closes the stage
Reimplemented from Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.
|
inlinevirtual |
Notifies the observer that the provider has finished sending push-based notifications.
Implements Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.
|
inlinevirtual |
Notifies the observer that the provider has experienced an error condition.
error | the error |
Implements Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.
|
inlinevirtual |
Provides the observer with the new value
value | the new value |
Reimplemented from Org.Apache.REEF.Wake.RX.AbstractRxStage< T >.