Uses of Class
groovyx.gpars.dataflow.remote.RemoteDataflowQueue

Packages that use RemoteDataflowQueue

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.remote.message	This package holds message classes for the remote actors implementation.

Uses of RemoteDataflowQueue in groovyx.gpars.dataflow

Methods in groovyx.gpars.dataflow that return types with arguments of type RemoteDataflowQueue

Modifier and Type	Method and Description
java.lang.Class<RemoteDataflowQueue>	DataflowQueue.getRemoteClass()

Uses of RemoteDataflowQueue in groovyx.gpars.dataflow.remote

Fields in groovyx.gpars.dataflow.remote with type parameters of type RemoteDataflowQueue

Modifier and Type	Field and Description
private java.util.concurrent.ConcurrentMap<java.lang.String,DataflowVariable<RemoteDataflowQueue<?>>>	RemoteDataflows.remoteQueues Stores promises to remote instances of DataflowQueues.

Methods in groovyx.gpars.dataflow.remote that return types with arguments of type RemoteDataflowQueue

Modifier and Type	Method and Description
Promise<RemoteDataflowQueue<?>>	RemoteDataflows.getDataflowQueue(java.lang.String host, int port, java.lang.String name) Retrieves DataflowQueue published under specified name on remote host.

Uses of RemoteDataflowQueue in groovyx.gpars.remote.message

Constructors in groovyx.gpars.remote.message with parameters of type RemoteDataflowQueue

Constructor and Description
RemoteDataflowQueueEnqueueValueMsg(RemoteDataflowQueue<T> queue, T value)
RemoteDataflowQueueValueRequestMsg(RemoteDataflowQueue<T> queue, DataflowVariable<T> value)