| 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.
|