Uses of Class
groovyx.gpars.dataflow.stream.DataFlowStream

Packages that use DataFlowStream

groovyx.gpars.dataflow.stream

Uses of DataFlowStream in groovyx.gpars.dataflow.stream

Fields in groovyx.gpars.dataflow.stream declared as DataFlowStream

private DataFlowStream<T>	DataFlowStreamReadAdapter.asyncHead
private DataFlowStream<T>	DataFlowStreamReadAdapter.head
private DataFlowStream<T>	DataFlowStreamWriteAdapter.head

Fields in groovyx.gpars.dataflow.stream with type parameters of type DataFlowStream

private java.util.concurrent.atomic.AtomicReference<DataFlowStream<T>>

DataFlowStream.rest

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

DataFlowStream<T>	DataFlowStream.apply(groovy.lang.Closure closure) Calls the supplied closure with the stream as a parameter
DataFlowStream<T>	DataFlowStream.generate(T seed, groovy.lang.Closure generator, groovy.lang.Closure condition) Populates the stream with generated values
protected DataFlowStream<T>	DataFlowStreamWriteAdapter.getHead()
DataFlowStream<T>	DataFlowStream.leftShift(DataFlowReadChannel<T> ref) Adds a dataflow variable value to the stream, once the value is available
DataFlowStream<T>	DataFlowStream.leftShift(T value) Adds a value to the stream

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

private void	DataFlowStream.filter(DataFlowStream<T> rest, groovy.lang.Closure filterClosure, DataFlowStream<T> result)
private void	DataFlowStream.filter(DataFlowStream<T> rest, groovy.lang.Closure filterClosure, DataFlowStream<T> result)
private void	DataFlowStream.generateNext(T value, DataFlowStream<T> stream, groovy.lang.Closure generator, groovy.lang.Closure condition)
private void	DataFlowStream.map(FList<T> rest, groovy.lang.Closure mapClosure, DataFlowStream result)

Constructors in groovyx.gpars.dataflow.stream with parameters of type DataFlowStream

DataFlowStreamReadAdapter(DataFlowStream<T> stream)
Creates a new adapter

DataFlowStreamWriteAdapter(DataFlowStream<T> stream)
Creates a new adapter