DataflowExpression (gpars 1.3-SNAPSHOT)

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

All Implemented Interfaces:

groovy.lang.GroovyObject, DataflowReadChannel<T>, SelectableChannel<T>, java.io.Serializable

Direct Known Subclasses:

DataflowComplexExpression, DataflowExpression.TransformOne, DataflowGetPropertyExpression, DataflowVariable, RemoteDataflowExpression
```
public abstract class DataflowExpression<T>
extends WithSerialId
implements groovy.lang.GroovyObject, DataflowReadChannel<T>
```
The base class for all dataflow elements.

Author:

Alex Tkachman, Vaclav Pech

See Also:

Serialized Form

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`static class`	`DataflowExpression.BindDataflow<T>` Represents a remote message binding a value to a remoted DataflowExpression
`(package private) class`	`DataflowExpression.DataflowExpressionsCollector` Listener for availability of data flow expressions we depend on.
`private static class`	`DataflowExpression.TransformMany<V>`
`private static class`	`DataflowExpression.TransformOne<V>`
`private static class`	`DataflowExpression.WaitingThread` A logical representation of a synchronous or asynchronous request to read the value once it is bound.

Field Summary

Fields
Modifier and Type	Field and Description
`private static java.lang.String`	`A_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED`
`private static java.lang.String`	`ATTACHMENT`
`private static java.lang.String`	`CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED`
`private static DataflowExpression.WaitingThread`	`dummyWaitingThread` A request chain terminator
`protected java.lang.Throwable`	`error`
`private DataflowChannelEventOrchestrator<T>`	`eventManager`
`private groovy.lang.MetaClass`	`metaClass` The current metaclass
`private static java.lang.String`	`RESULT`
`protected static int`	`S_INITIALIZED`
`protected static int`	`S_INITIALIZING`
`protected static int`	`S_NOT_INITIALIZED` Possible states
`private static long`	`serialVersionUID`
`protected int`	`state` Holds the current state of the variable
`protected static java.util.concurrent.atomic.AtomicIntegerFieldUpdater<DataflowExpression>`	`stateUpdater` Updater for the state field
`protected T`	`value` Holds the actual value.
`private DataflowExpression.WaitingThread`	`waiting` Points to the head of the chain of requests waiting for a value to be bound
`protected static java.util.concurrent.atomic.AtomicReferenceFieldUpdater<DataflowExpression,DataflowExpression.WaitingThread>`	`waitingUpdater` Updater for the waiting field

Fields inherited from class groovyx.gpars.serial.WithSerialId
serialHandle

Constructor Summary

Constructors
Modifier Constructor and Description

protected DataflowExpression()
Creates a new unbound Dataflow Expression

