Uses of Interface
groovyx.gpars.dataflow.DataFlowWriteChannel

Packages that use DataFlowWriteChannel

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

Uses of DataFlowWriteChannel in groovyx.gpars.dataflow

Subinterfaces of DataFlowWriteChannel in groovyx.gpars.dataflow

interface

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

Classes in groovyx.gpars.dataflow that implement DataFlowWriteChannel

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>

Methods in groovyx.gpars.dataflow that return DataFlowWriteChannel

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

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

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

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.

Uses of DataFlowWriteChannel in groovyx.gpars.dataflow.stream

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

class

DataFlowStreamWriteAdapter<T> Adapts a DataFlowStream to accommodate for the DataFlowWriteChannel interface.

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

DataFlowWriteChannel<T>	DataFlowStreamWriteAdapter.leftShift(DataFlowReadChannel<T> ref)
DataFlowWriteChannel<T>	DataFlowStreamWriteAdapter.leftShift(T value)