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

Packages that use DataflowExpression

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

private DataflowExpression<java.lang.Object>	Actor.joinLatch
private DataflowExpression<java.lang.Object>	Actor.MyRemoteHandle.joinLatch

Methods in groovyx.gpars.actor that return DataflowExpression

DataflowExpression<java.lang.Object>

Actor.getJoinLatch() Join-point for this actor

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

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

class	DataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable.
static class	DataflowVariable.RemoteDataflowVariable<T>
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

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>	DataflowReadChannel.poll() Retrieves the value at the head of the buffer.
DataflowExpression<T>	SyncDataflowStreamReadAdapter.poll()

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

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

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

private DataflowExpression<T>	DataflowExpression.BindDataflow.expr
private DataflowExpression<T>	DataflowGetPropertyExpression.receiver

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

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

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

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

private DataflowExpression<T>

StreamCore.hookWheneverBoundListeners(DataflowExpression<T> expr) Hooks the registered when bound handlers to the supplied dataflow expression