groovyx.gpars.dataflow.operator

Interfaces

• ControlMessage
• DataflowEventListener

Classes

• BinaryChoiceClosure
• ChainWithClosure
• ChoiceClosure
• CopyChannelsClosure
• CountingPoisonPill
• DataflowEventAdapter
• DataflowOperator
• DataflowOperatorActor
• DataflowPrioritySelector
• DataflowProcessor
• DataflowProcessorActor
• DataflowProcessorAtomicBoundAllClosure
• DataflowSelector
• DataflowSelectorActor
• FilterClosure
• ForkingDataflowOperatorActor
• ForkingDataflowSelectorActor
• ImmediateCountingPoisonPill
• Pipeline
• PoisonPill
• PoisonTrackCounter
• SeparationClosure
• StopGently