Uses of Package
groovyx.gpars.dataflow.operator

Packages that use groovyx.gpars.dataflow.operator

groovyx.gpars	This package holds classes for asynchronous collection processing.
groovyx.gpars.dataflow	This package holds classes for basic dataflow concurrency constructs, like dataflow variables, streams and threads.
groovyx.gpars.dataflow.operator	This package holds classes representing operators and channels necessary for full dataflow concurrency.
groovyx.gpars.dataflow.operator.component
groovyx.gpars.group

Classes in groovyx.gpars.dataflow.operator used by groovyx.gpars

DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.

Classes in groovyx.gpars.dataflow.operator used by groovyx.gpars.dataflow

DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.

Classes in groovyx.gpars.dataflow.operator used by groovyx.gpars.dataflow.operator

ControlMessage
A marker interface indicating control dataflow messages, which in general do not get propagated to the operator's body

DataflowEventListener
Enables external entities to observe the state of dataflow selectors and operators

DataflowOperator
Dataflow selectors and operators (processors) form the basic units in dataflow networks.

DataflowOperatorActor
An operator's internal actor.

DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.

DataflowProcessorActor
A base actor class for operators' and selectors' actors

DataflowSelector
Dataflow selectors and operators (processors) form the basic units in dataflow networks.

DataflowSelectorActor
An selector's internal actor.

Pipeline
A builder for operator pipelines.

PoisonPill
Represents the poison for dataflow operators.

PoisonTrackCounter
A helper class used by poison messages to count terminated dataflow processors

StopGently
A message to stop operators' actors once they handle the next round of messages.

Classes in groovyx.gpars.dataflow.operator used by groovyx.gpars.dataflow.operator.component

DataflowEventAdapter
A default empty implementation of DataflowEventListener

DataflowEventListener
Enables external entities to observe the state of dataflow selectors and operators

DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.

Classes in groovyx.gpars.dataflow.operator used by groovyx.gpars.group

DataflowProcessor
Dataflow selectors and operators (processors) form the basic units in dataflow networks.