Package org.apache.reef.wake.rx.impl

Wake's RX-style communication implementation.

See: Description

Class Summary

Class	Description
RxSyncStage<T>	Stage that executes the observer synchronously.
RxThreadPoolStage<T>	Stage that executes the observer with a thread pool.
SimpleSubject<T>	A Subject that relays all messages to its subscribers.
TimeoutSubject<T>	Deprecated in 0.14 as unused

Package org.apache.reef.wake.rx.impl Description

Wake's RX-style communication implementation.