DataflowStreamReadAdapter (org.codehaus.gpars)

groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter

All Implemented Interfaces and Traits:

DataflowReadChannel
```
@java.lang.SuppressWarnings({"unchecked"})
public class DataflowStreamReadAdapter
extends java.lang.Object
```
Adapts a DataflowStream to accommodate for the DataflowReadChannel interface. To minimize the overhead and stay in-line with the DataflowStream semantics, the DataflowStreamReadAdapter class is not thread-safe and should only be used from within a single thread. If multiple threads need to read from a DataflowStream, they should each create their own wrapping DataflowStreamReadAdapter.
Parameters:
- The type of messages to pass through the stream
Authors:
Vaclav Pech

Field Summary

Fields
Modifiers	Name	Description
`private StreamCore<T>`	`asyncHead`
`private DataflowChannelEventOrchestrator<T>`	`eventManager`
`private StreamCore<T>`	`head`

Constructor Summary

Constructors
Constructor and description
`DataflowStreamReadAdapter (StreamCore<T> stream)` Creates a new adapter

Methods Summary

Methods
Type	Name and description
`protected java.util.List<DataflowVariable<T>>`	`allUnprocessedDFVs()`
`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)`
`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)`
`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`	`fireOnMessage(T value)`
`DataflowChannelEventListenerManager<T>`	`getEventManager()`
`T`	`getVal()`
`T`	`getVal(long timeout, java.util.concurrent.TimeUnit units)`
`void`	`getValAsync(MessageStream callback)`
`void`	`getValAsync(java.lang.Object attachment, MessageStream callback)`
`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)`
`boolean`	`isBound()`
`java.util.Iterator<T>`	`iterator()`
`int`	`length()` Returns the current size of the buffer
`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`	`moveAsyncHead()`
`private void`	`moveHead()`
`DataflowReadChannel<V>`	`or(groovy.lang.Closure<V> closure)`
`void`	`or(DataflowWriteChannel<T> target)`
`DataflowExpression<T>`	`poll()`
`Promise<V>`	`rightShift(groovy.lang.Closure<V> closure)`
`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)`
`private boolean`	`shouldReportTimeout()`
`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)`
`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.
`java.lang.String`	`toString()`
`void`	`whenBound(groovy.lang.Closure<V> closure)`
`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)`
`void`	`whenBound(MessageStream stream)`
`void`	`wheneverBound(groovy.lang.Closure<V> closure)`
`void`	`wheneverBound(MessageStream stream)`

Inherited Methods Summary

Inherited Methods
Methods inherited from class	Name
`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 StreamCore<T> asyncHead
  - private DataflowChannelEventOrchestrator<T> eventManager
  - private StreamCore<T> head
- Constructor Detail
  - public DataflowStreamReadAdapter(StreamCore<T> stream)
    
    Creates a new adapter
    Parameters:
    stream - The stream to wrap
- Method Detail
  - protected final java.util.List<DataflowVariable<T>> allUnprocessedDFVs()
  - @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)
  - @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.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.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)
  - @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 fireOnMessage(T value)
  - @java.lang.Override public DataflowChannelEventListenerManager<T> getEventManager()
  - @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)
  - @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 boolean isBound()
  - public java.util.Iterator<T> iterator()
  - @java.lang.Override public int length()
    
    Returns the current size of the buffer
    Returns:
    Number of DFVs in the queue
  - @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.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.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 moveAsyncHead()
  - private void moveHead()
  - @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 DataflowExpression<T> poll()
  - @java.lang.Override public Promise<V> rightShift(groovy.lang.Closure<V> closure)
  - @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)
  - private boolean shouldReportTimeout()
  - @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)
  - @java.lang.Override public DataflowReadChannel<T> tap(DataflowWriteChannel<T> target)
  - @java.lang.Override public DataflowReadChannel<T> tap(Pool pool, DataflowWriteChannel<T> target)
  - @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.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 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 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("ObjectToString") @java.lang.Override public final java.lang.String toString()
  - @java.lang.Override public void whenBound(groovy.lang.Closure<V> closure)
  - @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 void whenBound(PGroup group, groovy.lang.Closure<V> closure)
  - @java.lang.Override public void whenBound(MessageStream stream)
  - @java.lang.Override public void wheneverBound(groovy.lang.Closure<V> closure)
  - @java.lang.Override public void wheneverBound(MessageStream stream)

Summary:
Field
Constructor
Method

| Detail:
Field
Constructor
Method

[Java] Class DataflowStreamReadAdapter<T>

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private StreamCore<T> asyncHead

private DataflowChannelEventOrchestrator<T> eventManager

private StreamCore<T> head

Constructor Detail

public DataflowStreamReadAdapter(StreamCore<T> stream)

Method Detail

protected final java.util.List<DataflowVariable<T>> allUnprocessedDFVs()

@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)

@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.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.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)

@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 fireOnMessage(T value)

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

@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)

@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 boolean isBound()

public java.util.Iterator<T> iterator()

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

private void moveHead()

@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 DataflowExpression<T> poll()

@java.lang.Override public Promise<V> rightShift(groovy.lang.Closure<V> closure)

@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)

private boolean shouldReportTimeout()

@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)