Package | Description |
---|---|
groovyx.gpars.dataflow.stream |
Modifier and Type | Class and Description |
---|---|
class |
DataflowStream<T>
Represents a deterministic dataflow channel.
|
class |
StreamCore<T>
Represents a common base for publish-subscribe deterministic channels.
|
class |
SyncDataflowStream<T>
Represents a synchronous deterministic dataflow channel.
|
Modifier and Type | Field and Description |
---|---|
private FList<T> |
FListIterator.current |
Modifier and Type | Method and Description |
---|---|
FList<T> |
FList.filter(groovy.lang.Closure filterClosure) |
FList<T> |
StreamCore.filter(groovy.lang.Closure filterClosure)
Builds a filtered stream using the supplied filter closure
|
FList<T> |
DataflowStream.getRest()
Retrieves a DataflowStream representing the rest of this Stream after removing the first element
|
FList<T> |
FList.getRest() |
abstract FList<T> |
StreamCore.getRest()
Retrieves a DataflowStream representing the rest of this Stream after removing the first element
|
FList<T> |
SyncDataflowStream.getRest()
Retrieves a DataflowStream representing the rest of this Stream after removing the first element
|
FList<java.lang.Object> |
FList.map(groovy.lang.Closure mapClosure) |
FList<java.lang.Object> |
StreamCore.map(groovy.lang.Closure mapClosure)
Builds a modified stream using the supplied map closure
|
Modifier and Type | Method and Description |
---|---|
private void |
StreamCore.map(FList<T> rest,
groovy.lang.Closure mapClosure,
StreamCore<java.lang.Object> result) |
private T |
StreamCore.reduce(T current,
FList<T> rest,
groovy.lang.Closure reduceClosure) |
Constructor and Description |
---|
FListIterator(FList<T> list) |