Trait CommandWorker 

pub trait CommandWorker: Send {
    // Required methods
    fn is_stop_requested(&self) -> bool;
    fn request_graceful_stop(&mut self);
    async fn run_forever(&mut self) -> Result<(), CommandWorkerError>;
}

Required Methods

fn is_stop_requested(&self) -> bool

fn request_graceful_stop(&mut self)

async fn run_forever(&mut self) -> Result<(), CommandWorkerError>

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors

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>,