T
- Type of values to bind with the DataflowVariablepublic class DataflowVariable<T> extends DataflowExpression<T> implements DataflowChannel<T>, Promise<T>
Modifier and Type | Class and Description |
---|---|
static class |
DataflowVariable.RemoteDataflowVariable<T> |
DataflowExpression.BindDataflow<T>
Modifier and Type | Field and Description |
---|---|
private static long |
serialVersionUID |
S_INITIALIZED, S_INITIALIZING, S_NOT_INITIALIZED, state, value
serialHandle
Constructor and Description |
---|
DataflowVariable()
Creates a new unbound Dataflow Variable
|
Modifier and Type | Method and Description |
---|---|
private DataflowWriteChannel<T> |
bindDFV(DataflowReadChannel<T> ref) |
T |
get()
Retrieves the value of the variable, blocking until a value is available
|
T |
get(long timeout,
java.util.concurrent.TimeUnit units)
Retrieves the value of the variable, blocking up to given timeout, if the value has not been assigned yet.
|
java.lang.Class<DataflowVariable.RemoteDataflowVariable> |
getRemoteClass()
Class of remote object to be created
|
DataflowWriteChannel<T> |
leftShift(DataflowReadChannel<T> ref)
Assigns a value from one DataflowVariable instance to this variable.
|
DataflowWriteChannel<T> |
leftShift(T value)
Assigns a value to the variable.
|
(package private) boolean |
shouldThrowTimeout() |
binaryChoice, binaryChoice, binaryChoice, bind, bindSafely, bindUnique, chainWith, chainWith, chainWith, choice, choice, choice, doBindImpl, doBindRemote, evaluate, filter, filter, filter, getMetaClass, getProperty, getVal, getVal, getValAsync, getValAsync, into, into, into, invokeMethod, isBound, join, join, length, merge, merge, merge, merge, merge, merge, or, or, poll, rightShift, scheduleCallback, separate, separate, separate, setMetaClass, setProperty, split, split, split, split, split, split, subscribe, subscribe, tap, tap, tap, then, then, then, toString, transform, whenBound, whenBound, whenBound, whenBound, wheneverBound, wheneverBound
createRemoteHandle, getOrCreateSerialHandle, writeReplace
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
binaryChoice, binaryChoice, binaryChoice, chainWith, chainWith, chainWith, choice, choice, choice, filter, filter, filter, getVal, getVal, getValAsync, getValAsync, into, into, into, isBound, length, merge, merge, merge, merge, merge, merge, or, or, poll, rightShift, separate, separate, separate, split, split, split, split, split, split, tap, tap, tap, then, then, then, whenBound, whenBound, whenBound, whenBound, wheneverBound, wheneverBound
bind
getVal, getVal, getValAsync, getValAsync, isBound, rightShift, then, then, then, whenBound, whenBound, whenBound, whenBound
private static final long serialVersionUID
public DataflowVariable()
public DataflowWriteChannel<T> leftShift(T value)
leftShift
in interface DataflowWriteChannel<T>
value
- The value to assignpublic DataflowWriteChannel<T> leftShift(DataflowReadChannel<T> ref)
leftShift
in interface DataflowWriteChannel<T>
ref
- The DataflowVariable instance the value of which to bindprivate DataflowWriteChannel<T> bindDFV(DataflowReadChannel<T> ref)
public T get() throws java.lang.Throwable
public final T get(long timeout, java.util.concurrent.TimeUnit units) throws java.lang.Throwable
boolean shouldThrowTimeout()
public java.lang.Class<DataflowVariable.RemoteDataflowVariable> getRemoteClass()
WithSerialId
getRemoteClass
in class WithSerialId