Struct CommandPipeline 

pub struct CommandPipeline<C>
where
    C: Command + 'static,
{ /* private fields */ }

Ordered middleware pipeline ending in one typed command handler.

Middleware runs in registration order before the handler and unwinds in reverse order after it. The pipeline also implements CommandHandler<C>, so existing application services and saga processors can receive it without depending on a new abstraction.

Implementations

impl<C> CommandPipeline<C>

where C: Command + 'static,

pub fn new(handler: Arc<dyn CommandHandler<C>>) -> Self

Creates an empty pipeline ending in handler.

pub fn with_middleware(self, middleware: Arc<dyn CommandMiddleware<C>>) -> Self

Appends middleware and returns the updated pipeline.

pub fn push_middleware(&mut self, middleware: Arc<dyn CommandMiddleware<C>>)

Appends middleware after every previously registered layer.

pub fn middleware_count(&self) -> usize

Returns the number of registered middleware layers.

Trait Implementations

impl<C> CommandHandler<C> for CommandPipeline<C>

where C: Command + 'static,

fn command(&self, command: C) -> BoxFuture<'_, SoapResult<C::Output>>

Handles the command.

impl<C> Debug for CommandPipeline<C>

where C: Command + 'static,

fn fmt(&self, formatter: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.