Struct AsyncCommandHandler 

pub struct AsyncCommandHandler<M> { /* private fields */ }

Handles execution of async commands.

This handler spawns async futures as tokio tasks and sends their results back to the runtime via a message channel. It also handles synchronous command actions directly.

Implementations

impl<M: Send + 'static> AsyncCommandHandler<M>

pub fn new() -> Self

Creates a new async command handler.

pub fn execute(&mut self, command: Command<M>)

Executes a command, collecting sync messages and async futures.

Sync actions (Message, Batch, Quit, Callback) are processed immediately. Async actions are collected for later spawning.

pub fn spawn_pending( &mut self, msg_tx: Sender<M>, err_tx: Sender<Box<dyn Error + Send + Sync + 'static>>, cancel: CancellationToken, )

Spawns all pending async futures as tokio tasks.

Each future is spawned with access to the message sender and cancellation token. When a future completes with Some(message), the message is sent to the runtime.

For fallible futures, errors are sent to the error channel instead.

pub fn take_messages(&mut self) -> Vec<M>

Takes all pending sync messages.

pub fn has_pending_futures(&self) -> bool

Returns true if any async futures are pending.

pub fn pending_future_count(&self) -> usize

Returns the number of pending async futures.

pub fn should_quit(&self) -> bool

Returns true if a quit command was executed.

pub fn reset_quit(&mut self)

Resets the quit flag.

Trait Implementations

impl<M: Send + 'static> Default for AsyncCommandHandler<M>

fn default() -> Self

Returns the “default value” for a type.