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 |