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) |