Apache REEF
0.15.0
Retainable Evaluator Execution Framework
|
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... | |
Stage that executes the observer synchronously
|
inline |
Constructs a Rx synchronous stage
observer | the observer |
|
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 >.