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

groovyx.gpars.dataflow
[Java] Class SyncDataflowStreamReadAdapter

java.lang.Object
  groovyx.gpars.dataflow.stream.DataflowStreamReadAdapter
      groovyx.gpars.dataflow.SyncDataflowStreamReadAdapter

final class SyncDataflowStreamReadAdapter
extends DataflowStreamReadAdapter

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
private boolean closed

private boolean wheneverBoundSet

 
Fields inherited from class DataflowStreamReadAdapter
asyncHead, eventManager, head
 
Constructor Summary
SyncDataflowStreamReadAdapter(StreamCore stream)

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

private void checkClosed()

void close()

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)

boolean isBound()

java.util.Iterator iterator()

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

DataflowExpression poll()

Promise rightShift(groovy.lang.Closure closure)

DataflowReadChannel tap(PGroup group, DataflowWriteChannel target)

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)

void wheneverBound(groovy.lang.Closure closure)

void wheneverBound(MessageStream stream)

 
Methods inherited from 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
 

Field Detail

closed

private boolean closed

wheneverBoundSet

private boolean wheneverBoundSet

 
Constructor Detail

SyncDataflowStreamReadAdapter

SyncDataflowStreamReadAdapter(StreamCore stream)

 
Method Detail

chainWith

@java.lang.Overridepublic  DataflowReadChannel merge(final PGroup group, final List> others, final Closure closure) {
public DataflowReadChannel chainWith(PGroup group, groovy.lang.Closure closure)

checkClosed

private void checkClosed()

close

void close()

getVal

@java.lang.Overridesuper.getValAsync(callback);
public java.lang.Object getVal()

getVal

@java.lang.Overridesuper.getValAsync(attachment, callback);
public java.lang.Object getVal(long timeout, java.util.concurrent.TimeUnit units)

getValAsync

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

getValAsync

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

isBound

@java.lang.Override}
public boolean isBound()

iterator

@java.lang.Overridereturn super.getVal(timeout, units);
public java.util.Iterator iterator()

merge

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

poll

@java.lang.Override*/
public DataflowExpression poll()

rightShift

@java.lang.Override*
public Promise rightShift(groovy.lang.Closure closure)

tap

@java.lang.Override}
public DataflowReadChannel tap(PGroup group, DataflowWriteChannel target)

whenBound

@java.lang.Overridepublic  void whenBound(final Pool pool, final Closure closure) {
public void whenBound(groovy.lang.Closure closure)

whenBound

@java.lang.Overridesuper.whenBound(stream);
public void whenBound(Pool pool, groovy.lang.Closure closure)

whenBound

@java.lang.OverridewheneverBoundSet = true;
public void whenBound(PGroup group, groovy.lang.Closure closure)

whenBound

@java.lang.OverridecheckClosed();
public void whenBound(MessageStream stream)

wheneverBound

@java.lang.Overridepublic  DataflowReadChannel chainWith(final PGroup group, final Closure closure) {
public void wheneverBound(groovy.lang.Closure closure)

wheneverBound

@java.lang.Overridepublic DataflowReadChannel tap(final PGroup group, final DataflowWriteChannel target) {
public void wheneverBound(MessageStream stream)

 

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