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

Packages that use StreamCore

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

Uses of StreamCore in groovyx.gpars.dataflow

Constructors in groovyx.gpars.dataflow with parameters of type StreamCore

SyncDataflowStreamReadAdapter(StreamCore<T> stream)
Creates a new adapter

Uses of StreamCore in groovyx.gpars.dataflow.stream

Subclasses of StreamCore in groovyx.gpars.dataflow.stream

class	DataflowStream<T> Represents a deterministic dataflow channel.
class	SyncDataflowStream<T> Represents a synchronous deterministic dataflow channel.

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

private StreamCore<T>	DataflowStreamReadAdapter.asyncHead
private StreamCore<T>	DataflowStreamReadAdapter.head
private StreamCore<T>	DataflowStreamWriteAdapter.head

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

protected java.util.concurrent.atomic.AtomicReference<StreamCore<T>>

StreamCore.rest

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

StreamCore<T>	StreamCore.apply(groovy.lang.Closure closure) Calls the supplied closure with the stream as a parameter
protected StreamCore<T>	DataflowStream.createNewStream() A factory method to create new instances of the correct class when needed
protected abstract StreamCore<T>	StreamCore.createNewStream() A factory method to create new instances of the correct class when needed
protected StreamCore<T>	SyncDataflowStream.createNewStream() A factory method to create new instances of the correct class when needed
StreamCore<T>	StreamCore.generate(T seed, groovy.lang.Closure generator, groovy.lang.Closure condition) Populates the stream with generated values
protected StreamCore<T>	DataflowStreamWriteAdapter.getHead()
StreamCore<T>	StreamCore.leftShift(DataflowReadChannel<T> ref) Adds a dataflow variable value to the stream, once the value is available
StreamCore<T>	StreamCore.leftShift(T value) Adds a value to the stream
private StreamCore<T>	DataflowStreamWriteAdapter.updateHead() Moves head

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

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

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

DataflowStreamReadAdapter(StreamCore<T> stream)
Creates a new adapter

DataflowStreamWriteAdapter(StreamCore<T> stream)
Creates a new adapter