Constructors
Modifier	Constructor and Description
`protected`	`DataflowExpression()` Creates a new unbound Dataflow Expression

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method and Description
`void`	`binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)` Directs the output to one of the two output channels depending on the boolean result of the provided closure.
`void`	`binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)` Directs the output to one of the two output channels depending on the boolean result of the provided closure.
`void`	`binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)` Directs the output to one of the two output channels depending on the boolean result of the provided closure.
`void`	`binaryChoice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)` Directs the output to one of the two output channels depending on the boolean result of the provided closure.
`void`	`binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)` Directs the output to one of the two output channels depending on the boolean result of the provided closure.
`void`	`binaryChoice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)` Directs the output to one of the two output channels depending on the boolean result of the provided closure.
`void`	`bind(T value)` Assigns a value to the variable.
`void`	`bindError(java.lang.Throwable e)`
`void`	`bindSafely(T value)` Assigns a value to the variable.
`void`	`bindUnique(T value)` Assigns a value to the variable.
`<V> DataflowReadChannel<V>`	`chainWith(groovy.lang.Closure<V> closure)` Creates and attaches a new operator processing values from the channel
`<V> DataflowReadChannel<V>`	`chainWith(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)` Creates and attaches a new operator processing values from the channel
`<V> DataflowReadChannel<V>`	`chainWith(PGroup group, groovy.lang.Closure<V> closure)` Creates and attaches a new operator processing values from the channel
`<V> DataflowReadChannel<V>`	`chainWith(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)` Creates and attaches a new operator processing values from the channel
`<V> DataflowReadChannel<V>`	`chainWith(Pool pool, groovy.lang.Closure<V> closure)` Creates and attaches a new operator processing values from the channel
`<V> DataflowReadChannel<V>`	`chainWith(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<V> closure)` Creates and attaches a new operator processing values from the channel
`void`	`choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)` Directs the output to one of the output channels depending on the int result of the provided closure.
`void`	`choice(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)` Directs the output to one of the output channels depending on the int result of the provided closure.
`void`	`choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)` Directs the output to one of the output channels depending on the int result of the provided closure.
`void`	`choice(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)` Directs the output to one of the output channels depending on the int result of the provided closure.
`void`	`choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)` Directs the output to one of the output channels depending on the int result of the provided closure.
`void`	`choice(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)` Directs the output to one of the output channels depending on the int result of the provided closure.
`private DataflowChannelEventOrchestrator<T>`	`createEventManager()`
`private void`	`doBind(T value)` Performs the actual bind operation, unblocks all blocked threads and informs all asynchronously waiting actors.
`protected void`	`doBindImpl(T value)`
`void`	`doBindRemote(java.util.UUID hostId, T message)` Binds the value after receiving a bing message over the wire
`private Promise<java.util.List>`	`doThenForkAndJoin(PGroup group, Pool pool, groovy.lang.Closure<? extends java.lang.Object>[] closures)`
`protected T`	`evaluate()` Evaluates the expression after the ones we depend on are ready
`DataflowReadChannel<T>`	`filter(groovy.lang.Closure<java.lang.Boolean> closure)` Creates and attaches a new operator that will filter data using the provided closure
`DataflowReadChannel<T>`	`filter(java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)` Creates and attaches a new operator that will filter data using the provided closure
`DataflowReadChannel<T>`	`filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure)` Creates and attaches a new operator that will filter data using the provided closure
`DataflowReadChannel<T>`	`filter(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)` Creates and attaches a new operator that will filter data using the provided closure
`DataflowReadChannel<T>`	`filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)` Creates and attaches a new operator that will filter data using the provided closure
`DataflowReadChannel<T>`	`filter(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)` Creates and attaches a new operator that will filter data using the provided closure
`private void`	`fireBindError(T value, boolean unique)`
`private void`	`fireBindError(java.lang.Throwable e)`
`private void`	`fireOnMessage(T value)`
`BindErrorListenerManager<T>`	`getBindErrorManager()`
`DataflowChannelEventListenerManager<T>`	`getEventManager()` Retrieves the event manager object of this channel
`groovy.lang.MetaClass`	`getMetaClass()`
`java.lang.Object`	`getProperty(java.lang.String propertyName)` Returns either standard property of the expression or creates an expression, which will request given property when the receiver becomes available
`T`	`getVal()` Reads the value of the variable.
`T`	`getVal(long timeout, java.util.concurrent.TimeUnit units)` Reads the value of the variable.
`void`	`getValAsync(MessageStream callback)` Asynchronously retrieves the value of the variable.
`void`	`getValAsync(java.lang.Object attachment, MessageStream callback)` Used by Dataflow operators.
`private static void`	`handleInterruption(java.util.concurrent.atomic.AtomicBoolean newWaiting)`
`void`	`into(DataflowWriteChannel<T> target)` Makes the output of the current channel to be an input for the specified channel
`void`	`into(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)` Makes the output of the current channel to be an input for the specified channel
`void`	`into(PGroup group, DataflowWriteChannel<T> target)` Makes the output of the current channel to be an input for the specified channel
`void`	`into(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)` Makes the output of the current channel to be an input for the specified channel
`void`	`into(Pool pool, DataflowWriteChannel<T> target)` Makes the output of the current channel to be an input for the specified channel
`void`	`into(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)` Makes the output of the current channel to be an input for the specified channel
`java.lang.Object`	`invokeMethod(java.lang.String name, java.lang.Object args)` Invokes the method on itself or creates an expression, which will invoke the method n the bound value, once it is available.
`boolean`	`isBound()` Check if value has been set already for this expression
`void`	`join()` Blocks, if the value has not been assigned yet to the DataflowVariable
`void`	`join(long timeout, java.util.concurrent.TimeUnit units)` Blocks, if the value has not been assigned yet to the DataflowVariable
`int`	`length()` Reports the current number of elements in the channel
`<V> DataflowReadChannel<V>`	`merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`<V> DataflowReadChannel<V>`	`merge(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)` Merges channels together as inputs for a single dataflow operator.
`private void`	`notifyRemote(java.util.UUID hostId)` Sends notifications to all subscribers
`<V> DataflowReadChannel<V>`	`or(groovy.lang.Closure<V> closure)` Creates and attaches a new operator processing values from the channel
`void`	`or(DataflowWriteChannel<T> target)` Makes the output of the current channel to be an input for the specified channel
`DataflowExpression<T>`	`poll()` Retrieves the bound value.
`<V> Promise<V>`	`rightShift(groovy.lang.Closure<V> closure)` Schedule closure to be executed by pooled actor after data became available.
`protected void`	`scheduleCallback(java.lang.Object attachment, MessageStream callback)` Sends the result back to the actor, which is waiting asynchronously for the value to be bound.
`void`	`separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)` Allows the closure to output different values to different output channels.
`void`	`separate(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)` Allows the closure to output different values to different output channels.
`void`	`separate(PGroup group, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)` Allows the closure to output different values to different output channels.
`void`	`separate(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)` Allows the closure to output different values to different output channels.
`void`	`separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)` Allows the closure to output different values to different output channels.
`void`	`separate(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)` Allows the closure to output different values to different output channels.
`void`	`setMetaClass(groovy.lang.MetaClass metaClass)`
`void`	`setProperty(java.lang.String propertyName, java.lang.Object newValue)`
`void`	`split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)` Splits the output of the current channel to be an input for the specified channels
`void`	`split(java.util.List<DataflowWriteChannel<T>> targets)` Makes the output of the current channel to be an input for the specified channels
`void`	`split(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)` Splits the output of the current channel to be an input for the specified channels
`void`	`split(java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)` Makes the output of the current channel to be an input for the specified channels
`void`	`split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)` Splits the output of the current channel to be an input for the specified channels
`void`	`split(PGroup group, java.util.List<DataflowWriteChannel<T>> targets)` Makes the output of the current channel to be an input for the specified channels
`void`	`split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)` Splits the output of the current channel to be an input for the specified channels
`void`	`split(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)` Makes the output of the current channel to be an input for the specified channels
`void`	`split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)` Splits the output of the current channel to be an input for the specified channels
`void`	`split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)` Makes the output of the current channel to be an input for the specified channels
`void`	`split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)` Splits the output of the current channel to be an input for the specified channels
`void`	`split(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)` Makes the output of the current channel to be an input for the specified channels
`protected void`	`subscribe()` A utility method to call at the very end of constructors of derived expressions.
`protected void`	`subscribe(DataflowExpression.DataflowExpressionsCollector listener)`
`DataflowReadChannel<T>`	`tap(DataflowWriteChannel<T> target)` Taps into the pipeline.
`DataflowReadChannel<T>`	`tap(java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)` Taps into the pipeline.
`DataflowReadChannel<T>`	`tap(PGroup group, DataflowWriteChannel<T> target)` Taps into the pipeline.
`DataflowReadChannel<T>`	`tap(PGroup group, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)` Taps into the pipeline.
`DataflowReadChannel<T>`	`tap(Pool pool, DataflowWriteChannel<T> target)` Taps into the pipeline.
`DataflowReadChannel<T>`	`tap(Pool pool, java.util.Map<java.lang.String,java.lang.Object> params, DataflowWriteChannel<T> target)` Taps into the pipeline.
`<V> Promise<V>`	`then(groovy.lang.Closure<V> closure)` Schedule closure to be executed after data became available.
`<V> Promise<V>`	`then(PGroup group, groovy.lang.Closure<V> closure)` Schedule closure to be executed after data becomes available.
`<V> Promise<V>`	`then(Pool pool, groovy.lang.Closure<V> closure)` Schedule closure to be executed after data becomes available.
`Promise<java.util.List>`	`thenForkAndJoin(groovy.lang.Closure<? extends java.lang.Object>... closures)` Schedule a set of closures to be executed after data became available on the current promise.
`Promise<java.util.List>`	`thenForkAndJoin(PGroup group, groovy.lang.Closure<? extends java.lang.Object>... closures)` Schedule a set of closures to be executed after data became available on the current promise.
`Promise<java.util.List>`	`thenForkAndJoin(Pool pool, groovy.lang.Closure<? extends java.lang.Object>... closures)` Schedule a set of closures to be executed after data became available on the current promise.
`java.lang.String`	`toString()`
`static <V> DataflowExpression<V>`	`transform(java.lang.Object another, groovy.lang.Closure closure)` Transforms values bound eventually to dataflow variables using the supplied closure.
`<V> void`	`whenBound(groovy.lang.Closure<V> closure)` Schedule closure to be executed by pooled actor after data becomes available.
`void`	`whenBound(MessageStream stream)` Send the bound data to provided stream when it becomes available
`<V> void`	`whenBound(PGroup group, groovy.lang.Closure<V> closure)` Schedule closure to be executed by pooled actor after data becomes available.
`<V> void`	`whenBound(Pool pool, groovy.lang.Closure<V> closure)` Schedule closure to be executed by pooled actor after data becomes available.
`<V> void`	`wheneverBound(groovy.lang.Closure<V> closure)` Send all pieces of data bound in the future to the provided stream when it becomes available.
`void`	`wheneverBound(MessageStream stream)` Send all pieces of data bound in the future to the provided stream when it becomes available.

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
  - ATTACHMENT
```
private static final java.lang.String ATTACHMENT
```
    See Also:
    
    Constant Field Values
  - RESULT
```
private static final java.lang.String RESULT
```
    See Also:
    
    Constant Field Values
  - stateUpdater
```
protected static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<DataflowExpression> stateUpdater
```
    Updater for the state field
  - waitingUpdater
```
protected static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<DataflowExpression,DataflowExpression.WaitingThread> waitingUpdater
```
    Updater for the waiting field
  - serialVersionUID
```
private static final long serialVersionUID
```
    See Also:
    
    Constant Field Values
  - CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED
```
private static final java.lang.String CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED
```
    See Also:
    
    Constant Field Values
  - A_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED
```
private static final java.lang.String A_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED
```
    See Also:
    
    Constant Field Values
  - metaClass
```
private groovy.lang.MetaClass metaClass
```
    The current metaclass
  - value
```
protected volatile T value
```
    Holds the actual value. Is null before a concrete value is bound to it.
  - error
```
protected volatile java.lang.Throwable error
```
  - state
```
protected volatile int state
```
    Holds the current state of the variable
  - waiting
```
private volatile DataflowExpression.WaitingThread waiting
```
    Points to the head of the chain of requests waiting for a value to be bound
  - S_NOT_INITIALIZED
```
protected static final int S_NOT_INITIALIZED
```
    Possible states
    
    See Also:
    
    Constant Field Values
  - S_INITIALIZING
```
protected static final int S_INITIALIZING
```
    See Also:
    
    Constant Field Values
  - S_INITIALIZED
```
protected static final int S_INITIALIZED
```
    See Also:
    
    Constant Field Values
  - dummyWaitingThread
```
private static final DataflowExpression.WaitingThread dummyWaitingThread
```
    A request chain terminator
  - eventManager
```
private volatile DataflowChannelEventOrchestrator<T> eventManager
```
- Constructor Detail
  - DataflowExpression
```
protected DataflowExpression()
```
    Creates a new unbound Dataflow Expression
- Method Detail
  - isBound
```
public final boolean isBound()
```
    Check if value has been set already for this expression
    
    Specified by:
    
    isBound in interface DataflowReadChannel<T>
    
    Returns:
    
    true if bound already
  - length
```
public final int length()
```
    Description copied from interface: DataflowReadChannel
    
    Reports the current number of elements in the channel
    
    Specified by:
    
    length in interface DataflowReadChannel<T>
    
    Returns:
    
    The current snapshot of the number of elements in the channel
  - getValAsync
```
public void getValAsync(MessageStream callback)
```
    Asynchronously retrieves the value of the variable. Sends the actual value of the variable as a message back the the supplied actor once the value has been bound. The actor can perform other activities or release a thread back to the pool by calling react() waiting for the message with the value of the Dataflow Variable.
    
    Specified by:
    
    getValAsync in interface DataflowReadChannel<T>
    
    Parameters:
    
    callback - An actor to send the bound value to.
  - getValAsync
```
public void getValAsync(java.lang.Object attachment,
                        MessageStream callback)
