groovyx.gpars.dataflow.expression
Class DataflowGetPropertyExpression<T>

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.dataflow.expression.DataflowExpression<T>
          groovyx.gpars.dataflow.expression.DataflowGetPropertyExpression<T>

All Implemented Interfaces:

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

public class DataflowGetPropertyExpression<T>
extends DataflowExpression<T>

A DFE, which evaluates a property when the receiver becomes available

Author:

Alex Tkachman

See Also:

Serialized Form

Nested Class Summary

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

DataflowExpression.BindDataflow<T>, DataflowExpression.DataflowExpressionsCollector

Field Summary

private java.lang.String	name
private DataflowExpression<T>	receiver
private static long	serialVersionUID

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

DataflowGetPropertyExpression(DataflowExpression<T> expression, java.lang.String name)

Method Summary

protected T	evaluate() Retrieves the receiver's property value
protected void	subscribe(DataflowExpression.DataflowExpressionsCollector listener)

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

receiver

private final DataflowExpression<T> receiver

name

private final java.lang.String name

Constructor Detail

DataflowGetPropertyExpression

public DataflowGetPropertyExpression(DataflowExpression<T> expression,
                                     java.lang.String name)

Method Detail

subscribe

protected void subscribe(DataflowExpression.DataflowExpressionsCollector listener)

Overrides:

subscribe in class DataflowExpression<T>

evaluate

protected T evaluate()

Retrieves the receiver's property value

Overrides:

evaluate in class DataflowExpression<T>

Returns:

The value to bind