org.codehaus.gpars

groovyx.gpars.dataflow
[Java] Class DataflowExpression.DataflowExpressionsCollector

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.dataflow.DataflowExpression.DataflowExpressionsCollector

final class DataflowExpression.DataflowExpressionsCollector
extends MessageStream

Listener for availability of data flow expressions we depend from


Field Summary
private java.util.concurrent.atomic.AtomicInteger count

private static long serialVersionUID

 
Fields inherited from class MessageStream
serialVersionUID
 
Fields inherited from class WithSerialId
serialHandle, serialVersionUID
 
Constructor Summary
DataflowExpression.DataflowExpressionsCollector()

 
Method Summary
MessageStream send(java.lang.Object message)

void start()

java.lang.Object subscribe(java.lang.Object element)

 
Methods inherited from class MessageStream
call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait
 
Methods inherited from class WithSerialId
createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
 
Methods inherited from class java.lang.Object
java.lang.Object#wait(long), java.lang.Object#wait(), java.lang.Object#wait(long, int), 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

count

private final java.util.concurrent.atomic.AtomicInteger count


serialVersionUID

private static final long serialVersionUID


 
Constructor Detail

DataflowExpression.DataflowExpressionsCollector

DataflowExpression.DataflowExpressionsCollector()


 
Method Detail

send

@Override
public MessageStream send(java.lang.Object message)


start

void start()


subscribe

java.lang.Object subscribe(java.lang.Object element)


 

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