```
    Used by Dataflow operators. Asynchronously retrieves the value of the variable. Sends a message back the the supplied MessageStream with a map holding the supplied attachment under the 'attachment' key and the actual value of the variable under the 'result' key once the value has been bound. Attachment is an arbitrary value helping the actor.operator match its request with the reply. The actor/operator can perform other activities or release a thread back to the pool by calling react() waiting for the message with the value of the Dataflow Variable.
    
    Specified by:
    
    getValAsync in interface DataflowReadChannel<T>
    
    Parameters:
    
    attachment - arbitrary non-null attachment if reader needs better identification of result
    
    callback - An actor to send the bound value plus the supplied index to.
  - join
```
public final void join()
                throws java.lang.InterruptedException
```
    Blocks, if the value has not been assigned yet to the DataflowVariable
    
    Throws:
    
    java.lang.InterruptedException - If the current thread gets interrupted while waiting for the variable to be bound
  - join
```
public final void join(long timeout,
                       java.util.concurrent.TimeUnit units)
                throws java.lang.InterruptedException
```
    Blocks, if the value has not been assigned yet to the DataflowVariable
    
    Parameters:
    
    timeout - The timeout value
    
    units - Units for the timeout
    
    Throws:
    
    java.lang.InterruptedException - If the current thread gets interrupted while waiting for the variable to be bound
  - getVal
```
public T getVal()
         throws java.lang.InterruptedException
```
    Reads the value of the variable. Blocks, if the value has not been assigned yet.
    
    Specified by:
    
    getVal in interface DataflowReadChannel<T>
    
    Returns:
    
    The actual value
    
    Throws:
    
    java.lang.InterruptedException - If the current thread gets interrupted while waiting for the variable to be bound
  - getVal
```
public T getVal(long timeout,
                java.util.concurrent.TimeUnit units)
         throws java.lang.InterruptedException
```
    Reads the value of the variable. Blocks up to given timeout, if the value has not been assigned yet.
    
    Specified by:
    
    getVal in interface DataflowReadChannel<T>
    
    Parameters:
    
    timeout - The timeout value
    
    units - Units for the timeout
    
    Returns:
    
    The actual value
    
    Throws:
    
    java.lang.InterruptedException - If the current thread gets interrupted while waiting for the variable to be bound
  - poll
```
public final DataflowExpression<T> poll()
```
    Retrieves the bound value. Returns null, if no value is available.
    
    Specified by:
    
    poll in interface SelectableChannel<T>
    
    Returns:
    
    The value bound to the DFV or null
  - handleInterruption
```
private static void handleInterruption(java.util.concurrent.atomic.AtomicBoolean newWaiting)
                                throws java.lang.InterruptedException
