Struct AsyncDispatcher 

pub struct AsyncDispatcher { /* private fields */ }

Asynchronous event dispatcher for agent systems.

The dispatcher manages a queue of events and routes them to registered agents via a router. It runs in a background task and can be stopped gracefully.

Examples

use mojentic::async_dispatcher::AsyncDispatcher;
use mojentic::router::Router;

let router = Arc::new(Router::new());
let mut dispatcher = AsyncDispatcher::new(router);

dispatcher.start().await.unwrap();
dispatcher.dispatch(my_event);
dispatcher.wait_for_empty_queue(Some(Duration::from_secs(10))).await.unwrap();
dispatcher.stop().await.unwrap();

Implementations

impl AsyncDispatcher

pub fn new(router: Arc<Router>) -> Self

Create a new AsyncDispatcher.

Arguments

• router - The router to use for routing events to agents

pub fn with_batch_size(self, size: usize) -> Self

Set the batch size (number of events to process per iteration).

Arguments

• size - The batch size

pub async fn start(&mut self) -> Result<()>

Start the event dispatch task.

This spawns a background task that processes events from the queue.

pub async fn stop(&mut self) -> Result<()>

Stop the event dispatch task.

This signals the background task to stop and waits for it to complete.

pub fn dispatch(&self, event: Box<dyn Event>)

Dispatch an event to the queue.

The event will be processed asynchronously by the background task.

Arguments

• event - The event to dispatch

pub async fn wait_for_empty_queue( &self, timeout: Option<Duration>, ) -> Result<bool>

Wait for the event queue to become empty.

Arguments

• timeout - Optional timeout duration

Returns

true if the queue is empty, false if timeout was reached

pub async fn queue_len(&self) -> usize

Get the current queue length.

Trait Implementations

impl Drop for AsyncDispatcher

fn drop(&mut self)

Executes the destructor for this type.