Wrapper class for commands to be sent to the TcpPipelineHandler actor.
Wrapper class for events emitted by the TcpPipelineHandler actor.
This method must be implemented to return the PipelineContext necessary for the operation of the given PipelineStage.
Java API: construct a command to be sent to the TcpPipelineHandler actor.
Java API: extract a wrapped event received from the TcpPipelineHandler actor.
Java API: extract a wrapped event received from the TcpPipelineHandler actor.
if the given object is not an Event matching this specific Init instance.
(init: StringAdd).self
(init: StringFormat).self
(init: ArrowAssoc[Init[Ctx, Cmd, Evt]]).x
(Since version 2.10.0) Use leftOfArrow
instead
(init: Ensuring[Init[Ctx, Cmd, Evt]]).x
(Since version 2.10.0) Use resultOfEnsuring
instead
This class wraps up a pipeline with its external (i.e. “top”) command and event types and providing unique wrappers for sending commands and receiving events (nested and non-static classes which are specific to each instance of Init). All events emitted by the pipeline will be sent to the registered handler wrapped in an Event.