Struct CommandExecutor 

pub struct CommandExecutor<M = ()> { /* private fields */ }

Executes commands and sends resulting messages

Implementations

impl<M> CommandExecutor<M>

where M: Clone + Send + 'static,

pub fn new() -> Result<Self>

Create a new command executor with default error handler

pub fn with_error_handler<H>(error_handler: H) -> Result<Self>

where H: ErrorHandler<M> + Send + Sync + 'static,

Create a new command executor with custom error handler

pub fn with_resource_limits(limits: ResourceLimits) -> Result<Self>

Create a new command executor with custom resource limits

pub fn resource_stats(&self) -> ResourceStats

Get current resource statistics

pub fn execute(&self, cmd: Cmd<M>, tx: &SyncSender<Event<M>>)

Execute a command and send the result through the channel

pub fn execute_batch(&self, commands: Vec<Cmd<M>>, tx: &SyncSender<Event<M>>)

Execute a batch of commands concurrently

pub fn execute_sequence(&self, commands: Vec<Cmd<M>>, tx: &SyncSender<Event<M>>)

Execute a sequence of commands (one after another)

pub fn spawn<F>(&self, future: F) -> JoinHandle<F::Output>

where F: Future + Send + 'static, F::Output: Send + 'static,

Spawn a future on the runtime with resource limit checking

pub fn block_on<F: Future>(&self, future: F) -> F::Output

Block on the runtime to ensure all tasks complete (for testing)

Trait Implementations

impl<M: Clone> Clone for CommandExecutor<M>

fn clone(&self) -> CommandExecutor<M>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<M> Default for CommandExecutor<M>

where M: Clone + Send + 'static,

fn default() -> Self

Returns the “default value” for a type.