| Package | Description |
|---|---|
| groovyx.gpars.dataflow.operator |
This package holds classes representing operators and channels necessary for full dataflow concurrency.
|
| Modifier and Type | Method and Description |
|---|---|
<V> Pipeline |
Pipeline.chainWith(groovy.lang.Closure<V> closure)
Creates and attaches a new operator
|
<V> Pipeline |
Pipeline.chainWith(java.util.Map<java.lang.String,java.lang.Object> params,
groovy.lang.Closure<V> closure)
Creates and attaches a new operator
|
Pipeline |
Pipeline.filter(groovy.lang.Closure<java.lang.Boolean> closure)
Creates and attaches a new operator that will filter data using the provided closure
|
Pipeline |
Pipeline.filter(java.util.Map<java.lang.String,java.lang.Object> params,
groovy.lang.Closure<java.lang.Boolean> closure)
Creates and attaches a new operator that will filter data using the provided closure
|
(package private) Pipeline |
Pipeline.merge(DataflowReadChannel<java.lang.Object> other,
groovy.lang.Closure closure)
Merges channels together as inputs for a single dataflow operator.
|
(package private) Pipeline |
Pipeline.merge(java.util.List<DataflowReadChannel<java.lang.Object>> others,
groovy.lang.Closure closure)
Merges channels together as inputs for a single dataflow operator.
|
(package private) Pipeline |
Pipeline.merge(java.util.Map<java.lang.String,java.lang.Object> params,
DataflowReadChannel<java.lang.Object> other,
groovy.lang.Closure closure)
Merges channels together as inputs for a single dataflow operator.
|
(package private) Pipeline |
Pipeline.merge(java.util.Map<java.lang.String,java.lang.Object> params,
java.util.List<DataflowReadChannel<java.lang.Object>> others,
groovy.lang.Closure closure)
Merges channels together as inputs for a single dataflow operator.
|
<V> Pipeline |
Pipeline.or(groovy.lang.Closure<V> closure)
Creates and attaches a new operator
|
<V> Pipeline |
Pipeline.tap(DataflowWriteChannel<V> target)
Taps into the pipeline at the current position, sending all data that pass through the pipeline also to the channel specified.
|
<V> Pipeline |
Pipeline.tap(java.util.Map<java.lang.String,java.lang.Object> params,
DataflowWriteChannel<V> target)
Taps into the pipeline at the current position, sending all data that pass through the pipeline also to the channel specified.
|