Uses of Interface
org.apache.reef.wake.rx.Observable

Packages that use Observable

Package	Description
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.

Uses of Observable in org.apache.reef.wake.examples.join

Classes in org.apache.reef.wake.examples.join that implement Observable

Modifier and Type	Class and Description
class	BlockingJoin Blocking join.
class	NonBlockingJoin Non-blocking Join.
class	TupleSource A source class generating TupleEvent.

Uses of Observable in org.apache.reef.wake.rx

Subinterfaces of Observable in org.apache.reef.wake.rx

Modifier and Type	Interface and Description
interface	DynamicObservable<T> Defines a "dynamically configured" provider for push-based notification.
interface	StaticObservable Defines a "static" provider for push-based notification.
interface	Subject<InType,OutType> A class implementing Observer<InType> and StaticObservable<OutType>.

Uses of Observable in org.apache.reef.wake.rx.impl

Classes in org.apache.reef.wake.rx.impl that implement Observable

Modifier and Type	Class and Description
class	SimpleSubject<T> A Subject that relays all messages to its subscribers.
class	TimeoutSubject<T> Deprecated. in 0.14 as unused