SyncDataflowStreamReadAdapter (org.codehaus.gpars)

groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter

Provides a special implementation of DataflowStreamReadAdapter, which cooperates with SyncDataflowBroadcast subscription and un-subscription mechanism.
Parameters:
- The type of messages to pass through the stream
Authors:
Vaclav Pech

Field Summary

Fields
Modifiers	Name	Description
`private boolean`	`closed`
`private boolean`	`wheneverBoundSet`

Inherited fields
Fields inherited from class	Fields
`class DataflowStreamReadAdapter`	`asyncHead, eventManager, head`

Constructor Summary

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

Methods Summary

Methods
Type	Name and description
`DataflowReadChannel<V>`	`chainWith(PGroup group, groovy.lang.Closure<V> closure)`
`private void`	`checkClosed()`
`void`	`close()` Closes the channel so that it cannot be used any longer
`T`	`getVal()`
`T`	`getVal(long timeout, java.util.concurrent.TimeUnit units)`
`void`	`getValAsync(MessageStream callback)`
`void`	`getValAsync(java.lang.Object attachment, MessageStream callback)`
`boolean`	`isBound()`
`java.util.Iterator<T>`	`iterator()`
`DataflowReadChannel<V>`	`merge(PGroup group, java.util.List<DataflowReadChannel<java.lang.Object>> others, groovy.lang.Closure<V> closure)`
`DataflowExpression<T>`	`poll()`
`Promise<V>`	`rightShift(groovy.lang.Closure<V> closure)`
`DataflowReadChannel<T>`	`tap(PGroup group, DataflowWriteChannel<T> target)`
`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 DataflowStreamReadAdapter`	allUnprocessedDFVs, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, binaryChoice, chainWith, chainWith, chainWith, chainWith, chainWith, chainWith, choice, choice, choice, choice, choice, choice, filter, filter, filter, filter, filter, filter, fireOnMessage, getEventManager, getVal, getVal, getValAsync, getValAsync, into, into, into, into, into, into, isBound, iterator, length, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, merge, moveAsyncHead, moveHead, or, or, poll, rightShift, separate, separate, separate, separate, separate, separate, shouldReportTimeout, split, split, split, split, split, split, split, split, split, split, split, split, tap, tap, tap, tap, tap, tap, then, then, then, toString, whenBound, whenBound, whenBound, whenBound, wheneverBound, wheneverBound
`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 boolean closed
  - private boolean wheneverBoundSet
- Constructor Detail
  - SyncDataflowStreamReadAdapter(StreamCore<T> stream)
    
    Creates a new adapter
    Parameters:
    stream - The stream to wrap
- Method Detail
  - @java.lang.Override public DataflowReadChannel<V> chainWith(PGroup group, groovy.lang.Closure<V> closure)
  - private void checkClosed()
  - void close()
    
    Closes the channel so that it cannot be used any longer
    throws:
    InterruptedException When the thread gets interrupted
  - @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 boolean isBound()
  - @java.lang.Override public java.util.Iterator<T> iterator()
  - @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 DataflowExpression<T> poll()
  - @java.lang.Override public Promise<V> rightShift(groovy.lang.Closure<V> closure)
  - @java.lang.Override public DataflowReadChannel<T> tap(PGroup group, DataflowWriteChannel<T> target)
  - @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 SyncDataflowStreamReadAdapter<T>

Field Summary

Constructor Summary

Methods Summary

Inherited Methods Summary

Field Detail

private boolean closed

private boolean wheneverBoundSet

Constructor Detail

SyncDataflowStreamReadAdapter(StreamCore<T> stream)

Method Detail

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

private void checkClosed()

void close()

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

@java.lang.Override public java.util.Iterator<T> iterator()

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

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

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

@java.lang.Override public void whenBound(groovy.lang.Closure<V> closure)

@java.lang.Override public void whenBound(Pool pool, groovy.lang.Closure<V> closure)

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