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

groovyx.gpars.dataflow
Class DataFlowExpression.DataFlowExpressionsCollector

java.lang.Object
  groovyx.gpars.serial.WithSerialId
      groovyx.gpars.actor.impl.MessageStream
          groovyx.gpars.dataflow.DataFlowExpression.DataFlowExpressionsCollector

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

 
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
 

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

public void start()

subscribe

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

 

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