Package | Description |
---|---|
groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
groovyx.gpars.dataflow.stream |
Class and Description |
---|
DataflowStreamReadAdapter
Adapts a DataflowStream to accommodate for the DataflowReadChannel interface.
|
DataflowStreamWriteAdapter
Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
|
StreamCore
Represents a common base for publish-subscribe deterministic channels.
|
Class and Description |
---|
FList
Represents a list implemented as a Functional Queue.
|
StreamCore
Represents a common base for publish-subscribe deterministic channels.
|