|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface PipePair<CmdAbove,CmdBelow,EvtAbove,EvtBelow>
Scala API: A pair of pipes, one for commands and one for events, plus a management port. Commands travel from top to bottom, events from bottom to top. All messages which need to be handled “in-order” (e.g. top-down or bottom-up) need to be either events or commands; management messages are processed in no particular order.
Java base classes are provided in the form of AbstractPipePair
and AbstractSymmetricPipePair
since the Scala function types can be
awkward to handle in Java.
PipelineStage
,
AbstractPipePair
,
AbstractSymmetricPipePair
,
PipePairFactory
Method Summary | |
---|---|
scala.Function1<CmdAbove,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> |
commandPipeline()
The command pipeline transforms injected commands from the upper stage into commands for the stage below, but it can also emit events for the upper stage. |
scala.Function1<EvtBelow,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> |
eventPipeline()
The event pipeline transforms injected event from the lower stage into event for the stage above, but it can also emit commands for the stage below. |
scala.PartialFunction<java.lang.Object,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> |
managementPort()
The management port allows sending broadcast messages to all stages within this pipeline. |
Method Detail |
---|
scala.Function1<CmdAbove,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> commandPipeline()
scala.Function1<EvtBelow,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> eventPipeline()
scala.PartialFunction<java.lang.Object,scala.collection.Iterable<scala.util.Either<EvtAbove,CmdBelow>>> managementPort()
The default implementation ignores all management commands.
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |