Uses of Interface
groovyx.gpars.dataflow.DataflowReadChannel

Packages that use DataflowReadChannel

groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.impl
groovyx.gpars.dataflow.stream

Uses of DataflowReadChannel in groovyx.gpars.dataflow

Subinterfaces of DataflowReadChannel in groovyx.gpars.dataflow

interface

DataflowChannel<T> A common interface for all dataflow variables, streams or queues

Classes in groovyx.gpars.dataflow that implement DataflowReadChannel

class	DataflowComplexExpression<T>
class	DataflowExpression<T> The base class for all dataflow elements.
private static class	DataflowExpression.TransformMany<V>
private static class	DataflowExpression.TransformOne<V>
class	DataflowGetPropertyExpression<T> DFE which evaluate property when receiver became available
class	DataflowInvocationExpression Data flow expression which invokes method of object after receiver and all arguments became available
class	DataflowQueue<T> Represents a thread-safe data flow stream.
class	DataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable.
static class	DataflowVariable.RemoteDataflowVariable<T>
class	RemoteDataflowExpression<T>

Methods in groovyx.gpars.dataflow that return DataflowReadChannel

DataflowReadChannel<T>

DataflowBroadcast.createReadChannel() Retrieves an implementation of DataflowReadChannel to read all messages submitted to the broadcast chanel.

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

private DataflowWriteChannel<T>	DataflowVariable.bindDFV(DataflowReadChannel<T> ref)
DataflowWriteChannel<T>	DataflowQueue.leftShift(DataflowReadChannel<T> ref) Adds a DataflowVariable to the buffer.
DataflowWriteChannel<T>	DataflowVariable.leftShift(DataflowReadChannel<T> ref) Assigns a value from one DataflowVariable instance to this variable.
DataflowWriteChannel<T>	DataflowWriteChannel.leftShift(DataflowReadChannel<T> ref) Assigns a value from one DataflowVariable instance to this variable.
static groovyx.gpars.dataflow.operator.DataflowProcessor	Dataflow.operator(DataflowReadChannel input, DataflowWriteChannel output, groovy.lang.Closure code) Creates an operator using the current parallel group
static groovyx.gpars.dataflow.operator.DataflowProcessor	Dataflow.operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, groovy.lang.Closure code) Creates an operator using the current parallel group
static Select<?>	Dataflow.select(DataflowReadChannel<?>... channels) Creates a select using the default dataflow parallel group.
static groovyx.gpars.dataflow.operator.DataflowProcessor	Dataflow.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels) Creates a splitter copying its single input channel into all of its output channels.
static groovyx.gpars.dataflow.operator.DataflowProcessor	Dataflow.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels, int maxForks) Creates a splitter copying its single input channel into all of its output channels.

Method parameters in groovyx.gpars.dataflow with type arguments of type DataflowReadChannel

static Select<?>

Dataflow.select(java.util.List<DataflowReadChannel> channels) Creates a select using the default dataflow parallel group.

Constructors in groovyx.gpars.dataflow with parameters of type DataflowReadChannel

Select(groovyx.gpars.group.PGroup pGroup, DataflowReadChannel<? extends T>... channels)

Constructor parameters in groovyx.gpars.dataflow with type arguments of type DataflowReadChannel

Select(groovyx.gpars.group.PGroup pGroup, java.util.List<DataflowReadChannel<? extends T>> channels)

Uses of DataflowReadChannel in groovyx.gpars.dataflow.impl

Fields in groovyx.gpars.dataflow.impl declared as DataflowReadChannel

private DataflowReadChannel<? extends T>

SelectCallback.channel

Fields in groovyx.gpars.dataflow.impl with type parameters of type DataflowReadChannel

private java.util.List<DataflowReadChannel<? extends T>>

SelectBase.channels

Methods in groovyx.gpars.dataflow.impl with parameters of type DataflowReadChannel

(package private) void	SelectBase.boundNotification(int index, DataflowReadChannel<? extends T> channel) Invoked by the SelectCallback instances, potentially concurrently to inform about new values being available for read from channels.
private void	SelectBase.disableDFV(int currentPosition, DataflowReadChannel<? extends T> channel) Sets the flag in the disabledDFVs array, if the channel is a DFV

Constructors in groovyx.gpars.dataflow.impl with parameters of type DataflowReadChannel

SelectCallback(java.lang.Object owner, int index, DataflowReadChannel<? extends T> channel)

Constructor parameters in groovyx.gpars.dataflow.impl with type arguments of type DataflowReadChannel

SelectBase(groovyx.gpars.group.PGroup pGroup, java.util.List<DataflowReadChannel<? extends T>> channels)
Stores the input channel and registers for the wheneverBound() event on each

Uses of DataflowReadChannel in groovyx.gpars.dataflow.stream

Classes in groovyx.gpars.dataflow.stream that implement DataflowReadChannel

class

DataflowStreamReadAdapter<T> Adapts a DataflowStream to accommodate for the DataflowReadChannel interface.

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

DataflowStream<T>	DataflowStream.leftShift(DataflowReadChannel<T> ref) Adds a dataflow variable value to the stream, once the value is available
DataflowWriteChannel<T>	DataflowStreamWriteAdapter.leftShift(DataflowReadChannel<T> ref)