groovyx.gpars.dataflow
Class DataflowVariable.RemoteDataflowVariable<T>

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

All Implemented Interfaces:

groovy.lang.GroovyObject, DataflowChannel<T>, DataflowReadChannel<T>, DataflowWriteChannel<T>, Promise<T>, RemoteSerialized, java.io.Serializable

Enclosing class:

DataflowVariable<T>

public static final class DataflowVariable.RemoteDataflowVariable<T>
extends DataflowVariable<T>
implements RemoteSerialized

See Also:

Serialized Form

Nested Class Summary

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

DataflowVariable.RemoteDataflowVariable<T>

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

DataflowExpression.BindDataflow<T>

Field Summary

private boolean	disconnected
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

DataflowVariable.RemoteDataflowVariable(RemoteHost host)

Method Summary

Methods inherited from class groovyx.gpars.dataflow.DataflowVariable

get, get, getError, getRemoteClass, isError, leftShift, leftShift, shouldThrowTimeout, then, then, then

Methods inherited from class groovyx.gpars.dataflow.expression.DataflowExpression

binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, bind, bindError, bindSafely, bindUnique, doBindImpl, doBindRemote, evaluate, 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, 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, writeReplace

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface groovyx.gpars.dataflow.DataflowReadChannel

binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, filter, filter, filter, filter, filter, filter, getEventManager, getVal, getVal, getValAsync, getValAsync, chainWith, chainWith, chainWith, chainWith, chainWith, chainWith, choice, choice, choice, choice, choice, choice, into, into, into, into, into, into, isBound, length, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, or, or, poll, rightShift, separate, separate, separate, separate, separate, separate, split, split, split, split, split, split, split, split, split, split, split, split, tap, tap, tap, tap, tap, tap, then, then, then, whenBound, whenBound, whenBound, whenBound, wheneverBound, wheneverBound

Methods inherited from interface groovyx.gpars.dataflow.DataflowWriteChannel

bind

Methods inherited from interface groovyx.gpars.dataflow.Promise

isBound, join, join, rightShift, then, then, then, whenBound, whenBound, whenBound, whenBound

Field Detail

serialVersionUID

private static final long serialVersionUID

See Also:

Constant Field Values

remoteHost

private final RemoteHost remoteHost

disconnected

private boolean disconnected

Constructor Detail

DataflowVariable.RemoteDataflowVariable

public DataflowVariable.RemoteDataflowVariable(RemoteHost host)