Package | Description |
---|---|
groovyx.gpars.dataflow |
This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
|
groovyx.gpars.dataflow.remote | |
groovyx.gpars.dataflow.stream | |
groovyx.gpars.remote.message |
This package holds message classes for the remote actors implementation.
|
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 |
---|
DataflowStreamWriteAdapter
Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
|
Class and Description |
---|
DataflowStreamWriteAdapter
Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
|
FList
Represents a list implemented as a Functional Queue.
|
StreamCore
Represents a common base for publish-subscribe deterministic channels.
|
Class and Description |
---|
DataflowStreamWriteAdapter
Adapts a DataflowStream to accommodate for the DataflowWriteChannel interface.
|