See: Description
| Interface | Description |
|---|---|
| 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
|
| Class | Description |
|---|---|
| BinaryChoiceClosure |
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
|
| ChainWithClosure<V> |
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
|
| ChoiceClosure |
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
|
| CopyChannelsClosure<V> |
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
|
| CountingPoisonPill |
Represents a non-immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.
|
| DataflowEventAdapter |
A default empty implementation of DataflowEventListener
|
| DataflowOperator |
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| DataflowOperatorActor |
An operator's internal actor.
|
| DataflowPrioritySelector |
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| DataflowProcessor |
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| DataflowProcessorActor |
A base actor class for operators' and selectors' actors
|
| DataflowProcessorAtomicBoundAllClosure | |
| DataflowSelector |
Dataflow selectors and operators (processors) form the basic units in dataflow networks.
|
| DataflowSelectorActor |
An selector's internal actor.
|
| FilterClosure<V> |
Used by the filter() method to wrap the supplied closure and use it for filtering data.
|
| ForkingDataflowOperatorActor |
An operator's internal actor.
|
| ForkingDataflowSelectorActor |
An selector's internal actor.
|
| ImmediateCountingPoisonPill |
Represents an immediate PoisonPill that counts stopped operators and can be used to wait for all the operators to terminate.
|
| 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
|
| SeparationClosure |
Used by the chainWith() method to wrap the supplied closure inside the operator's body.
|
| StopGently |
A message to stop operators' actors once they handle the next round of messages.
|
This package holds classes representing operators and channels necessary for full dataflow concurrency.