Struct RuntimeBus 

pub struct RuntimeBus { /* private fields */ }

Implementations

impl RuntimeBus

pub fn new( repo: Arc<dyn RouteRepositoryPort>, projections: Arc<dyn ProjectionStorePort>, events: Arc<dyn EventPublisherPort>, dedup: Arc<dyn CommandDedupPort>, ) -> Self

pub fn with_uow(self, uow: Arc<dyn RuntimeUnitOfWorkPort>) -> Self

pub fn with_execution(self, execution: Arc<dyn RuntimeExecutionPort>) -> Self

pub fn repo(&self) -> &Arc<dyn RouteRepositoryPort>

Trait Implementations

impl RuntimeCommandBus for RuntimeBus

fn execute<'life0, 'async_trait>( &'life0 self, cmd: RuntimeCommand, ) -> Pin<Box<dyn Future<Output = Result<RuntimeCommandResult, CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

impl RuntimeQueryBus for RuntimeBus

fn ask<'life0, 'async_trait>( &'life0 self, query: RuntimeQuery, ) -> Pin<Box<dyn Future<Output = Result<RuntimeQueryResult, CamelError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,