```
    Throws:
    
    java.lang.InterruptedException
  - bindSafely
```
public final void bindSafely(T value)
```
    Assigns a value to the variable. Returns silently if invoked on an already bound variable.
    
    Parameters:
    
    value - The value to assign
  - bindError
```
public final void bindError(java.lang.Throwable e)
```
  - bind
```
public final void bind(T value)
```
    Assigns a value to the variable. Can only be invoked once on each instance of DataflowVariable. Allows attempts to bind to equal values.
    
    Parameters:
    
    value - The value to assign
  - bindUnique
```
public final void bindUnique(T value)
```
    Assigns a value to the variable. Can only be invoked once on each instance of DataflowVariable Doesn't allow attempts to bind to equal values.
    
    Parameters:
    
    value - The value to assign
  - doBind
```
private void doBind(T value)
```
    Performs the actual bind operation, unblocks all blocked threads and informs all asynchronously waiting actors.
    
    Parameters:
    
    value - The value to assign
  - doBindImpl
```
protected void doBindImpl(T value)
```
  - doBindRemote
```
public final void doBindRemote(java.util.UUID hostId,
                               T message)
```
    Binds the value after receiving a bing message over the wire
    
    Parameters:
    
    hostId - Id of the bind originator host
    
    message - The value to bind
  - notifyRemote
```
private void notifyRemote(java.util.UUID hostId)
```
    Sends notifications to all subscribers
    
    Parameters:
    
    hostId - The local host id
  - scheduleCallback
```
protected void scheduleCallback(java.lang.Object attachment,
                                MessageStream callback)
```
    Sends the result back to the actor, which is waiting asynchronously for the value to be bound. The message will either be a map holding the attachment under the 'attachment' key and the actual bound value under the 'result' key, or it will be the result itself if the callback doesn't care about the index.
    
    Parameters:
    
    attachment - An arbitrary object identifying the request
    
    callback - The actor to send the message to
  - rightShift
```
public final <V> Promise<V> rightShift(groovy.lang.Closure<V> closure)
```
    Schedule closure to be executed by pooled actor after data became available. It is important to notice that even if the expression is already bound the execution of closure will not happen immediately but will be scheduled
    
    Specified by:
    
    rightShift in interface DataflowReadChannel<T>
    
    Parameters:
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
    
    Returns:
    
    A promise for the results of the supplied closure. This allows for chaining of then() method calls.
  - whenBound
```
public final <V> void whenBound(groovy.lang.Closure<V> closure)
```
    Schedule closure to be executed by pooled actor after data becomes available. It is important to notice that even if the expression is already bound the execution of closure will not happen immediately but will be scheduled.
    
    Specified by:
    
    whenBound in interface DataflowReadChannel<T>
    
    Parameters:
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - whenBound
```
public <V> void whenBound(Pool pool,
                          groovy.lang.Closure<V> closure)
```
    Schedule closure to be executed by pooled actor after data becomes available. It is important to notice that even if the expression is already bound the execution of closure will not happen immediately but will be scheduled.
    
    Specified by:
    
    whenBound in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use for task scheduling for asynchronous message delivery
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - whenBound
```
public final <V> void whenBound(PGroup group,
                                groovy.lang.Closure<V> closure)
```
    Schedule closure to be executed by pooled actor after data becomes available. It is important to notice that even if the expression is already bound the execution of closure will not happen immediately but will be scheduled.
    
    Specified by:
    
    whenBound in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use for task scheduling for asynchronous message delivery
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - whenBound
```
public final void whenBound(MessageStream stream)
```
    Send the bound data to provided stream when it becomes available
    
    Specified by:
    
    whenBound in interface DataflowReadChannel<T>
    
    Parameters:
    
    stream - stream where to send result
  - then
```
public final <V> Promise<V> then(groovy.lang.Closure<V> closure)
```
    Schedule closure to be executed after data became available. It is important to notice that even if the expression is already bound the execution of closure will not happen immediately but will be scheduled
    
    Specified by:
    
    then in interface DataflowReadChannel<T>
    
    Parameters:
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
    
    Returns:
    
    A promise for the results of the supplied closure. This allows for chaining of then() method calls.
  - then
```
public final <V> Promise<V> then(Pool pool,
                                 groovy.lang.Closure<V> closure)
```
    Schedule closure to be executed after data becomes available. It is important to notice that even if the expression is already bound the execution of closure will not happen immediately but will be scheduled.
    
    Specified by:
    
    then in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use for task scheduling for asynchronous message delivery
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
    
    Returns:
    
    A promise for the results of the supplied closure. This allows for chaining of then() method calls.
  - then
```
public final <V> Promise<V> then(PGroup group,
                                 groovy.lang.Closure<V> closure)
```
    Schedule closure to be executed after data becomes available. It is important to notice that even if the expression is already bound the execution of closure will not happen immediately but will be scheduled.
    
    Specified by:
    
    then in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use for task scheduling for asynchronous message delivery
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
    
    Returns:
    
    A promise for the results of the supplied closure. This allows for chaining of then() method calls.
  - thenForkAndJoin
```
public final Promise<java.util.List> thenForkAndJoin(groovy.lang.Closure<? extends java.lang.Object>... closures)
```
    Schedule a set of closures to be executed after data became available on the current promise. It is important to notice that even if the expression is already bound the execution of closures will not happen immediately, but will be scheduled. The returned Promise will hold a list of results of the individual closures, ordered in the same order. In case of an exception being thrown from any of the closures, the first exception gets propagated into the promise returned from the method.
    
    Parameters:
    
    closures - closure to execute when data becomes available. The closure should take at most one argument.
    
    Returns:
    
    A promise for the results of the supplied closures. This allows for chaining of then() method calls.
  - thenForkAndJoin
```
public final Promise<java.util.List> thenForkAndJoin(Pool pool,
                                                     groovy.lang.Closure<? extends java.lang.Object>... closures)
```
    Schedule a set of closures to be executed after data became available on the current promise. It is important to notice that even if the expression is already bound the execution of closures will not happen immediately, but will be scheduled. The returned Promise will hold a list of results of the individual closures, ordered in the same order. In case of an exception being thrown from any of the closures, the first exception gets propagated into the promise returned from the method.
    
    Parameters:
    
    pool - The thread pool to use for task scheduling for asynchronous message delivery
    
    closures - closure to execute when data becomes available. The closure should take at most one argument.
    
    Returns:
    
    A promise for the results of the supplied closures. This allows for chaining of then() method calls.
  - thenForkAndJoin
```
public final Promise<java.util.List> thenForkAndJoin(PGroup group,
                                                     groovy.lang.Closure<? extends java.lang.Object>... closures)
