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

Packages that use StreamCore

Package	Description
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

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

Uses of StreamCore in groovyx.gpars.dataflow.stream

Subclasses of StreamCore in groovyx.gpars.dataflow.stream

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

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

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicReference<StreamCore<T>>	StreamCore.rest

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

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

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

Constructor and Description
DataflowStreamReadAdapter(StreamCore<T> stream) Creates a new adapter
DataflowStreamWriteAdapter(StreamCore<T> stream) Creates a new adapter