groovyx.gpars.dataflow
Class DataflowExpression.TransformOne<V>

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.dataflow.DataflowExpression<V>
          groovyx.gpars.dataflow.DataflowExpression.TransformOne<V>

All Implemented Interfaces:

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

Enclosing class:

DataflowExpression<T>

private static class DataflowExpression.TransformOne<V>
extends DataflowExpression<V>

Nested Class Summary

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

DataflowExpression.BindDataflow<T>, DataflowExpression.DataflowExpressionsCollector

Field Summary

(package private) java.lang.Object	arg
private groovy.lang.Closure	closure
private static long	serialVersionUID

Fields inherited from class groovyx.gpars.dataflow.DataflowExpression

S_INITIALIZED, S_INITIALIZING, S_NOT_INITIALIZED, state, stateUpdater, value, waitingUpdater

Fields inherited from class groovyx.gpars.serial.WithSerialId

serialHandle

Constructor Summary

private

DataflowExpression.TransformOne(java.lang.Object another, groovy.lang.Closure closure)

Method Summary

protected V	evaluate() Evaluate expression after the ones we depend on are ready
protected void	subscribe(DataflowExpression.DataflowExpressionsCollector listener)

Methods inherited from class groovyx.gpars.dataflow.DataflowExpression

bind, bindSafely, bindUnique, doBindRemote, getMetaClass, getProperty, getVal, getVal, getValAsync, getValAsync, invokeMethod, isBound, join, join, poll, rightShift, setMetaClass, setProperty, subscribe, 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

arg

java.lang.Object arg

closure

private final groovy.lang.Closure closure

Constructor Detail

DataflowExpression.TransformOne

private DataflowExpression.TransformOne(java.lang.Object another,
                                        groovy.lang.Closure closure)

Method Detail

evaluate

protected V evaluate()

Description copied from class: DataflowExpression

Evaluate expression after the ones we depend on are ready

Overrides:

evaluate in class DataflowExpression<V>

Returns:

value to bind

subscribe

protected void subscribe(DataflowExpression.DataflowExpressionsCollector listener)

Overrides:

subscribe in class DataflowExpression<V>