```
    Schedule a set of closures to be executed after data became available on the current promise. It is important to notice that even if the expression is already bound the execution of closures will not happen immediately, but will be scheduled. The returned Promise will hold a list of results of the individual closures, ordered in the same order. In case of an exception being thrown from any of the closures, the first exception gets propagated into the promise returned from the method.
    
    Parameters:
    
    group - The PGroup to use for task scheduling for asynchronous message delivery
    
    closures - closure to execute when data becomes available. The closure should take at most one argument.
    
    Returns:
    
    A promise for the results of the supplied closures. This allows for chaining of then() method calls.
  - doThenForkAndJoin
```
private Promise<java.util.List> doThenForkAndJoin(PGroup group,
                                                  Pool pool,
                                                  groovy.lang.Closure<? extends java.lang.Object>[] closures)
```
  - wheneverBound
```
public final <V> void wheneverBound(groovy.lang.Closure<V> closure)
```
    Send all pieces of data bound in the future to the provided stream when it becomes available. *
    
    Specified by:
    
    wheneverBound in interface SelectableChannel<T>
    
    Parameters:
    
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - wheneverBound
```
public final void wheneverBound(MessageStream stream)
```
    Send all pieces of data bound in the future to the provided stream when it becomes available.
    
    Specified by:
    
    wheneverBound in interface SelectableChannel<T>
    
    Parameters:
    
    stream - stream where to send result
  - chainWith
```
public final <V> DataflowReadChannel<V> chainWith(groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator processing values from the channel
    
    Specified by:
    
    chainWith in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values returned from the supplied closure
    
    Parameters:
    
    closure - The function to invoke on all incoming values as part of the new operator's body
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - chainWith
```
public final <V> DataflowReadChannel<V> chainWith(Pool pool,
                                                  groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator processing values from the channel
    
    Specified by:
    
    chainWith in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values returned from the supplied closure
    
    Parameters:
    
    pool - The thread pool to use
    
    closure - The function to invoke on all incoming values as part of the new operator's body
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - chainWith
```
public <V> DataflowReadChannel<V> chainWith(PGroup group,
                                            groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator processing values from the channel
    
    Specified by:
    
    chainWith in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values returned from the supplied closure
    
    Parameters:
    
    group - The PGroup to use
    
    closure - The function to invoke on all incoming values as part of the new operator's body
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - chainWith
```
public final <V> DataflowReadChannel<V> chainWith(java.util.Map<java.lang.String,java.lang.Object> params,
                                                  groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator processing values from the channel
    
    Specified by:
    
    chainWith in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values returned from the supplied closure
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    closure - The function to invoke on all incoming values as part of the new operator's body
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - chainWith
```
public final <V> DataflowReadChannel<V> chainWith(Pool pool,
                                                  java.util.Map<java.lang.String,java.lang.Object> params,
                                                  groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator processing values from the channel
    
    Specified by:
    
    chainWith in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values returned from the supplied closure
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    closure - The function to invoke on all incoming values as part of the new operator's body
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - chainWith
```
public <V> DataflowReadChannel<V> chainWith(PGroup group,
                                            java.util.Map<java.lang.String,java.lang.Object> params,
                                            groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator processing values from the channel
    
    Specified by:
    
    chainWith in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values returned from the supplied closure
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    closure - The function to invoke on all incoming values as part of the new operator's body
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - or
```
public <V> DataflowReadChannel<V> or(groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator processing values from the channel
    
    Specified by:
    
    or in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values returned from the supplied closure
    
    Parameters:
    
    closure - The function to invoke on all incoming values as part of the new operator's body
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - filter
```
public DataflowReadChannel<T> filter(groovy.lang.Closure<java.lang.Boolean> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator that will filter data using the provided closure
    
    Specified by:
    
    filter in interface DataflowReadChannel<T>
    
    Parameters:
    
    closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - filter
```
public DataflowReadChannel<T> filter(Pool pool,
                                     groovy.lang.Closure<java.lang.Boolean> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator that will filter data using the provided closure
    
    Specified by:
    
    filter in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - filter
```
public DataflowReadChannel<T> filter(PGroup group,
                                     groovy.lang.Closure<java.lang.Boolean> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator that will filter data using the provided closure
    
    Specified by:
    
    filter in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - filter
```
public DataflowReadChannel<T> filter(java.util.Map<java.lang.String,java.lang.Object> params,
                                     groovy.lang.Closure<java.lang.Boolean> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator that will filter data using the provided closure
    
    Specified by:
    
    filter in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - filter
```
public DataflowReadChannel<T> filter(Pool pool,
                                     java.util.Map<java.lang.String,java.lang.Object> params,
                                     groovy.lang.Closure<java.lang.Boolean> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator that will filter data using the provided closure
    
    Specified by:
    
    filter in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - filter
```
public DataflowReadChannel<T> filter(PGroup group,
                                     java.util.Map<java.lang.String,java.lang.Object> params,
                                     groovy.lang.Closure<java.lang.Boolean> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Creates and attaches a new operator that will filter data using the provided closure
    
    Specified by:
    
    filter in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    closure - The filter function to invoke on all incoming values to decide whether to pass the value on or not
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - into
```
public void into(DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channel
    
    Specified by:
    
    into in interface DataflowReadChannel<T>
    
    Parameters:
    
    target - The channel to copy data into
  - into
```
public void into(Pool pool,
                 DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channel
    
    Specified by:
    
    into in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    target - The channel to copy data into
  - into
```
public void into(PGroup group,
                 DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channel
    
    Specified by:
    
    into in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    target - The channel to copy data into
  - into
```
public void into(java.util.Map<java.lang.String,java.lang.Object> params,
                 DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channel
    
    Specified by:
    
    into in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target - The channel to copy data into
  - into
```
public void into(Pool pool,
                 java.util.Map<java.lang.String,java.lang.Object> params,
                 DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channel
    
    Specified by:
    
    into in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target - The channel to copy data into
  - into
```
public void into(PGroup group,
                 java.util.Map<java.lang.String,java.lang.Object> params,
                 DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channel
    
    Specified by:
    
    into in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target - The channel to copy data into
  - or
```
public void or(DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channel
    
    Specified by:
    
    or in interface DataflowReadChannel<T>
    
    Parameters:
    
    target - The channel to copy data into
  - split
```
public void split(DataflowWriteChannel<T> target1,
                  DataflowWriteChannel<T> target2)
```
    Description copied from interface: DataflowReadChannel
    
    Splits the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    target1 - The first channel to copy data into
    
    target2 - The second channel to copy data into
  - split
```
public void split(Pool pool,
                  DataflowWriteChannel<T> target1,
                  DataflowWriteChannel<T> target2)
```
    Description copied from interface: DataflowReadChannel
    
    Splits the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    target1 - The first channel to copy data into
    
    target2 - The second channel to copy data into
  - split
```
public void split(PGroup group,
                  DataflowWriteChannel<T> target1,
                  DataflowWriteChannel<T> target2)
```
    Description copied from interface: DataflowReadChannel
    
    Splits the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    target1 - The first channel to copy data into
    
    target2 - The second channel to copy data into
  - split
```
public void split(java.util.List<DataflowWriteChannel<T>> targets)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    targets - The channels to copy data into
  - split
```
public void split(Pool pool,
                  java.util.List<DataflowWriteChannel<T>> targets)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    targets - The channels to copy data into
  - split
```
public void split(PGroup group,
                  java.util.List<DataflowWriteChannel<T>> targets)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    targets - The channels to copy data into
  - split
```
public void split(java.util.Map<java.lang.String,java.lang.Object> params,
                  DataflowWriteChannel<T> target1,
                  DataflowWriteChannel<T> target2)
```
    Description copied from interface: DataflowReadChannel
    
    Splits the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target1 - The first channel to copy data into
    
    target2 - The second channel to copy data into
  - split
```
public void split(Pool pool,
                  java.util.Map<java.lang.String,java.lang.Object> params,
                  DataflowWriteChannel<T> target1,
                  DataflowWriteChannel<T> target2)
```
    Description copied from interface: DataflowReadChannel
    
    Splits the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target1 - The first channel to copy data into
    
    target2 - The second channel to copy data into
  - split
```
public void split(PGroup group,
                  java.util.Map<java.lang.String,java.lang.Object> params,
                  DataflowWriteChannel<T> target1,
                  DataflowWriteChannel<T> target2)
```
    Description copied from interface: DataflowReadChannel
    
    Splits the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target1 - The first channel to copy data into
    
    target2 - The second channel to copy data into
  - split
```
public void split(java.util.Map<java.lang.String,java.lang.Object> params,
                  java.util.List<DataflowWriteChannel<T>> targets)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    targets - The channels to copy data into
  - split
```
public void split(Pool pool,
                  java.util.Map<java.lang.String,java.lang.Object> params,
                  java.util.List<DataflowWriteChannel<T>> targets)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    targets - The channels to copy data into
  - split
```
public void split(PGroup group,
                  java.util.Map<java.lang.String,java.lang.Object> params,
                  java.util.List<DataflowWriteChannel<T>> targets)
```
    Description copied from interface: DataflowReadChannel
    
    Makes the output of the current channel to be an input for the specified channels
    
    Specified by:
    
    split in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    targets - The channels to copy data into
  - tap
```
public DataflowReadChannel<T> tap(DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Taps into the pipeline. The supplied channel will receive a copy of all messages passed through.
    
    Specified by:
    
    tap in interface DataflowReadChannel<T>
    
    Parameters:
    
    target - The channel to tap data into
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - tap
```
public DataflowReadChannel<T> tap(Pool pool,
                                  DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Taps into the pipeline. The supplied channel will receive a copy of all messages passed through.
    
    Specified by:
    
    tap in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    target - The channel to tap data into
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - tap
```
public DataflowReadChannel<T> tap(PGroup group,
                                  DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Taps into the pipeline. The supplied channel will receive a copy of all messages passed through.
    
    Specified by:
    
    tap in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    target - The channel to tap data into
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - tap
```
public DataflowReadChannel<T> tap(java.util.Map<java.lang.String,java.lang.Object> params,
                                  DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Taps into the pipeline. The supplied channel will receive a copy of all messages passed through.
    
    Specified by:
    
    tap in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target - The channel to tap data into
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - tap
```
public DataflowReadChannel<T> tap(Pool pool,
                                  java.util.Map<java.lang.String,java.lang.Object> params,
                                  DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Taps into the pipeline. The supplied channel will receive a copy of all messages passed through.
    
    Specified by:
    
    tap in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target - The channel to tap data into
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - tap
```
public DataflowReadChannel<T> tap(PGroup group,
                                  java.util.Map<java.lang.String,java.lang.Object> params,
                                  DataflowWriteChannel<T> target)
```
    Description copied from interface: DataflowReadChannel
    
    Taps into the pipeline. The supplied channel will receive a copy of all messages passed through.
    
    Specified by:
    
    tap in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    target - The channel to tap data into
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(DataflowReadChannel<java.lang.Object> other,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    other - The channel to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(Pool pool,
                                        DataflowReadChannel<java.lang.Object> other,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    pool - The thread pool to use
    
    other - The channel to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(PGroup group,
                                        DataflowReadChannel<java.lang.Object> other,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    group - The PGroup to use
    
    other - The channel to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(java.util.List<DataflowReadChannel<java.lang.Object>> others,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    others - The channels to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(Pool pool,
                                        java.util.List<DataflowReadChannel<java.lang.Object>> others,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    pool - The thread pool to use
    
    others - The channels to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(PGroup group,
                                        java.util.List<DataflowReadChannel<java.lang.Object>> others,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    group - The PGroup to use
    
    others - The channels to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(java.util.Map<java.lang.String,java.lang.Object> params,
                                        DataflowReadChannel<java.lang.Object> other,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    other - The channel to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(Pool pool,
                                        java.util.Map<java.lang.String,java.lang.Object> params,
                                        DataflowReadChannel<java.lang.Object> other,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    other - The channel to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(PGroup group,
                                        java.util.Map<java.lang.String,java.lang.Object> params,
                                        DataflowReadChannel<java.lang.Object> other,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    other - The channel to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(java.util.Map<java.lang.String,java.lang.Object> params,
                                        java.util.List<DataflowReadChannel<java.lang.Object>> others,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    others - The channels to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(Pool pool,
                                        java.util.Map<java.lang.String,java.lang.Object> params,
                                        java.util.List<DataflowReadChannel<java.lang.Object>> others,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    others - The channels to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - merge
```
public <V> DataflowReadChannel<V> merge(PGroup group,
                                        java.util.Map<java.lang.String,java.lang.Object> params,
                                        java.util.List<DataflowReadChannel<java.lang.Object>> others,
                                        groovy.lang.Closure<V> closure)
```
    Description copied from interface: DataflowReadChannel
    
    Merges channels together as inputs for a single dataflow operator.
    
    Specified by:
    
    merge in interface DataflowReadChannel<T>
    
    Type Parameters:
    
    V - The type of values passed between the channels
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    others - The channels to merge with
    
    closure - The function to invoke on all incoming values as part of the new operator's body. The number of arguments to the closure must match the number of input channels.
    
    Returns:
    
    A channel of the same type as this channel, which the new operator will output into.
  - binaryChoice
```
public void binaryChoice(DataflowWriteChannel<T> trueBranch,
                         DataflowWriteChannel<T> falseBranch,
                         groovy.lang.Closure<java.lang.Boolean> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the two output channels depending on the boolean result of the provided closure.
    
    Specified by:
    
    binaryChoice in interface DataflowReadChannel<T>
    
    Parameters:
    
    trueBranch - The channel to send data to if the closure returns true
    
    falseBranch - The channel to send data to if the closure returns true
    
    code - A closure directing data to either the true or the false output branch
  - binaryChoice
```
public void binaryChoice(Pool pool,
                         DataflowWriteChannel<T> trueBranch,
                         DataflowWriteChannel<T> falseBranch,
                         groovy.lang.Closure<java.lang.Boolean> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the two output channels depending on the boolean result of the provided closure.
    
    Specified by:
    
    binaryChoice in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    trueBranch - The channel to send data to if the closure returns true
    
    falseBranch - The channel to send data to if the closure returns true
    
    code - A closure directing data to either the true or the false output branch
  - binaryChoice
```
public void binaryChoice(PGroup group,
                         DataflowWriteChannel<T> trueBranch,
                         DataflowWriteChannel<T> falseBranch,
                         groovy.lang.Closure<java.lang.Boolean> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the two output channels depending on the boolean result of the provided closure.
    
    Specified by:
    
    binaryChoice in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    trueBranch - The channel to send data to if the closure returns true
    
    falseBranch - The channel to send data to if the closure returns true
    
    code - A closure directing data to either the true or the false output branch
  - binaryChoice
```
public void binaryChoice(java.util.Map<java.lang.String,java.lang.Object> params,
                         DataflowWriteChannel<T> trueBranch,
                         DataflowWriteChannel<T> falseBranch,
                         groovy.lang.Closure<java.lang.Boolean> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the two output channels depending on the boolean result of the provided closure.
    
    Specified by:
    
    binaryChoice in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    trueBranch - The channel to send data to if the closure returns true
    
    falseBranch - The channel to send data to if the closure returns true
    
    code - A closure directing data to either the true or the false output branch
  - binaryChoice
```
public void binaryChoice(Pool pool,
                         java.util.Map<java.lang.String,java.lang.Object> params,
                         DataflowWriteChannel<T> trueBranch,
                         DataflowWriteChannel<T> falseBranch,
                         groovy.lang.Closure<java.lang.Boolean> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the two output channels depending on the boolean result of the provided closure.
    
    Specified by:
    
    binaryChoice in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    trueBranch - The channel to send data to if the closure returns true
    
    falseBranch - The channel to send data to if the closure returns true
    
    code - A closure directing data to either the true or the false output branch
  - binaryChoice
```
public void binaryChoice(PGroup group,
                         java.util.Map<java.lang.String,java.lang.Object> params,
                         DataflowWriteChannel<T> trueBranch,
                         DataflowWriteChannel<T> falseBranch,
                         groovy.lang.Closure<java.lang.Boolean> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the two output channels depending on the boolean result of the provided closure.
    
    Specified by:
    
    binaryChoice in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    trueBranch - The channel to send data to if the closure returns true
    
    falseBranch - The channel to send data to if the closure returns true
    
    code - A closure directing data to either the true or the false output branch
  - choice
```
public void choice(java.util.List<DataflowWriteChannel<T>> outputs,
                   groovy.lang.Closure<java.lang.Integer> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the output channels depending on the int result of the provided closure.
    
    Specified by:
    
    choice in interface DataflowReadChannel<T>
    
    Parameters:
    
    outputs - The channels to send data to of the closure returns true
    
    code - A closure returning an index of the output channel to direct the data to
  - choice
```
public void choice(Pool pool,
                   java.util.List<DataflowWriteChannel<T>> outputs,
                   groovy.lang.Closure<java.lang.Integer> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the output channels depending on the int result of the provided closure.
    
    Specified by:
    
    choice in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    outputs - The channels to send data to.
    
    code - A closure returning an index of the output channel to direct the data to
  - choice
```
public void choice(PGroup group,
                   java.util.List<DataflowWriteChannel<T>> outputs,
                   groovy.lang.Closure<java.lang.Integer> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the output channels depending on the int result of the provided closure.
    
    Specified by:
    
    choice in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    outputs - The channels to send data to.
    
    code - A closure returning an index of the output channel to direct the data to
  - choice
```
public void choice(java.util.Map<java.lang.String,java.lang.Object> params,
                   java.util.List<DataflowWriteChannel<T>> outputs,
                   groovy.lang.Closure<java.lang.Integer> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the output channels depending on the int result of the provided closure.
    
    Specified by:
    
    choice in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    outputs - The channels to send data to of the closure returns true
    
    code - A closure returning an index of the output channel to direct the data to
  - choice
```
public void choice(Pool pool,
                   java.util.Map<java.lang.String,java.lang.Object> params,
                   java.util.List<DataflowWriteChannel<T>> outputs,
                   groovy.lang.Closure<java.lang.Integer> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the output channels depending on the int result of the provided closure.
    
    Specified by:
    
    choice in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    outputs - The channels to send data to.
    
    code - A closure returning an index of the output channel to direct the data to
  - choice
```
public void choice(PGroup group,
                   java.util.Map<java.lang.String,java.lang.Object> params,
                   java.util.List<DataflowWriteChannel<T>> outputs,
                   groovy.lang.Closure<java.lang.Integer> code)
```
    Description copied from interface: DataflowReadChannel
    
    Directs the output to one of the output channels depending on the int result of the provided closure.
    
    Specified by:
    
    choice in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    outputs - The channels to send data to.
    
    code - A closure returning an index of the output channel to direct the data to
  - separate
```
public void separate(java.util.List<DataflowWriteChannel<?>> outputs,
                     groovy.lang.Closure<java.util.List<java.lang.Object>> code)
```
    Description copied from interface: DataflowReadChannel
    
    Allows the closure to output different values to different output channels.
    
    Specified by:
    
    separate in interface DataflowReadChannel<T>
    
    Parameters:
    
    outputs - The channels to send data to.
    
    code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.
  - separate
```
public void separate(Pool pool,
                     java.util.List<DataflowWriteChannel<?>> outputs,
                     groovy.lang.Closure<java.util.List<java.lang.Object>> code)
```
    Description copied from interface: DataflowReadChannel
    
    Allows the closure to output different values to different output channels.
    
    Specified by:
    
    separate in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    outputs - The channels to send data to.
    
    code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.
  - separate
```
public void separate(PGroup group,
                     java.util.List<DataflowWriteChannel<?>> outputs,
                     groovy.lang.Closure<java.util.List<java.lang.Object>> code)
```
    Description copied from interface: DataflowReadChannel
    
    Allows the closure to output different values to different output channels.
    
    Specified by:
    
    separate in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    outputs - The channels to send data to.
    
    code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.
  - separate
```
public void separate(java.util.Map<java.lang.String,java.lang.Object> params,
                     java.util.List<DataflowWriteChannel<?>> outputs,
                     groovy.lang.Closure<java.util.List<java.lang.Object>> code)
```
    Description copied from interface: DataflowReadChannel
    
    Allows the closure to output different values to different output channels.
    
    Specified by:
    
    separate in interface DataflowReadChannel<T>
    
    Parameters:
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    outputs - The channels to send data to.
    
    code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.
  - separate
```
public void separate(Pool pool,
                     java.util.Map<java.lang.String,java.lang.Object> params,
                     java.util.List<DataflowWriteChannel<?>> outputs,
                     groovy.lang.Closure<java.util.List<java.lang.Object>> code)
```
    Description copied from interface: DataflowReadChannel
    
    Allows the closure to output different values to different output channels.
    
    Specified by:
    
    separate in interface DataflowReadChannel<T>
    
    Parameters:
    
    pool - The thread pool to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    outputs - The channels to send data to.
    
    code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.
  - separate
```
public void separate(PGroup group,
                     java.util.Map<java.lang.String,java.lang.Object> params,
                     java.util.List<DataflowWriteChannel<?>> outputs,
                     groovy.lang.Closure<java.util.List<java.lang.Object>> code)
```
    Description copied from interface: DataflowReadChannel
    
    Allows the closure to output different values to different output channels.
    
    Specified by:
    
    separate in interface DataflowReadChannel<T>
    
    Parameters:
    
    group - The PGroup to use
    
    params - Additional parameters to initialize the operator with (e.g. listeners or maxForks)
    
    outputs - The channels to send data to.
    
    code - A closure returning a list of values to pass to the output channels. Values are output to the output channels with identical index.
  - getEventManager
```
public DataflowChannelEventListenerManager<T> getEventManager()
```
    Description copied from interface: DataflowReadChannel
    
    Retrieves the event manager object of this channel
    
    Specified by:
    
    getEventManager in interface DataflowReadChannel<T>
    
    Returns:
    
    The event manager to register custom events listeners
  - getBindErrorManager
```
public BindErrorListenerManager<T> getBindErrorManager()
```
  - createEventManager
```
private DataflowChannelEventOrchestrator<T> createEventManager()
```
  - fireOnMessage
```
private void fireOnMessage(T value)
```
  - fireBindError
```
private void fireBindError(T value,
                           boolean unique)
```
  - fireBindError
```
private void fireBindError(java.lang.Throwable e)
```
  - transform
```
public static <V> DataflowExpression<V> transform(java.lang.Object another,
                                                  groovy.lang.Closure closure)
```
    Transforms values bound eventually to dataflow variables using the supplied closure.
    
    Type Parameters:
    
    V - Type of the bound values
    
    Parameters:
    
    another - A list of DataflowVariables to transform
    
    closure - The transformation function, which must take the same number of arguments as there are elements in the "another" list
    
    Returns:
    
    The value returned from the transformation closure.
  - subscribe
```
protected final void subscribe()
```
    A utility method to call at the very end of constructors of derived expressions. Creates and subscribes a listener to monitor the expression
  - evaluate
```
protected T evaluate()
```
    Evaluates the expression after the ones we depend on are ready
    
    Returns:
    
    The value to bind
  - subscribe
```
protected void subscribe(DataflowExpression.DataflowExpressionsCollector listener)
```
  - invokeMethod
```
public final java.lang.Object invokeMethod(java.lang.String name,
                                           java.lang.Object args)
```
    Invokes the method on itself or creates an expression, which will invoke the method n the bound value, once it is available.
    
    Specified by:
    
    invokeMethod in interface groovy.lang.GroovyObject
  - getProperty
```
public final java.lang.Object getProperty(java.lang.String propertyName)
```
    Returns either standard property of the expression or creates an expression, which will request given property when the receiver becomes available
    
    Specified by:
    
    getProperty in interface groovy.lang.GroovyObject
    
    Parameters:
    
    propertyName - The name of the property to retrieve
    
    Returns:
    
    The property value, instance of DataflowGetPropertyExpression
  - setMetaClass
```
public final void setMetaClass(groovy.lang.MetaClass metaClass)
```
    Specified by:
    
    setMetaClass in interface groovy.lang.GroovyObject
  - setProperty
```
public final void setProperty(java.lang.String propertyName,
                              java.lang.Object newValue)
```
    Specified by:
    
    setProperty in interface groovy.lang.GroovyObject
  - getMetaClass
```
public final groovy.lang.MetaClass getMetaClass()
```
    Specified by:
    
    getMetaClass in interface groovy.lang.GroovyObject
  - toString
```
public java.lang.String toString()
```
    Overrides:
    
    toString in class java.lang.Object

Class DataflowExpression<T>

Nested Class Summary

Field Summary

Fields inherited from class groovyx.gpars.serial.WithSerialId

Constructor Summary

Method Summary

Methods inherited from class groovyx.gpars.serial.WithSerialId

Methods inherited from class java.lang.Object

Field Detail

ATTACHMENT

RESULT

stateUpdater

waitingUpdater

serialVersionUID

CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED

A_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED

metaClass

value

error

state

waiting

S_NOT_INITIALIZED

S_INITIALIZING

S_INITIALIZED

dummyWaitingThread

eventManager

Constructor Detail

DataflowExpression

Method Detail

isBound

length

getValAsync

getValAsync

join

join

getVal

getVal

poll

handleInterruption

bindSafely

bindError

bind

bindUnique

doBind

doBindImpl

doBindRemote

notifyRemote

scheduleCallback

rightShift

whenBound

whenBound

whenBound

whenBound

then

then

then

thenForkAndJoin

thenForkAndJoin

thenForkAndJoin

doThenForkAndJoin

wheneverBound

wheneverBound

chainWith

chainWith

chainWith

chainWith

chainWith

chainWith

or

filter

filter

filter

filter

filter

filter

into

into

into

into

into