| Package | Description |
|---|---|
| groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
| groovyx.gpars.dataflow.remote | |
| groovyx.gpars.dataflow.stream | |
| groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
| Modifier and Type | Class and Description |
|---|---|
class |
DataflowBroadcast<T>
Offers a deterministic one-to-many and many-to-many messaging alternative to DataflowQueue.
|
class |
SyncDataflowBroadcast<T>
Offers a synchronous deterministic one-to-many and many-to-many messaging alternative to SyncDataflowQueue.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RemoteDataflowBroadcast<T>
Proxy object for remote instance of Broadcast.
|
| Modifier and Type | Field and Description |
|---|---|
private DataflowStreamWriteAdapter<T> |
DataflowStreamWriteAdapter.BindDataflowStream.stream |
| Constructor and Description |
|---|
BindDataflowStream(DataflowStreamWriteAdapter<T> stream,
T value) |
| Modifier and Type | Field and Description |
|---|---|
private DataflowStreamWriteAdapter |
RemoteDataflowBroadcastReplyMsg.stream |