DataflowExpression (org.codehaus.gpars)

groovyx.gpars.dataflow.expression.DataflowExpression

All Implemented Interfaces and Traits:: DataflowReadChannel, groovy.lang.GroovyObject

@java.lang.SuppressWarnings({"UnqualifiedStaticUsage", "CallToSimpleGetterFromWithinClass", "ConstantDeclaredInAbstractClass", "unchecked"})
public abstract class DataflowExpression
extends WithSerialId

The base class for all dataflow elements.

Authors:: Alex Tkachman, Vaclav Pech

Nested Class Summary

Nested classes
Modifiers	Name	Description
`static class`	`DataflowExpression.BindDataflow`	Represents a remote message binding a value to a remoted DataflowExpression
`class`	`DataflowExpression.DataflowExpressionsCollector`	Listener for availability of data flow expressions we depend on.
`private static class`	`DataflowExpression.TransformMany`
`private static class`	`DataflowExpression.TransformOne`
`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
Modifiers	Name	Description
`private static java.lang.String`	`ATTACHMENT`
`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`	`CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED`
`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 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 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, WaitingThread>`	`waitingUpdater`	Updater for the waiting field

Inherited fields
Fields inherited from class	Fields
`class WithSerialId`	`serialHandle, serialVersionUID`

Constructor Summary

Constructors
Constructor and description
`DataflowExpression ()`

Methods Summary

Methods
Type	Name and description
`protected java.lang.Object`	`DataflowExpression()` Creates a new unbound Dataflow Expression
`void`	`binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)`
`void`	`binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)`
`void`	`binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)`
`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)`
`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)`
`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)`
`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.
`DataflowReadChannel<V>`	`chainWith(groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`chainWith(Pool pool, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`chainWith(PGroup group, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`chainWith(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`chainWith(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`chainWith(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)`
`void`	`choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)`
`void`	`choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)`
`void`	`choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)`
`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)`
`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)`
`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)`
`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)`
`DataflowReadChannel<T>`	`filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)`
`DataflowReadChannel<T>`	`filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure)`
`DataflowReadChannel<T>`	`filter(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)`
`DataflowReadChannel<T>`	`filter(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)`
`DataflowReadChannel<T>`	`filter(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> 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()`
`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)`
`void`	`into(Pool pool, DataflowWriteChannel<T> target)`
`void`	`into(PGroup group, DataflowWriteChannel<T> target)`
`void`	`into(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)`
`void`	`into(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)`
`void`	`into(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)`
`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()`
`DataflowReadChannel<V>`	`merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)`
`DataflowReadChannel<V>`	`merge(java.util.Map<java.lang.String, java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)`
`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)`
`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)`
`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)`
`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)`
`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)`
`private void`	`notifyRemote(java.util.UUID hostId)` Sends notifications to all subscribers
`DataflowReadChannel<V>`	`or(groovy.lang.Closure<V> closure)`
`void`	`or(DataflowWriteChannel<T> target)`
`DataflowExpression<T>`	`poll()` Retrieves the bound value.
`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)`
`void`	`separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)`
`void`	`separate(PGroup group, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)`
`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)`
`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)`
`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)`
`void`	`setMetaClass(groovy.lang.MetaClass metaClass)`
`void`	`setProperty(java.lang.String propertyName, java.lang.Object newValue)`
`void`	`split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)`
`void`	`split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)`
`void`	`split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)`
`void`	`split(java.util.List<DataflowWriteChannel<T>> targets)`
`void`	`split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)`
`void`	`split(PGroup group, java.util.List<DataflowWriteChannel<T>> targets)`
`void`	`split(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)`
`void`	`split(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)`
`void`	`split(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)`
`void`	`split(java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)`
`void`	`split(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)`
`void`	`split(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)`
`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)`
`DataflowReadChannel<T>`	`tap(Pool pool, DataflowWriteChannel<T> target)`
`DataflowReadChannel<T>`	`tap(PGroup group, DataflowWriteChannel<T> target)`
`DataflowReadChannel<T>`	`tap(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)`
`DataflowReadChannel<T>`	`tap(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)`
`DataflowReadChannel<T>`	`tap(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)`
`Promise<V>`	`then(groovy.lang.Closure<V> closure)` Schedule closure to be executed after data became available.
`Promise<V>`	`then(Pool pool, groovy.lang.Closure<V> closure)` Schedule closure to be executed after data becomes available.
`Promise<V>`	`then(PGroup group, 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(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.
`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.
`java.lang.String`	`toString()`
`static DataflowExpression<V>`	`transform(java.lang.Object another, groovy.lang.Closure closure)` Transforms values bound eventually to dataflow variables using the supplied closure.
`void`	`whenBound(groovy.lang.Closure<V> closure)` Schedule closure to be executed by pooled actor after data becomes available.
`void`	`whenBound(Pool pool, groovy.lang.Closure<V> closure)` Schedule closure to be executed by pooled actor after data becomes available.
`void`	`whenBound(PGroup group, 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
`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.

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`class WithSerialId`	`createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace`
`class java.lang.Object`	`java.lang.Object#wait(), java.lang.Object#wait(long, int), java.lang.Object#wait(long), java.lang.Object#equals(java.lang.Object), java.lang.Object#toString(), java.lang.Object#hashCode(), java.lang.Object#getClass(), java.lang.Object#notify(), java.lang.Object#notifyAll()`

- Field Detail
  - private static final java.lang.String ATTACHMENT
  - private static final java.lang.String A_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED
  - private static final java.lang.String CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED
  - private static final java.lang.String RESULT
  - protected static final int S_INITIALIZED
  - protected static final int S_INITIALIZING
  - protected static final int S_NOT_INITIALIZED
    
    Possible states
  - private static final 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 final long serialVersionUID
  - protected int state
    
    Holds the current state of the variable
  - @java.lang.SuppressWarnings({"rawtypes", "RawUseOfParameterizedType"}) protected static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<DataflowExpression> stateUpdater
    
    Updater for the state field
  - @java.lang.SuppressWarnings({"InstanceVariableMayNotBeInitialized"}) protected T value
    
    Holds the actual value. Is null before a concrete value is bound to it.
  - @java.lang.SuppressWarnings({"UnusedDeclaration"}) //modified through stateUpdater private DataflowExpression.WaitingThread waiting
    
    Points to the head of the chain of requests waiting for a value to be bound
  - @java.lang.SuppressWarnings({"rawtypes", "RawUseOfParameterizedType"}) protected static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<DataflowExpression, WaitingThread> waitingUpdater
    
    Updater for the waiting field
- Constructor Detail
  - DataflowExpression()
- Method Detail
  - protected java.lang.Object DataflowExpression()
    
    Creates a new unbound Dataflow Expression
  - @java.lang.Override public void binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
  - @java.lang.Override public void binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
  - @java.lang.Override public void binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)
  - @java.lang.Override 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)
  - @java.lang.Override 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)
  - @java.lang.Override 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)
  - 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
  - public final void bindError(java.lang.Throwable e)
  - 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
  - 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
  - @java.lang.Override public final DataflowReadChannel<V> chainWith(groovy.lang.Closure<V> closure)
  - @java.lang.Override public final DataflowReadChannel<V> chainWith(Pool pool, groovy.lang.Closure<V> closure)
  - @java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public DataflowReadChannel<V> chainWith(PGroup group, groovy.lang.Closure<V> closure)
  - @java.lang.Override public final DataflowReadChannel<V> chainWith(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)
  - @java.lang.Override public final DataflowReadChannel<V> chainWith(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)
  - @java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public DataflowReadChannel<V> chainWith(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)
  - @java.lang.Override public void choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
  - @java.lang.Override public void choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
  - @java.lang.Override public void choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)
  - @java.lang.Override 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)
  - @java.lang.Override 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)
  - @java.lang.Override 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)
  - private DataflowChannelEventOrchestrator<T> createEventManager()
  - 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
  - protected void doBindImpl(T value)
  - 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
  - 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
    Returns:
    The value to bind
  - @java.lang.Override public DataflowReadChannel<T> filter(groovy.lang.Closure<java.lang.Boolean> closure)
  - @java.lang.Override public DataflowReadChannel<T> filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)
  - @java.lang.Override public DataflowReadChannel<T> filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure)
  - @java.lang.Override public DataflowReadChannel<T> filter(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
  - @java.lang.Override public DataflowReadChannel<T> filter(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
  - @java.lang.Override public DataflowReadChannel<T> filter(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)
  - private void fireBindError(T value, boolean unique)
  - private void fireBindError(java.lang.Throwable e)
  - private void fireOnMessage(T value)
  - public BindErrorListenerManager<T> getBindErrorManager()
  - @java.lang.Override public DataflowChannelEventListenerManager<T> getEventManager()
  - @java.lang.Override public final groovy.lang.MetaClass getMetaClass()
  - @java.lang.Override 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
    Returns:
    The property value, instance of DataflowGetPropertyExpression
    Parameters:
    propertyName - The name of the property to retrieve
  - @java.lang.Override public T getVal()
    
    Reads the value of the variable. Blocks, if the value has not been assigned yet.
    throws:
    InterruptedException If the current thread gets interrupted while waiting for the variable to be bound
    
    Returns:
    The actual value
  - @java.lang.Override public T getVal(long timeout, java.util.concurrent.TimeUnit units)
    
    Reads the value of the variable. Blocks up to given timeout, if the value has not been assigned yet.
    throws:
    InterruptedException If the current thread gets interrupted while waiting for the variable to be bound
    
    Returns:
    The actual value
    Parameters:
    timeout - The timeout value
    units - Units for the timeout
  - @java.lang.Override 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.
    Parameters:
    callback - An actor to send the bound value to.
  - @java.lang.Override 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.
    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.
  - private static void handleInterruption(java.util.concurrent.atomic.AtomicBoolean newWaiting)
  - @java.lang.Override public void into(DataflowWriteChannel<T> target)
  - @java.lang.Override public void into(Pool pool, DataflowWriteChannel<T> target)
  - @java.lang.Override public void into(PGroup group, DataflowWriteChannel<T> target)
  - @java.lang.Override public void into(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)
  - @java.lang.Override public void into(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)
  - @java.lang.Override public void into(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)
  - @java.lang.Override 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.
  - @java.lang.Override public final boolean isBound()
    
    Check if value has been set already for this expression
    Returns:
    true if bound already
  - public final void join()
    
    Blocks, if the value has not been assigned yet to the DataflowVariable
    throws:
    InterruptedException If the current thread gets interrupted while waiting for the variable to be bound
  - public final void join(long timeout, java.util.concurrent.TimeUnit units)
    
    Blocks, if the value has not been assigned yet to the DataflowVariable
    throws:
    InterruptedException If the current thread gets interrupted while waiting for the variable to be bound
    
    Parameters:
    timeout - The timeout value
    units - Units for the timeout
  - @java.lang.Override public final int length()
  - @java.lang.Override public DataflowReadChannel<V> merge(DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
  - @java.lang.Override public DataflowReadChannel<V> merge(Pool pool, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
  - @java.lang.Override public DataflowReadChannel<V> merge(PGroup group, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
  - @java.lang.Override public DataflowReadChannel<V> merge(java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
  - @java.lang.Override public DataflowReadChannel<V> merge(Pool pool, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
  - @java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public DataflowReadChannel<V> merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)
  - @java.lang.Override public DataflowReadChannel<V> merge(java.util.Map<java.lang.String, java.lang.Object> params, DataflowReadChannel<java.lang.Object> other, groovy.lang.Closure<V> closure)
  - @java.lang.Override public 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)
  - @java.lang.Override public 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)
  - @java.lang.Override public 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)
  - @java.lang.Override public 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)
  - @java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public 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)
  - private void notifyRemote(java.util.UUID hostId)
    
    Sends notifications to all subscribers
    Parameters:
    hostId - The local host id
  - @java.lang.Override public DataflowReadChannel<V> or(groovy.lang.Closure<V> closure)
  - @java.lang.Override public void or(DataflowWriteChannel<T> target)
  - @java.lang.Override public final DataflowExpression<T> poll()
    
    Retrieves the bound value. Returns null, if no value is available.
    Returns:
    The value bound to the DFV or null
  - @java.lang.Override public final 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
    Parameters:
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - @java.lang.SuppressWarnings({"TypeMayBeWeakened"}) 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
  - @java.lang.Override public void separate(java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
  - @java.lang.Override public void separate(Pool pool, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
  - @java.lang.Override public void separate(PGroup group, java.util.List<DataflowWriteChannel<?>> outputs, groovy.lang.Closure<java.util.List<java.lang.Object>> code)
  - @java.lang.Override 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)
  - @java.lang.Override 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)
  - @java.lang.Override 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)
  - @java.lang.Override public final void setMetaClass(groovy.lang.MetaClass metaClass)
  - @java.lang.Override public final void setProperty(java.lang.String propertyName, java.lang.Object newValue)
  - @java.lang.Override public void split(DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
  - @java.lang.Override public void split(Pool pool, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
  - @java.lang.Override public void split(PGroup group, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
  - @java.lang.Override public void split(java.util.List<DataflowWriteChannel<T>> targets)
  - @java.lang.Override public void split(Pool pool, java.util.List<DataflowWriteChannel<T>> targets)
  - @java.lang.Override public void split(PGroup group, java.util.List<DataflowWriteChannel<T>> targets)
  - @java.lang.Override public void split(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
  - @java.lang.Override public void split(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
  - @java.lang.Override public void split(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target1, DataflowWriteChannel<T> target2)
  - @java.lang.Override public void split(java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
  - @java.lang.Override public void split(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
  - @java.lang.Override public void split(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, java.util.List<DataflowWriteChannel<T>> targets)
  - 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
  - protected void subscribe(DataflowExpression.DataflowExpressionsCollector listener)
  - @java.lang.Override public DataflowReadChannel<T> tap(DataflowWriteChannel<T> target)
  - @java.lang.Override public DataflowReadChannel<T> tap(Pool pool, DataflowWriteChannel<T> target)
  - @java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public DataflowReadChannel<T> tap(PGroup group, DataflowWriteChannel<T> target)
  - @java.lang.Override public DataflowReadChannel<T> tap(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)
  - @java.lang.Override public DataflowReadChannel<T> tap(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)
  - @java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public DataflowReadChannel<T> tap(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)
  - @java.lang.Override public final 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
    Returns:
    A promise for the results of the supplied closure. This allows for chaining of then() method calls.
    Parameters:
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - @java.lang.Override public final 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.
    Returns:
    A promise for the results of the supplied closure. This allows for chaining of then() method calls.
    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.
  - @java.lang.Override public final 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.
    Returns:
    A promise for the results of the supplied closure. This allows for chaining of then() method calls.
    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.
  - @java.lang.SuppressWarnings({"rawtypes", "ClassReferencesSubclass"}) 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.
    Returns:
    A promise for the results of the supplied closures. This allows for chaining of then() method calls.
    Parameters:
    closures - closure to execute when data becomes available. The closure should take at most one argument.
  - @java.lang.SuppressWarnings({"rawtypes", "ClassReferencesSubclass"}) 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.
    Returns:
    A promise for the results of the supplied closures. This allows for chaining of then() method calls.
    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.
  - @java.lang.SuppressWarnings({"rawtypes", "ClassReferencesSubclass"}) 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.
    Returns:
    A promise for the results of the supplied closures. This allows for chaining of then() method calls.
    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.
  - @java.lang.SuppressWarnings({"ArithmeticOnVolatileField"}) @java.lang.Override public java.lang.String toString()
  - public static DataflowExpression<V> transform(java.lang.Object another, groovy.lang.Closure closure)
    
    Transforms values bound eventually to dataflow variables using the supplied closure.
    Returns:
    The value returned from the transformation closure.
    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
    - Type of the bound values
  - @java.lang.Override public final 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.
    Parameters:
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - @java.lang.Override public 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.
    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.
  - @java.lang.Override public final 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.
    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.
  - @java.lang.Override public final void whenBound(MessageStream stream)
    
    Send the bound data to provided stream when it becomes available
    Parameters:
    stream - stream where to send result
  - @java.lang.Override public final void wheneverBound(groovy.lang.Closure<V> closure)
    
    Send all pieces of data bound in the future to the provided stream when it becomes available. *
    Parameters:
    closure - closure to execute when data becomes available. The closure should take at most one argument.
  - @java.lang.Override public final void wheneverBound(MessageStream stream)
    
    Send all pieces of data bound in the future to the provided stream when it becomes available.
    Parameters:
    stream - stream where to send result

| Detail:
Field
Constructor
Method

[Java] Class DataflowExpression<T>

Nested Class Summary

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private static final java.lang.String ATTACHMENT

private static final java.lang.String A_DATAFLOW_VARIABLE_CAN_ONLY_BE_ASSIGNED_ONCE_ONLY_RE_ASSIGNMENTS_TO_AN_EQUAL_VALUE_ARE_ALLOWED

private static final java.lang.String CANNOT_FIRE_BIND_ERRORS_THE_THREAD_HAS_BEEN_INTERRUPTED

private static final java.lang.String RESULT

protected static final int S_INITIALIZED

protected static final int S_INITIALIZING

protected static final int S_NOT_INITIALIZED

private static final DataflowExpression.WaitingThread dummyWaitingThread

protected java.lang.Throwable error

private DataflowChannelEventOrchestrator<T> eventManager

private groovy.lang.MetaClass metaClass

private static final long serialVersionUID

protected int state

@java.lang.SuppressWarnings({"rawtypes", "RawUseOfParameterizedType"}) protected static final java.util.concurrent.atomic.AtomicIntegerFieldUpdater<DataflowExpression> stateUpdater

@java.lang.SuppressWarnings({"InstanceVariableMayNotBeInitialized"}) protected T value

@java.lang.SuppressWarnings({"UnusedDeclaration"}) //modified through stateUpdater private DataflowExpression.WaitingThread waiting

@java.lang.SuppressWarnings({"rawtypes", "RawUseOfParameterizedType"}) protected static final java.util.concurrent.atomic.AtomicReferenceFieldUpdater<DataflowExpression, WaitingThread> waitingUpdater

Constructor Detail

DataflowExpression()

Method Detail

protected java.lang.Object DataflowExpression()

@java.lang.Override public void binaryChoice(DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)

@java.lang.Override public void binaryChoice(Pool pool, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)

@java.lang.Override public void binaryChoice(PGroup group, DataflowWriteChannel<T> trueBranch, DataflowWriteChannel<T> falseBranch, groovy.lang.Closure<java.lang.Boolean> code)

@java.lang.Override 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)

@java.lang.Override 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)

@java.lang.Override 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)

public final void bind(T value)

public final void bindError(java.lang.Throwable e)

public final void bindSafely(T value)

public final void bindUnique(T value)

@java.lang.Override public final DataflowReadChannel<V> chainWith(groovy.lang.Closure<V> closure)

@java.lang.Override public final DataflowReadChannel<V> chainWith(Pool pool, groovy.lang.Closure<V> closure)

@java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public DataflowReadChannel<V> chainWith(PGroup group, groovy.lang.Closure<V> closure)

@java.lang.Override public final DataflowReadChannel<V> chainWith(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)

@java.lang.Override public final DataflowReadChannel<V> chainWith(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)

@java.lang.SuppressWarnings({"ClassReferencesSubclass"}) @java.lang.Override public DataflowReadChannel<V> chainWith(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<V> closure)

@java.lang.Override public void choice(java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)

@java.lang.Override public void choice(Pool pool, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)

@java.lang.Override public void choice(PGroup group, java.util.List<DataflowWriteChannel<T>> outputs, groovy.lang.Closure<java.lang.Integer> code)

@java.lang.Override 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)

@java.lang.Override 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)

@java.lang.Override 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)

private DataflowChannelEventOrchestrator<T> createEventManager()

private void doBind(T value)

protected void doBindImpl(T value)

public final void doBindRemote(java.util.UUID hostId, T message)

private Promise<java.util.List> doThenForkAndJoin(PGroup group, Pool pool, groovy.lang.Closure<? extends java.lang.Object>[] closures)

protected T evaluate()

@java.lang.Override public DataflowReadChannel<T> filter(groovy.lang.Closure<java.lang.Boolean> closure)

@java.lang.Override public DataflowReadChannel<T> filter(Pool pool, groovy.lang.Closure<java.lang.Boolean> closure)

@java.lang.Override public DataflowReadChannel<T> filter(PGroup group, groovy.lang.Closure<java.lang.Boolean> closure)

@java.lang.Override public DataflowReadChannel<T> filter(java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)

@java.lang.Override public DataflowReadChannel<T> filter(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)

@java.lang.Override public DataflowReadChannel<T> filter(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, groovy.lang.Closure<java.lang.Boolean> closure)

private void fireBindError(T value, boolean unique)

private void fireBindError(java.lang.Throwable e)

private void fireOnMessage(T value)

public BindErrorListenerManager<T> getBindErrorManager()

@java.lang.Override public DataflowChannelEventListenerManager<T> getEventManager()

@java.lang.Override public final groovy.lang.MetaClass getMetaClass()

@java.lang.Override public final java.lang.Object getProperty(java.lang.String propertyName)

@java.lang.Override public T getVal()

@java.lang.Override public T getVal(long timeout, java.util.concurrent.TimeUnit units)

@java.lang.Override public void getValAsync(MessageStream callback)

@java.lang.Override public void getValAsync(java.lang.Object attachment, MessageStream callback)

private static void handleInterruption(java.util.concurrent.atomic.AtomicBoolean newWaiting)

@java.lang.Override public void into(DataflowWriteChannel<T> target)

@java.lang.Override public void into(Pool pool, DataflowWriteChannel<T> target)

@java.lang.Override public void into(PGroup group, DataflowWriteChannel<T> target)

@java.lang.Override public void into(java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)

@java.lang.Override public void into(Pool pool, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)

@java.lang.Override public void into(PGroup group, java.util.Map<java.lang.String, java.lang.Object> params, DataflowWriteChannel<T> target)