Struct Mediator 

pub struct Mediator { /* private fields */ }

Default implementation of IMediator.

Holds the host’s root ServiceProvider and its compiled handler registry. Each send call creates a per-request scope, so Scoped services (e.g. DbContext) are resolved fresh and released with the scope by rust-dix.

Implementations

impl Mediator

pub fn new( provider: Arc<ServiceProvider>, handler_cache: Arc<HandlerCache>, ) -> Mediator

Create a mediator over a host’s provider and compiled handler registry.

Host::build constructs these handles once; IServiceCollectionExt::add_mediator registers a transient mediator that resolves them from DI, so handler code can inject Arc<dyn IMediator> / Mediator and use the same path as in-process calls.

Trait Implementations

impl IMediator for Mediator

fn send<'life0, 'async_trait, T, R>( &'life0 self, req: T, ) -> Pin<Box<dyn Future<Output = Result<R, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, T: IRequest<R> + Send + 'static + 'async_trait, R: Send + 'static + 'async_trait, Mediator: 'async_trait,

Send a request and return its structured response.

fn send_boxed<'life0, 'async_trait>( &'life0 self, req: Box<dyn Any + Send>, ) -> Pin<Box<dyn Future<Output = Result<Box<dyn Any + Send>, Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, Mediator: 'async_trait,

Send a type-erased request and return a type-erased response.

fn publish<'life0, 'async_trait, T>( &'life0 self, event: T, ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>

where 'life0: 'async_trait, T: 'async_trait + IEventRequest, Mediator: 'async_trait,

Publish an event to all registered handlers.