Uses of Class
groovyx.gpars.dataflow.expression.DataflowExpression

Packages that use DataflowExpression

Package	Description
groovyx.gpars.actor	This package holds classes forming the public actor API.
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.expression
groovyx.gpars.dataflow.stream

Uses of DataflowExpression in groovyx.gpars.actor

Fields in groovyx.gpars.actor declared as DataflowExpression

Modifier and Type	Field and Description
private DataflowExpression<java.lang.Object>	Actor.joinLatch
private DataflowExpression<java.lang.Object>	Actor.MyRemoteHandle.joinLatch

Methods in groovyx.gpars.actor that return DataflowExpression

Modifier and Type	Method and Description
DataflowExpression<java.lang.Object>	Actor.getJoinLatch() Join-point for this actor

Constructors in groovyx.gpars.actor with parameters of type DataflowExpression

Constructor and Description
Actor.MyRemoteHandle(SerialHandle handle, SerialContext host, DataflowExpression<java.lang.Object> joinLatch)
Actor.RemoteActor(SerialContext host, DataflowExpression<java.lang.Object> jointLatch)
Actor(DataflowExpression<java.lang.Object> joinLatch) Constructor to be used by deserialization
Actor(DataflowExpression<java.lang.Object> joinLatch, PGroup parallelGroup)

Uses of DataflowExpression in groovyx.gpars.dataflow

Subclasses of DataflowExpression in groovyx.gpars.dataflow

Modifier and Type	Class and Description
class	DataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable.
static class	DataflowVariable.RemoteDataflowVariable<T>
class	LazyDataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
class	SyncDataflowVariable<T> A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.

Methods in groovyx.gpars.dataflow that return DataflowExpression

Modifier and Type	Method and Description
private DataflowExpression<T>	DataflowQueue.hookWheneverBoundListeners(DataflowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression
DataflowExpression<T>	DataflowQueue.poll() Retrieves the value at the head of the buffer.
DataflowExpression<T>	SelectableChannel.poll() Retrieves the value at the head of the buffer.
DataflowExpression<T>	SyncDataflowStreamReadAdapter.poll()

Methods in groovyx.gpars.dataflow with parameters of type DataflowExpression

Modifier and Type	Method and Description
private DataflowExpression<T>	DataflowQueue.hookWheneverBoundListeners(DataflowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression

Uses of DataflowExpression in groovyx.gpars.dataflow.expression

Subclasses of DataflowExpression in groovyx.gpars.dataflow.expression

Modifier and Type	Class and Description
class	DataflowComplexExpression<T> Provides the infrastructure for dataflow expressions to evaluate arguments.
private static class	DataflowExpression.TransformMany<V>
private static class	DataflowExpression.TransformOne<V>
class	DataflowGetPropertyExpression<T> A DFE, which evaluates a property when the receiver becomes available
class	DataflowInvocationExpression A dataflow expression, which invokes a method after the receiver as well as all the arguments become available
class	RemoteDataflowExpression<T>

Fields in groovyx.gpars.dataflow.expression declared as DataflowExpression

Modifier and Type	Field and Description
private DataflowExpression<T>	DataflowExpression.BindDataflow.expr
private DataflowExpression<T>	DataflowGetPropertyExpression.receiver

Methods in groovyx.gpars.dataflow.expression that return DataflowExpression

Modifier and Type	Method and Description
DataflowExpression<T>	DataflowExpression.poll() Retrieves the bound value.
static <V> DataflowExpression<V>	DataflowExpression.transform(java.lang.Object another, groovy.lang.Closure closure) Transforms values bound eventually to dataflow variables using the supplied closure.

Constructors in groovyx.gpars.dataflow.expression with parameters of type DataflowExpression

Constructor and Description
DataflowExpression.BindDataflow(DataflowExpression<T> expr, T message, java.util.UUID hostId)
DataflowGetPropertyExpression(DataflowExpression<T> expression, java.lang.String name)

Uses of DataflowExpression in groovyx.gpars.dataflow.stream

Methods in groovyx.gpars.dataflow.stream that return DataflowExpression

Modifier and Type	Method and Description
private DataflowExpression<T>	StreamCore.hookWheneverBoundListeners(DataflowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression
DataflowExpression<T>	DataflowStreamReadAdapter.poll()

Methods in groovyx.gpars.dataflow.stream with parameters of type DataflowExpression

Modifier and Type	Method and Description
private DataflowExpression<T>	StreamCore.hookWheneverBoundListeners(DataflowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression