Org.Apache.REEF.Wake.RX Namespace Reference

Namespaces
namespace	Impl

Classes
class	AbstractObserver
	An observer with logging-only onError and onCompleted() methods. More...
class	AbstractRxStage
	An Rx stage that implements metering More...
interface	IRxStage
	Stage that executes the observer More...
interface	IStaticObservable
interface	ISubject
	A class implementing Observer> and StaticObservable More...
class	ObserverCompletedException
	It is illegal to call onError() or onCompleted() when a call to onNext() is still outstanding, or to call onNext(), onError() or onCompleted() after a call to onError() or onCompleted() has been dispatched. More...