Uses of Class
org.apache.reef.wake.rx.AbstractRxStage

Packages that use AbstractRxStage

Package	Description
org.apache.reef.wake.rx.impl	Wake's RX-style communication implementation.

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

Subclasses of AbstractRxStage in org.apache.reef.wake.rx.impl

Modifier and Type	Class and Description
class	RxSyncStage<T> Stage that executes the observer synchronously.
class	RxThreadPoolStage<T> Stage that executes the observer with a thread pool.