pub struct LocalCommandDispatcher { /* private fields */ }Expand description
Dispatches commands to a local executable Service.
Implementations§
Trait Implementations§
Source§impl CommandDispatcher for LocalCommandDispatcher
impl CommandDispatcher for LocalCommandDispatcher
Source§fn dispatch<'life0, 'life1, 'async_trait>(
&'life0 self,
request: &'life1 CommandRequest,
) -> Pin<Box<dyn Future<Output = Result<CommandResponse, CommandDispatchError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
fn dispatch<'life0, 'life1, 'async_trait>(
&'life0 self,
request: &'life1 CommandRequest,
) -> Pin<Box<dyn Future<Output = Result<CommandResponse, CommandDispatchError>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
'life1: 'async_trait,
Dispatch one versioned command request and return the durable response.
Auto Trait Implementations§
impl !RefUnwindSafe for LocalCommandDispatcher
impl !UnwindSafe for LocalCommandDispatcher
impl Freeze for LocalCommandDispatcher
impl Send for LocalCommandDispatcher
impl Sync for LocalCommandDispatcher
impl Unpin for LocalCommandDispatcher
impl UnsafeUnpin for LocalCommandDispatcher
Blanket Implementations§
Source§impl<T> AggregateBuilder for T
impl<T> AggregateBuilder for T
fn aggregate<A: Aggregate>(self) -> AggregateRepository<Self, A>
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> Queueable for T
impl<T> Queueable for T
Source§fn queued(self) -> QueuedRepository<Self, InMemoryLockManager>
fn queued(self) -> QueuedRepository<Self, InMemoryLockManager>
Wrap with the default async lock manager. Pair with
.aggregate::<T>() for per-aggregate serialization over the async
repository surface.Source§fn queued_with<L: LockManager>(
self,
lock_manager: L,
) -> QueuedRepository<Self, L>
fn queued_with<L: LockManager>( self, lock_manager: L, ) -> QueuedRepository<Self, L>
Wrap with a custom async lock manager.