Uses of Package
org.apache.reef.wake.rx

Packages that use org.apache.reef.wake.rx

Package	Description
org.apache.reef.wake.examples.accumulate	A key-value combiner example.
org.apache.reef.wake.examples.join	Blocking and non-blocking join example.
org.apache.reef.wake.rx	Wake's RX-style communication.
org.apache.reef.wake.rx.impl	Wake's RX-style communication implementation.

Classes in org.apache.reef.wake.rx used by org.apache.reef.wake.examples.accumulate

Class and Description
Observer Provides a mechanism for receiving push-based notifications.

Classes in org.apache.reef.wake.rx used by org.apache.reef.wake.examples.join

Class and Description
Observable Defines a provider for push-based notification.
Observer Provides a mechanism for receiving push-based notifications.
StaticObservable Defines a "static" provider for push-based notification.

Classes in org.apache.reef.wake.rx used by org.apache.reef.wake.rx

Class and Description
Observable Defines a provider for push-based notification.
Observer Provides a mechanism for receiving push-based notifications.
RxStage Stage that executes the observer.
StaticObservable Defines a "static" provider for push-based notification.

Classes in org.apache.reef.wake.rx used by org.apache.reef.wake.rx.impl

Class and Description
AbstractRxStage An RxStage that implements metering.
Observable Defines a provider for push-based notification.
Observer Provides a mechanism for receiving push-based notifications.
RxStage Stage that executes the observer.
StaticObservable Defines a "static" provider for push-based notification.
Subject A class implementing Observer<InType> and StaticObservable<OutType>.