org.codehaus.gpars

groovyx.gpars.dataflow.expression
[Java] Class DataflowComplexExpression

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.dataflow.expression.DataflowExpression
          groovyx.gpars.dataflow.expression.DataflowComplexExpression

public abstract class DataflowComplexExpression
extends DataflowExpression

Provides the infrastructure for dataflow expressions to evaluate arguments. The arguments may be dataflow expressions of themselves and so we cannot evaluate them before they all have real values bound to them.

Authors:
Alex Tkachman


Field Summary
protected java.lang.Object[] args

private static long serialVersionUID

 
Fields inherited from class DataflowExpression
ATTACHMENT, A_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED, CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED, RESULT, S_INITIALIZED, S_INITIALIZING, S_NOT_INITIALIZED, dummyWaitingThread, error, eventManager, metaClass, serialVersionUID, state, value, waiting
 
Fields inherited from class WithSerialId
serialHandle, serialVersionUID
 
Constructor Summary
protected DataflowComplexExpression(java.lang.Object... elements)

 
Method Summary
protected java.lang.Object evaluate()

protected void subscribe(DataflowExpressionsCollector listener)

 
Methods inherited from class DataflowExpression
DataflowExpression, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, bind, bindError, bindSafely, bindUnique, chainWith, chainWith, chainWith, chainWith, chainWith, chainWith, choice, choice, choice, choice, choice, choice, createEventManager, doBind, doBindImpl, doBindRemote, doThenForkAndJoin, evaluate, filter, filter, filter, filter, filter, filter, fireBindError, fireBindError, fireOnMessage, getBindErrorManager, getEventManager, getMetaClass, getProperty, getVal, getVal, getValAsync, getValAsync, handleInterruption, into, into, into, into, into, into, invokeMethod, isBound, join, join, length, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, notifyRemote, or, or, poll, rightShift, scheduleCallback, separate, separate, separate, separate, separate, separate, setMetaClass, setProperty, split, split, split, split, split, split, split, split, split, split, split, split, subscribe, subscribe, tap, tap, tap, tap, tap, tap, then, then, then, thenForkAndJoin, thenForkAndJoin, thenForkAndJoin, toString, transform, whenBound, whenBound, whenBound, whenBound, wheneverBound, wheneverBound
 
Methods inherited from class WithSerialId
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
 

Field Detail

args

protected final java.lang.Object[] args


serialVersionUID

private static final long serialVersionUID


 
Constructor Detail

DataflowComplexExpression

protected DataflowComplexExpression(java.lang.Object... elements)


 
Method Detail

evaluate

@java.lang.Override
protected java.lang.Object evaluate()


subscribe

@java.lang.Override}
protected void subscribe(DataflowExpressionsCollector listener)


 

Copyright © 2008–2013 Václav Pech. All Rights Reserved.