Package org.apache.reef.wake.rx

Wake's RX-style communication.

See: Description

Interface Summary

Interface	Description
DynamicObservable<T>	Defines a "dynamically configured" provider for push-based notification.
Observable	Defines a provider for push-based notification.
Observer<T>	Provides a mechanism for receiving push-based notifications.
RxStage<T>	Stage that executes the observer.
StaticObservable	Defines a "static" provider for push-based notification.
Subject<InType,OutType>	A class implementing Observer<InType> and StaticObservable<OutType>.

Class Summary

Class	Description
AbstractObserver<T>	An Observer with logging-only onError and onCompleted() methods.
AbstractRxStage<T>	An RxStage that implements metering.

Package org.apache.reef.wake.rx Description

Wake's RX-style communication.