Uses of Interface
groovyx.gpars.dataflow.DataflowReadChannel

Packages that use DataflowReadChannel

Package	Description
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.operator	This package holds classes representing operators and channels necessary for full dataflow concurrency.
groovyx.gpars.dataflow.operator.component
groovyx.gpars.dataflow.stream
groovyx.gpars.group

Uses of DataflowReadChannel in groovyx.gpars.dataflow

Subinterfaces of DataflowReadChannel in groovyx.gpars.dataflow

Modifier and Type	Interface and Description
interface	DataflowChannel<T> A common interface for all dataflow variables, streams or queues

Classes in groovyx.gpars.dataflow that implement DataflowReadChannel

Modifier and Type	Class and Description
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	LazyDataflowVariable<T> Represents a thread-safe single-assignment, multi-read variable with delayed initialization.
class	SyncDataflowQueue<T> Represents a thread-safe synchronous data flow stream.
(package private) class	SyncDataflowStreamReadAdapter<T> Provides a special implementation of DataflowStreamReadAdapter, which cooperates with SyncDataflowBroadcast subscription and un-subscription mechanism.
class	SyncDataflowVariable<T> A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.

Methods in groovyx.gpars.dataflow that return DataflowReadChannel

Modifier and Type	Method and Description
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(PGroup group, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(PGroup group, groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
<V> DataflowReadChannel<V>	SyncDataflowQueue.chainWith(PGroup group, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	SyncDataflowStreamReadAdapter.chainWith(PGroup group, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	SyncDataflowVariable.chainWith(PGroup group, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(Pool pool, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(Pool pool, groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
<V> DataflowReadChannel<V>	DataflowQueue.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
DataflowReadChannel<T>	DataflowBroadcast.createReadChannel() Retrieves an implementation of DataflowReadChannel to read all messages submitted to the broadcast chanel.
DataflowReadChannel<T>	SyncDataflowBroadcast.createReadChannel() Retrieves an implementation of DataflowReadChannel to read all messages submitted to the broadcast chanel.
static DataflowReadChannel<java.lang.String>	Select.createTimeout(long timeout) Creates a timeout channel (DataflowVariable) that will bind a Select.TIMEOUT value after the specified timeout.
DataflowReadChannel<T>	DataflowQueue.filter(groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
DataflowReadChannel<T>	DataflowQueue.filter(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
DataflowReadChannel<T>	DataflowQueue.filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
DataflowReadChannel<T>	DataflowQueue.filter(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
DataflowReadChannel<T>	DataflowQueue.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
DataflowReadChannel<T>	DataflowQueue.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowReadChannel.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure) Creates and attaches a new operator that will filter data using the provided closure
<V> DataflowReadChannel<V>	DataflowQueue.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	SyncDataflowQueue.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	SyncDataflowStreamReadAdapter.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	SyncDataflowVariable.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.or(groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.or(groovy.lang.Closure<V> closure) Creates and attaches a new operator processing values from the channel
DataflowReadChannel<T>	DataflowQueue.tap(DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(DataflowWriteChannel<T> target) Taps into the pipeline.
DataflowReadChannel<T>	DataflowQueue.tap(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Taps into the pipeline.
DataflowReadChannel<T>	DataflowQueue.tap(PGroup group, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(PGroup group, DataflowWriteChannel<T> target) Taps into the pipeline.
DataflowReadChannel<T>	SyncDataflowQueue.tap(PGroup group, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	SyncDataflowStreamReadAdapter.tap(PGroup group, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	SyncDataflowVariable.tap(PGroup group, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowQueue.tap(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Taps into the pipeline.
DataflowReadChannel<T>	DataflowQueue.tap(Pool pool, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(Pool pool, DataflowWriteChannel<T> target) Taps into the pipeline.
DataflowReadChannel<T>	DataflowQueue.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowReadChannel.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Taps into the pipeline.

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

Modifier and Type	Method and Description
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.
<V> DataflowReadChannel<V>	DataflowQueue.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
static DataflowProcessor	Dataflow.operator(DataflowReadChannel input, DataflowWriteChannel output, groovy.lang.Closure code) Creates an operator using the current parallel group
static DataflowProcessor	Dataflow.operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, groovy.lang.Closure code) Creates an operator using the current parallel group
static 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 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.
void	SyncDataflowBroadcast.unsubscribeReadChannel(DataflowReadChannel<T> channel) Un-registers the supplied read channel from the broadcast.

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

Modifier and Type	Method and Description
<V> DataflowReadChannel<V>	DataflowQueue.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	SyncDataflowQueue.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	SyncDataflowStreamReadAdapter.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	SyncDataflowVariable.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowQueue.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.
<V> DataflowReadChannel<V>	DataflowQueue.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowReadChannel.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure) Merges channels together as inputs for a single dataflow operator.

Uses of DataflowReadChannel in groovyx.gpars.dataflow.expression

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

Modifier and Type	Class and Description
class	DataflowComplexExpression<T> Provides the infrastructure for dataflow expressions to evaluate arguments.
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> 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>

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

Modifier and Type	Method and Description
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(PGroup group, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(Pool pool, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
DataflowReadChannel<T>	DataflowExpression.filter(groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowExpression.filter(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowExpression.filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowExpression.filter(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowExpression.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowExpression.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.or(groovy.lang.Closure<V> closure)
DataflowReadChannel<T>	DataflowExpression.tap(DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowExpression.tap(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowExpression.tap(PGroup group, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowExpression.tap(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowExpression.tap(Pool pool, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowExpression.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)

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

Modifier and Type	Method and Description
<V> DataflowReadChannel<V>	DataflowExpression.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)

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

Modifier and Type	Method and Description
<V> DataflowReadChannel<V>	DataflowExpression.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowExpression.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)

Uses of DataflowReadChannel in groovyx.gpars.dataflow.operator

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

Modifier and Type	Field and Description
private DataflowReadChannel	Pipeline.output

Methods in groovyx.gpars.dataflow.operator that return DataflowReadChannel

Modifier and Type	Method and Description
DataflowReadChannel	Pipeline.getOutput()

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

Modifier and Type	Method and Description
(package private) static java.util.List<DataflowReadChannel<?>>	DataflowProcessor.extractInputs(java.util.Map<java.lang.String,java.lang.Object> channels)

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

Modifier and Type	Method and Description
java.lang.Object	DataflowEventAdapter.controlMessageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
java.lang.Object	DataflowEventListener.controlMessageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a control message (instances of ControlMessage) becomes available in an input channel.
protected java.lang.Object	DataflowProcessor.fireControlMessageArrived(DataflowReadChannel channel, int index, java.lang.Object message)
protected java.lang.Object	DataflowProcessor.fireMessageArrived(DataflowReadChannel channel, int index, java.lang.Object message)
(package private) Pipeline	Pipeline.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure closure) Merges channels together as inputs for a single dataflow operator.
(package private) Pipeline	Pipeline.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure closure) Merges channels together as inputs for a single dataflow operator.
java.lang.Object	DataflowEventAdapter.messageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message becomes available in an input channel.
java.lang.Object	DataflowEventListener.messageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message becomes available in an input channel.

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

Modifier and Type	Method and Description
(package private) Pipeline	Pipeline.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure closure) Merges channels together as inputs for a single dataflow operator.
(package private) Pipeline	Pipeline.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure closure) Merges channels together as inputs for a single dataflow operator.

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

Constructor and Description
Pipeline(DataflowReadChannel output)
Pipeline(PGroup group, DataflowReadChannel output)
Pipeline(Pool pool, DataflowReadChannel output)

Uses of DataflowReadChannel in groovyx.gpars.dataflow.operator.component

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

Modifier and Type	Method and Description
java.lang.Object	GracefulShutdownListener.controlMessageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Entering a non-idle state, so a notification needs to be sent to the monitor.
java.lang.Object	GracefulShutdownListener.messageArrived(DataflowProcessor processor, DataflowReadChannel<java.lang.Object> channel, int index, java.lang.Object message) Entering a non-idle state, so a notification needs to be sent to the monitor.

Uses of DataflowReadChannel in groovyx.gpars.dataflow.stream

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

Modifier and Type	Class and Description
class	DataflowStreamReadAdapter<T> Adapts a DataflowStream to accommodate for the DataflowReadChannel interface.

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

Modifier and Type	Method and Description
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(PGroup group, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(Pool pool, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.or(groovy.lang.Closure<V> closure)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(PGroup group, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(Pool pool, DataflowWriteChannel<T> target)
DataflowReadChannel<T>	DataflowStreamReadAdapter.tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)

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

Modifier and Type	Method and Description
DataflowWriteChannel<T>	DataflowStreamWriteAdapter.leftShift(DataflowReadChannel<T> ref)
StreamCore<T>	StreamCore.leftShift(DataflowReadChannel<T> ref) Adds a dataflow variable value to the stream, once the value is available
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)

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

Modifier and Type	Method and Description
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
<V> DataflowReadChannel<V>	DataflowStreamReadAdapter.merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)

Uses of DataflowReadChannel in groovyx.gpars.group

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

Modifier and Type	Method and Description
DataflowProcessor	PGroup.operator(DataflowReadChannel input, DataflowWriteChannel output, groovy.lang.Closure code) Creates an operator using the current parallel group
DataflowProcessor	PGroup.operator(DataflowReadChannel input, DataflowWriteChannel output, int maxForks, groovy.lang.Closure code) Creates an operator using the current parallel group
DataflowProcessor	PGroup.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels) Creates a splitter copying its single input channel into all of its output channels.
DataflowProcessor	PGroup.splitter(DataflowReadChannel inputChannel, java.util.List<DataflowWriteChannel> outputChannels, int maxForks) Creates a splitter copying its single input channel into all of its output channels.