Overview  Package   Class  Deprecated  Index  Help 
org.codehaus.gpars
FRAMES    NO FRAMES    
SUMMARY: NESTED | FIELD | METHOD DETAIL: FIELD | METHOD

groovyx.gpars.dataflow
[Java] Interface DataflowReadChannel

groovyx.gpars.dataflow.DataflowReadChannel
  groovyx.gpars.dataflow.SelectableChannel
All Superinterfaces:
SelectableChannel
public interface DataflowReadChannel
extends SelectableChannel

A common interface for all dataflow variables, streams or queues

Authors:
Vaclav Pech Date: 21st Sep 2010

Method Summary
void binaryChoice(DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

void binaryChoice(Pool pool, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

void binaryChoice(PGroup group, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

void binaryChoice(java.util.Map params, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

void binaryChoice(Pool pool, java.util.Map params, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

void binaryChoice(PGroup group, java.util.Map params, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

DataflowReadChannel chainWith(groovy.lang.Closure closure)

DataflowReadChannel chainWith(Pool pool, groovy.lang.Closure closure)

DataflowReadChannel chainWith(PGroup group, groovy.lang.Closure closure)

DataflowReadChannel chainWith(java.util.Map params, groovy.lang.Closure closure)

DataflowReadChannel chainWith(Pool pool, java.util.Map params, groovy.lang.Closure closure)

DataflowReadChannel chainWith(PGroup group, java.util.Map params, groovy.lang.Closure closure)

void choice(java.util.List outputs, groovy.lang.Closure code)

void choice(Pool pool, java.util.List outputs, groovy.lang.Closure code)

void choice(PGroup group, java.util.List outputs, groovy.lang.Closure code)

void choice(java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

void choice(Pool pool, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

void choice(PGroup group, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

DataflowReadChannel filter(groovy.lang.Closure closure)

DataflowReadChannel filter(Pool pool, groovy.lang.Closure closure)

DataflowReadChannel filter(PGroup group, groovy.lang.Closure closure)

DataflowReadChannel filter(java.util.Map params, groovy.lang.Closure closure)

DataflowReadChannel filter(Pool pool, java.util.Map params, groovy.lang.Closure closure)

DataflowReadChannel filter(PGroup group, java.util.Map params, groovy.lang.Closure closure)

DataflowChannelEventListenerManager getEventManager()

Reports the current number of elements in the channel
java.lang.Object getVal()

java.lang.Object getVal(long timeout, java.util.concurrent.TimeUnit units)

void getValAsync(MessageStream callback)

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

Reads the current value of the channel.

void into(DataflowWriteChannel target)

void into(Pool pool, DataflowWriteChannel target)

void into(PGroup group, DataflowWriteChannel target)

void into(java.util.Map params, DataflowWriteChannel target)

void into(Pool pool, java.util.Map params, DataflowWriteChannel target)

void into(PGroup group, java.util.Map params, DataflowWriteChannel target)

Splits the output of the current channel to be an input for the specified channels
boolean isBound()

int length()

DataflowReadChannel merge(DataflowReadChannel other, groovy.lang.Closure closure)

DataflowReadChannel merge(Pool pool, DataflowReadChannel other, groovy.lang.Closure closure)

DataflowReadChannel merge(PGroup group, DataflowReadChannel other, groovy.lang.Closure closure)

DataflowReadChannel merge(java.util.List others, groovy.lang.Closure closure)

DataflowReadChannel merge(Pool pool, java.util.List others, groovy.lang.Closure closure)

DataflowReadChannel merge(PGroup group, java.util.List others, groovy.lang.Closure closure)

DataflowReadChannel merge(java.util.Map params, DataflowReadChannel other, groovy.lang.Closure closure)

DataflowReadChannel merge(Pool pool, java.util.Map params, DataflowReadChannel other, groovy.lang.Closure closure)

DataflowReadChannel merge(PGroup group, java.util.Map params, DataflowReadChannel other, groovy.lang.Closure closure)

DataflowReadChannel merge(java.util.Map params, java.util.List others, groovy.lang.Closure closure)

DataflowReadChannel merge(Pool pool, java.util.Map params, java.util.List others, groovy.lang.Closure closure)

DataflowReadChannel merge(PGroup group, java.util.Map params, java.util.List others, groovy.lang.Closure closure)

DataflowReadChannel or(groovy.lang.Closure closure)

void or(DataflowWriteChannel target)

Promise rightShift(groovy.lang.Closure closure)

Schedule closure to be executed after data becomes available.

void separate(java.util.List outputs, groovy.lang.Closure code)

void separate(Pool pool, java.util.List outputs, groovy.lang.Closure code)

void separate(PGroup group, java.util.List outputs, groovy.lang.Closure code)

void separate(java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

void separate(Pool pool, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

void separate(PGroup group, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

Check if value has been set already for this expression
void split(DataflowWriteChannel target1, DataflowWriteChannel target2)

void split(Pool pool, DataflowWriteChannel target1, DataflowWriteChannel target2)

void split(PGroup group, DataflowWriteChannel target1, DataflowWriteChannel target2)

Makes the output of the current channel to be an input for the specified channels
void split(java.util.List targets)

void split(Pool pool, java.util.List targets)

void split(PGroup group, java.util.List targets)

void split(java.util.Map params, DataflowWriteChannel target1, DataflowWriteChannel target2)

void split(Pool pool, java.util.Map params, DataflowWriteChannel target1, DataflowWriteChannel target2)

void split(PGroup group, java.util.Map params, DataflowWriteChannel target1, DataflowWriteChannel target2)

void split(java.util.Map params, java.util.List targets)

void split(Pool pool, java.util.Map params, java.util.List targets)

void split(PGroup group, java.util.Map params, java.util.List targets)

DataflowReadChannel tap(DataflowWriteChannel target)

DataflowReadChannel tap(Pool pool, DataflowWriteChannel target)

DataflowReadChannel tap(PGroup group, DataflowWriteChannel target)

DataflowReadChannel tap(java.util.Map params, DataflowWriteChannel target)

DataflowReadChannel tap(Pool pool, java.util.Map params, DataflowWriteChannel target)

DataflowReadChannel tap(PGroup group, java.util.Map params, DataflowWriteChannel target)

Promise then(groovy.lang.Closure closure)

Promise then(Pool pool, groovy.lang.Closure closure)

Promise then(PGroup group, groovy.lang.Closure closure)

void whenBound(groovy.lang.Closure closure)

void whenBound(Pool pool, groovy.lang.Closure closure)

void whenBound(PGroup group, groovy.lang.Closure closure)

void whenBound(MessageStream stream)

 
Methods inherited from interface SelectableChannel
poll, wheneverBound, wheneverBound
 

Method Detail

binaryChoice

public void binaryChoice(DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

binaryChoice

public void binaryChoice(Pool pool, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

binaryChoice

public void binaryChoice(PGroup group, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

binaryChoice

public void binaryChoice(java.util.Map params, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

binaryChoice

public void binaryChoice(Pool pool, java.util.Map params, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

binaryChoice

public void binaryChoice(PGroup group, java.util.Map params, DataflowWriteChannel trueBranch, DataflowWriteChannel falseBranch, groovy.lang.Closure code)

chainWith

public DataflowReadChannel chainWith(groovy.lang.Closure closure)

chainWith

public DataflowReadChannel chainWith(Pool pool, groovy.lang.Closure closure)

chainWith

public DataflowReadChannel chainWith(PGroup group, groovy.lang.Closure closure)

chainWith

public DataflowReadChannel chainWith(java.util.Map params, groovy.lang.Closure closure)

chainWith

public DataflowReadChannel chainWith(Pool pool, java.util.Map params, groovy.lang.Closure closure)

chainWith

public DataflowReadChannel chainWith(PGroup group, java.util.Map params, groovy.lang.Closure closure)

choice

public void choice(java.util.List outputs, groovy.lang.Closure code)

choice

public void choice(Pool pool, java.util.List outputs, groovy.lang.Closure code)

choice

public void choice(PGroup group, java.util.List outputs, groovy.lang.Closure code)

choice

public void choice(java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

choice

public void choice(Pool pool, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

choice

public void choice(PGroup group, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

filter

public DataflowReadChannel filter(groovy.lang.Closure closure)

filter

public DataflowReadChannel filter(Pool pool, groovy.lang.Closure closure)

filter

public DataflowReadChannel filter(PGroup group, groovy.lang.Closure closure)

filter

public DataflowReadChannel filter(java.util.Map params, groovy.lang.Closure closure)

filter

public DataflowReadChannel filter(Pool pool, java.util.Map params, groovy.lang.Closure closure)

filter

public DataflowReadChannel filter(PGroup group, java.util.Map params, groovy.lang.Closure closure)

getEventManager

public DataflowChannelEventListenerManager getEventManager()
Reports the current number of elements in the channel
Returns:
The current snapshot of the number of elements in the channel

getVal

public java.lang.Object getVal()

getVal

public java.lang.Object getVal(long timeout, java.util.concurrent.TimeUnit units)

getValAsync

public void getValAsync(MessageStream callback)

getValAsync

public void getValAsync(java.lang.Object attachment, MessageStream callback)
Reads the current value of the channel. Blocks, if the value has not been assigned yet.
throws:
InterruptedException If the current thread gets interrupted while waiting for the channel to be bound
Returns:
The actual value

into

public void into(DataflowWriteChannel target)

into

public void into(Pool pool, DataflowWriteChannel target)

into

public void into(PGroup group, DataflowWriteChannel target)

into

public void into(java.util.Map params, DataflowWriteChannel target)

into

public void into(Pool pool, java.util.Map params, DataflowWriteChannel target)

into

public void into(PGroup group, java.util.Map params, DataflowWriteChannel target)
Splits the output of the current channel to be an input for the specified channels
Parameters:
target1 - The first channel to copy data into
target2 - The second channel to copy data into

isBound

public boolean isBound()

length

public int length()

merge

public DataflowReadChannel merge(DataflowReadChannel other, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(Pool pool, DataflowReadChannel other, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(PGroup group, DataflowReadChannel other, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(java.util.List others, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(Pool pool, java.util.List others, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(PGroup group, java.util.List others, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(java.util.Map params, DataflowReadChannel other, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(Pool pool, java.util.Map params, DataflowReadChannel other, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(PGroup group, java.util.Map params, DataflowReadChannel other, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(java.util.Map params, java.util.List others, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(Pool pool, java.util.Map params, java.util.List others, groovy.lang.Closure closure)

merge

public DataflowReadChannel merge(PGroup group, java.util.Map params, java.util.List others, groovy.lang.Closure closure)

or

public DataflowReadChannel or(groovy.lang.Closure closure)

or

public void or(DataflowWriteChannel target)

rightShift

public Promise rightShift(groovy.lang.Closure 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.
Parameters:
closure - closure to execute when data becomes available. The closure should take at most one argument.

separate

public void separate(java.util.List outputs, groovy.lang.Closure code)

separate

public void separate(Pool pool, java.util.List outputs, groovy.lang.Closure code)

separate

public void separate(PGroup group, java.util.List outputs, groovy.lang.Closure code)

separate

public void separate(java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

separate

public void separate(Pool pool, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)

separate

public void separate(PGroup group, java.util.Map params, java.util.List outputs, groovy.lang.Closure code)
Check if value has been set already for this expression
Returns:
true if bound already

split

public void split(DataflowWriteChannel target1, DataflowWriteChannel target2)

split

public void split(Pool pool, DataflowWriteChannel target1, DataflowWriteChannel target2)

split

public void split(PGroup group, DataflowWriteChannel target1, DataflowWriteChannel target2)
Makes the output of the current channel to be an input for the specified channels
Parameters:
pool - The thread pool to use
targets - The channels to copy data into

split

public void split(java.util.List targets)

split

public void split(Pool pool, java.util.List targets)

split

public void split(PGroup group, java.util.List targets)

split

public void split(java.util.Map params, DataflowWriteChannel target1, DataflowWriteChannel target2)

split

public void split(Pool pool, java.util.Map params, DataflowWriteChannel target1, DataflowWriteChannel target2)

split

public void split(PGroup group, java.util.Map params, DataflowWriteChannel target1, DataflowWriteChannel target2)

split

public void split(java.util.Map params, java.util.List targets)

split

public void split(Pool pool, java.util.Map params, java.util.List targets)

split

public void split(PGroup group, java.util.Map params, java.util.List targets)

tap

public DataflowReadChannel tap(DataflowWriteChannel target)

tap

public DataflowReadChannel tap(Pool pool, DataflowWriteChannel target)

tap

public DataflowReadChannel tap(PGroup group, DataflowWriteChannel target)

tap

public DataflowReadChannel tap(java.util.Map params, DataflowWriteChannel target)

tap

public DataflowReadChannel tap(Pool pool, java.util.Map params, DataflowWriteChannel target)

tap

public DataflowReadChannel tap(PGroup group, java.util.Map params, DataflowWriteChannel target)

then

public Promise then(groovy.lang.Closure closure)

then

public Promise then(Pool pool, groovy.lang.Closure closure)

then

public Promise then(PGroup group, groovy.lang.Closure closure)

whenBound

public void whenBound(groovy.lang.Closure closure)

whenBound

public void whenBound(Pool pool, groovy.lang.Closure closure)

whenBound

public void whenBound(PGroup group, groovy.lang.Closure closure)

whenBound

public void whenBound(MessageStream stream)

 

Copyright © 2008–2013 Václav Pech. All Rights Reserved.