Uses of Interface
groovyx.gpars.dataflow.DataflowWriteChannel

Packages that use DataflowWriteChannel

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.stream
groovyx.gpars.group

Uses of DataflowWriteChannel in groovyx.gpars.dataflow

Subinterfaces of DataflowWriteChannel 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 DataflowWriteChannel

Modifier and Type	Class and Description
class	DataflowBroadcast<T> Offers a deterministic one-to-many and many-to-many messaging alternative to DataflowQueue.
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	SyncDataflowBroadcast<T> Offers a synchronous deterministic one-to-many and many-to-many messaging alternative to SyncDataflowQueue.
class	SyncDataflowQueue<T> Represents a thread-safe synchronous data flow stream.
class	SyncDataflowVariable<T> A synchronous variant of DataflowVariable, which blocks the writer as well as the readers.

Methods in groovyx.gpars.dataflow that return DataflowWriteChannel

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.
DataflowWriteChannel<T>	DataflowQueue.leftShift(T value) Adds a DataflowVariable representing the passed in value to the buffer.
DataflowWriteChannel<T>	DataflowVariable.leftShift(T value) Assigns a value to the variable.
DataflowWriteChannel<T>	DataflowWriteChannel.leftShift(T value) Assigns a value to the variable.

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

Modifier and Type	Method and Description
void	DataflowQueue.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowQueue.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowReadChannel.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowQueue.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowQueue.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowReadChannel.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowQueue.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowQueue.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowReadChannel.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowQueue.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowQueue.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowReadChannel.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowQueue.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowQueue.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowReadChannel.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowQueue.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowQueue.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowReadChannel.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowReadChannel.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
void	DataflowQueue.into(DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
void	DataflowQueue.into(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
void	DataflowQueue.into(PGroup group, DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(PGroup group, DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
void	DataflowQueue.into(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
void	DataflowQueue.into(Pool pool, DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(Pool pool, DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
void	DataflowQueue.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowReadChannel.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
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
void	DataflowQueue.or(DataflowWriteChannel<T> target)
void	DataflowReadChannel.or(DataflowWriteChannel<T> target) Makes the output of the current channel to be an input for the specified channel
void	DataflowQueue.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowQueue.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowReadChannel.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowQueue.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowReadChannel.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowQueue.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowReadChannel.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowQueue.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowReadChannel.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowQueue.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowReadChannel.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowQueue.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowReadChannel.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
void	DataflowReadChannel.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2) Splits the output of the current channel to be an input for the specified channels
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.

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

Modifier and Type	Method and Description
void	DataflowQueue.choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.choice(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.choice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowReadChannel.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	DataflowQueue.separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.separate(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.separate(PGroup group, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(PGroup group, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.separate(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowReadChannel.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	DataflowQueue.split(java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(PGroup group, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(PGroup group, java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
void	DataflowQueue.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowReadChannel.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets) Makes the output of the current channel to be an input for the specified channels
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.

Uses of DataflowWriteChannel in groovyx.gpars.dataflow.expression

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

Modifier and Type	Method and Description
void	DataflowExpression.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowExpression.into(DataflowWriteChannel<T> target)
void	DataflowExpression.into(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowExpression.into(PGroup group, DataflowWriteChannel<T> target)
void	DataflowExpression.into(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowExpression.into(Pool pool, DataflowWriteChannel<T> target)
void	DataflowExpression.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowExpression.or(DataflowWriteChannel<T> target)
void	DataflowExpression.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowExpression.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
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)

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

Modifier and Type	Method and Description
void	DataflowExpression.choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.choice(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.choice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowExpression.separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.separate(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.separate(PGroup group, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.separate(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowExpression.split(java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowExpression.split(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowExpression.split(PGroup group, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowExpression.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowExpression.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowExpression.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)

Uses of DataflowWriteChannel in groovyx.gpars.dataflow.operator

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

Modifier and Type	Method and Description
DataflowWriteChannel<?>	DataflowProcessor.getOutput() The processor's first / only output channel
DataflowWriteChannel<?>	DataflowProcessor.getOutputs(int idx) The processor's output channel of the given index

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

Modifier and Type	Method and Description
(package private) static java.util.List<DataflowWriteChannel<?>>	DataflowProcessor.extractOutputs(java.util.Map<java.lang.String,java.lang.Object> channels)
java.util.List<DataflowWriteChannel<?>>	DataflowProcessor.getOutputs() The processor's all output channels

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

Modifier and Type	Method and Description
<T> void	Pipeline.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
<T> void	Pipeline.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
<T> void	Pipeline.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
<T> void	Pipeline.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code) Directs the output to one of the two output channels depending on the boolean result of the provided closure.
protected java.lang.Object	DataflowProcessor.fireMessageSentOut(DataflowWriteChannel channel, int index, java.lang.Object message)
<V> void	Pipeline.into(DataflowWriteChannel<V> target) Makes the output of the pipeline to be an input for the specified channel
<V> void	Pipeline.into(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<V> target) Makes the output of the pipeline to be an input for the specified channel
java.lang.Object	DataflowEventAdapter.messageSentOut(DataflowProcessor processor, DataflowWriteChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message is being bound to an output channel.
java.lang.Object	DataflowEventListener.messageSentOut(DataflowProcessor processor, DataflowWriteChannel<java.lang.Object> channel, int index, java.lang.Object message) Invoked when a message is being bound to an output channel.
<V> void	Pipeline.or(DataflowWriteChannel<V> target) Makes the output of the pipeline to be an input for the specified channel
<V> void	Pipeline.split(DataflowWriteChannel<V> target1, DataflowWriteChannel<V> target2) Splits the output of the pipeline to be an input for the specified channels
<V> void	Pipeline.split(DataflowWriteChannel<V> target1, DataflowWriteChannel<V> target2) Splits the output of the pipeline to be an input for the specified channels
<V> void	Pipeline.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<V> target1, DataflowWriteChannel<V> target2) Splits the output of the pipeline to be an input for the specified channels
<V> void	Pipeline.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<V> target1, DataflowWriteChannel<V> target2) Splits the output of the pipeline to be an input for the specified channels
<V> Pipeline	Pipeline.tap(DataflowWriteChannel<V> target) Taps into the pipeline at the current position, sending all data that pass through the pipeline also to the channel specified.
<V> Pipeline	Pipeline.tap(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<V> target) Taps into the pipeline at the current position, sending all data that pass through the pipeline also to the channel specified.

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

Modifier and Type	Method and Description
<T> void	Pipeline.choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
<T> void	Pipeline.choice(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code) Directs the output to one of the output channels depending on the int result of the provided closure.
void	Pipeline.separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
void	Pipeline.separate(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code) Allows the closure to output different values to different output channels.
<V> void	Pipeline.split(java.util.List<DataflowWriteChannel<V>> targets) Makes the output of the pipeline to be an input for the specified channels
<V> void	Pipeline.split(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<V>> targets) Makes the output of the pipeline to be an input for the specified channels

Uses of DataflowWriteChannel in groovyx.gpars.dataflow.stream

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

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

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

Modifier and Type	Method and Description
DataflowWriteChannel<T>	DataflowStreamWriteAdapter.leftShift(DataflowReadChannel<T> ref)
DataflowWriteChannel<T>	DataflowStreamWriteAdapter.leftShift(T value)

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

Modifier and Type	Method and Description
void	DataflowStreamReadAdapter.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
void	DataflowStreamReadAdapter.into(DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.into(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.into(PGroup group, DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.into(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.into(Pool pool, DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.or(DataflowWriteChannel<T> target)
void	DataflowStreamReadAdapter.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
void	DataflowStreamReadAdapter.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
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)

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

Modifier and Type	Method and Description
void	DataflowStreamReadAdapter.choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.choice(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.choice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
void	DataflowStreamReadAdapter.separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.separate(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.separate(PGroup group, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.separate(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
void	DataflowStreamReadAdapter.split(java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowStreamReadAdapter.split(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowStreamReadAdapter.split(PGroup group, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowStreamReadAdapter.split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowStreamReadAdapter.split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)
void	DataflowStreamReadAdapter.split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)

Uses of DataflowWriteChannel in groovyx.gpars.group

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

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

Method parameters in groovyx.gpars.group with type arguments of type DataflowWriteChannel

Modifier and Type	Method and Description
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.