Package | Description |
---|---|
org.apache.reef.wake.rx |
Wake's RX-style communication.
|
org.apache.reef.wake.rx.impl |
Wake's RX-style communication implementation.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractRxStage<T>
An
RxStage that implements metering. |
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.
|
Copyright © 2017 The Apache Software Foundation. All rights reserved.