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

java.lang.Object
  extended by groovyx.gpars.serial.WithSerialId
      extended by groovyx.gpars.dataflow.expression.DataflowExpression<T>
          extended by groovyx.gpars.dataflow.expression.RemoteDataflowExpression<T>
All Implemented Interfaces:
groovy.lang.GroovyObject, DataflowReadChannel<T>, RemoteSerialized, java.io.Serializable

public class RemoteDataflowExpression<T>
extends DataflowExpression<T>
implements RemoteSerialized

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  RemoteHost remoteHost
           
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
RemoteDataflowExpression()
           
 
Method Summary
protected  T evaluate()
          Evaluates the expression after the ones we depend on are ready
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

remoteHost

private final RemoteHost remoteHost
Constructor Detail

RemoteDataflowExpression

public RemoteDataflowExpression()
Method Detail

evaluate

protected T evaluate()
Description copied from class: DataflowExpression
Evaluates the expression after the ones we depend on are ready

Overrides:
evaluate in class DataflowExpression<T>
Returns:
The value to bind

subscribe

protected void subscribe(DataflowExpression.DataflowExpressionsCollector listener)
Overrides:
subscribe in class DataflowExpression<T>

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