groovyx.gpars.dataflow.expression
Class DataflowExpression.TransformMany<V>

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.dataflow.expression.DataflowExpression<T>
          groovyx.gpars.dataflow.expression.DataflowComplexExpression<V>
              groovyx.gpars.dataflow.expression.DataflowExpression.TransformMany<V>

All Implemented Interfaces:

groovy.lang.GroovyObject, DataflowReadChannel<V>, java.io.Serializable

Enclosing class:

DataflowExpression<T>

private static class DataflowExpression.TransformMany<V>
extends DataflowComplexExpression<V>

Nested Class Summary

Nested classes/interfaces inherited from class groovyx.gpars.dataflow.expression.DataflowExpression

DataflowExpression.BindDataflow<T>, DataflowExpression.DataflowExpressionsCollector

Field Summary

private groovy.lang.Closure	closure
private static long	serialVersionUID

Fields inherited from class groovyx.gpars.dataflow.expression.DataflowComplexExpression

args

Fields inherited from class groovyx.gpars.dataflow.expression.DataflowExpression

error, S_INITIALIZED, S_INITIALIZING, S_NOT_INITIALIZED, state, value

Fields inherited from class groovyx.gpars.serial.WithSerialId

serialHandle

Constructor Summary

private

DataflowExpression.TransformMany(java.util.Collection<?> collection, groovy.lang.Closure closure)

Method Summary

protected V

evaluate() Evaluates all the arguments

Methods inherited from class groovyx.gpars.dataflow.expression.DataflowComplexExpression

subscribe

Methods inherited from class groovyx.gpars.dataflow.expression.DataflowExpression

binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, bind, bindError, bindSafely, bindUnique, doBindImpl, doBindRemote, filter, filter, filter, filter, filter, filter, getEventManager, getMetaClass, getProperty, getVal, getVal, getValAsync, getValAsync, chainWith, chainWith, chainWith, chainWith, chainWith, chainWith, choice, choice, choice, choice, choice, choice, into, into, into, into, into, into, invokeMethod, isBound, join, join, length, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, or, or, poll, rightShift, separate, separate, separate, separate, separate, separate, setMetaClass, setProperty, scheduleCallback, split, split, split, split, split, split, split, split, split, split, split, split, subscribe, tap, tap, tap, tap, tap, tap, then, then, then, toString, transform, whenBound, whenBound, whenBound, whenBound, wheneverBound, wheneverBound

Methods inherited from class groovyx.gpars.serial.WithSerialId

createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

closure

private final groovy.lang.Closure closure

Constructor Detail

DataflowExpression.TransformMany

private DataflowExpression.TransformMany(java.util.Collection<?> collection,
                                         groovy.lang.Closure closure)

Method Detail

evaluate

protected V evaluate()

Description copied from class: DataflowComplexExpression

Evaluates all the arguments

Overrides:

evaluate in class DataflowComplexExpression<V>

Returns:

The value to bind