pub struct DefaultCommandWorker<H, D, T> { /* private fields */ }Implementations§
Source§impl<H, D, T> DefaultCommandWorker<H, D, T>
impl<H, D, T> DefaultCommandWorker<H, D, T>
pub fn new( dispatcher: D, handler: H, topic: T, consumer_group: ConsumerGroup, ) -> Self
Trait Implementations§
Source§impl<H, D, T> CommandWorker for DefaultCommandWorker<H, D, T>where
H: CommandHandler,
H::Command: Command,
D: CommandDispatcher<Uow = H::Uow>,
T: Topic<CommandEnvelope, Selector = CommandSelector>,
T::Consumer: Consumer<CommandEnvelope>,
<T::Consumer as Consumer<CommandEnvelope>>::Delivery: Delivery<CommandEnvelope>,
impl<H, D, T> CommandWorker for DefaultCommandWorker<H, D, T>where
H: CommandHandler,
H::Command: Command,
D: CommandDispatcher<Uow = H::Uow>,
T: Topic<CommandEnvelope, Selector = CommandSelector>,
T::Consumer: Consumer<CommandEnvelope>,
<T::Consumer as Consumer<CommandEnvelope>>::Delivery: Delivery<CommandEnvelope>,
fn is_stop_requested(&self) -> bool
fn request_graceful_stop(&mut self)
async fn run_forever(&mut self) -> Result<(), CommandWorkerError>
Auto Trait Implementations§
impl<H, D, T> !Freeze for DefaultCommandWorker<H, D, T>
impl<H, D, T> RefUnwindSafe for DefaultCommandWorker<H, D, T>
impl<H, D, T> Send for DefaultCommandWorker<H, D, T>
impl<H, D, T> Sync for DefaultCommandWorker<H, D, T>
impl<H, D, T> Unpin for DefaultCommandWorker<H, D, T>
impl<H, D, T> UnwindSafe for DefaultCommandWorker<H, D, T>
Blanket Implementations§
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