Package | Description |
---|---|
org.apache.reef.wake.rx.impl |
Wake's RX-style communication implementation.
|
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.