Package groovyx.gpars.dataflow.stream

Interface Summary

FList<T>

Represents a list implemented as a Functional Queue.

Class Summary

DataflowStream<T>	Represents a deterministic dataflow channel.
DataflowStreamReadAdapter<T>	Adapts a DataflowStream to accommodate for the DataflowReadChannel interface.
DataflowStreamWriteAdapter<T>	Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
FListIterator<T>
StreamCore<T>	Represents a common base for publish-subscribe deterministic channels.
SyncDataflowStream<T>	Represents a synchronous deterministic dataflow channel.