groovyx.gpars.dataflow.expression

Class RemoteDataflowExpression<T>

java.lang.Object

groovyx.gpars.serial.WithSerialId

groovyx.gpars.dataflow.expression.DataflowExpression<T>

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

All Implemented Interfaces:

groovy.lang.GroovyObject, DataflowReadChannel<T>, SelectableChannel<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

Fields

Modifier and Type	Field and Description
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

Constructors

Constructor and Description
RemoteDataflowExpression()

Method Summary

Methods

Modifier and Type	Method and Description
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, chainWith, chainWith, chainWith, chainWith, chainWith, chainWith, choice, choice, choice, choice, choice, choice, doBindImpl, doBindRemote, filter, filter, filter, filter, filter, filter, getBindErrorManager, getEventManager, getMetaClass, getProperty, getVal, getVal, getValAsync, getValAsync, 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, scheduleCallback, separate, separate, separate, separate, separate, separate, setMetaClass, setProperty, split, split, split, split, split, split, split, split, split, split, split, split, 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 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>