| Package | Description |
|---|---|
| groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
| groovyx.gpars.dataflow.expression | |
| groovyx.gpars.dataflow.impl | |
| groovyx.gpars.dataflow.remote | |
| groovyx.gpars.dataflow.stream |
| Modifier and Type | Method and Description |
|---|---|
DataflowChannelEventListenerManager<T> |
DataflowQueue.getEventManager() |
DataflowChannelEventListenerManager<T> |
DataflowReadChannel.getEventManager()
Retrieves the event manager object of this channel
|
| Modifier and Type | Method and Description |
|---|---|
DataflowChannelEventListenerManager<T> |
DataflowExpression.getEventManager() |
| Modifier and Type | Class and Description |
|---|---|
class |
DataflowChannelEventOrchestrator<T>
Groups the listener-related functionality shared by dataflow channels
|
| Modifier and Type | Method and Description |
|---|---|
DataflowChannelEventListenerManager<T> |
RemoteDataflowQueue.getEventManager() |
| Modifier and Type | Method and Description |
|---|---|
DataflowChannelEventListenerManager<T> |
DataflowStreamReadAdapter.getEventManager() |