Field Summary

Fields 

Modifiers	Name	Description
private java.util.concurrent.atomic.AtomicInteger	count
private static long	serialVersionUID

Inherited fields 

Fields inherited from class	Fields
class MessageStream	serialVersionUID
class WithSerialId	serialHandle, serialVersionUID

Constructor Summary

Constructors 

Constructor and description
DataflowExpression.DataflowExpressionsCollector ()

Methods Summary

Methods 

Type	Name and description
MessageStream	send(java.lang.Object message)
void	start()
java.lang.Object	subscribe(java.lang.Object element)

Inherited Methods Summary

Inherited Methods 

Methods inherited from class	Name
class MessageStream	call, getRemoteClass, leftShift, reInterrupt, send, send, send, sendAndWait, sendAndWait, sendAndWait
class WithSerialId	createRemoteHandle, getOrCreateSerialHandle, getRemoteClass, writeReplace
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()