org.apache.reef.wake.rx.impl (REEF 0.16.0 API)

This project has retired. For details please refer to its Attic page.

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.

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

Wake's RX-style communication implementation.