Uses of Class
groovyx.gpars.dataflow.operator.Pipeline

Packages that use Pipeline

groovyx.gpars.dataflow.operator

This package holds classes representing operators and channels necessary for full dataflow concurrency.

Uses of Pipeline in groovyx.gpars.dataflow.operator

Methods in groovyx.gpars.dataflow.operator that return Pipeline

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