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