Retrieve the akka.actor.ActorContext for this pipeline’s context.
Retrieve the akka.actor.ActorContext for this pipeline’s context.
Retrieve the akka.event.LoggingAdapter for this pipeline’s context.
Retrieve the akka.event.LoggingAdapter for this pipeline’s context.
INTERNAL API: Dealias a possibly optimized return value such that it can be safely used; this is never needed when only using public API.
INTERNAL API: Dealias a possibly optimized return value such that it can be safely used; this is never needed when only using public API.
A shared (and shareable) instance of an empty Iterable[Either[EvtAbove, CmdBelow]]
.
A shared (and shareable) instance of an empty Iterable[Either[EvtAbove, CmdBelow]]
.
Use this when processing does not yield any commands or events as result.
Scala API: Wrap a single command for efficient return to the pipeline’s machinery.
Scala API: Wrap a single command for efficient return to the pipeline’s machinery. This method avoids allocating a scala.util.Right and an scala.collection.Iterable by reusing one such instance within the PipelineContext, hence it can be used ONLY ONCE by each pipeline stage. Prototypic and safe usage looks like this:
override val commandPipeline = { cmd => val myResult = ... ctx.singleCommand(myResult) }
AbstractPipePair#singleCommand see AbstractPipePair for the Java API
Scala API: Wrap a single event for efficient return to the pipeline’s machinery.
Scala API: Wrap a single event for efficient return to the pipeline’s machinery. This method avoids allocating a scala.util.Left and an scala.collection.Iterable by reusing one such instance within the context, hence it can be used ONLY ONCE by each pipeline stage. Prototypic and safe usage looks like this:
override val eventPipeline = { cmd => val myResult = ... ctx.singleEvent(myResult) }
AbstractPipePair#singleEvent see AbstractPipePair for the Java API
(withinActorContext: StringAdd).self
(withinActorContext: StringFormat).self
(withinActorContext: ArrowAssoc[WithinActorContext]).x
(Since version 2.10.0) Use leftOfArrow
instead
(withinActorContext: Ensuring[WithinActorContext]).x
(Since version 2.10.0) Use resultOfEnsuring
instead
This interface bundles logging and ActorContext for Java.