Struct CommandHandler 

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

Handles execution of commands.

This handler processes sync actions immediately and collects async futures for later spawning as tokio tasks.

Implementations

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

pub fn new() -> Self

Creates a new 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 via spawn_pending.

pub fn spawn_pending( &mut self, msg_tx: Sender<M>, err_tx: Sender<BoxedError>, 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 messages.

pub fn take_overlay_pushes(&mut self) -> Vec<Box<dyn Overlay<M> + Send>>

Takes all pending overlay pushes.

pub fn take_overlay_pops(&mut self) -> usize

Takes the count of pending overlay pops and resets the counter.

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 CommandHandler<M>

fn default() -> Self

Returns the “default value” for a type.