| Package | Description |
|---|---|
| groovyx.gpars.dataflow.remote | |
| groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
| Modifier and Type | Field and Description |
|---|---|
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowBroadcast> |
RemoteDataflows.publishedBroadcasts
Stores DataflowBroadcasts published in context of this instance of RemoteDataflows.
|
| Modifier and Type | Method and Description |
|---|---|
void |
RemoteDataflows.publish(DataflowBroadcast broadcastStream,
java.lang.String name)
Publishes
DataflowBroadcast under given name. |
| Constructor and Description |
|---|
RemoteDataflowBroadcastReplyMsg(java.lang.String name,
DataflowBroadcast stream) |