Struct EventTypeRouter 

pub struct EventTypeRouter { /* private fields */ }

Direct event-type-to-channel router for non-blocking dispatch.

Maps event_type → Sender<ContextMessage> directly (single HashMap lookup), uses try_send() for non-blocking dispatch, and is cheaply cloneable via Arc<HashMap> for multi-producer scenarios.

Implementations

impl EventTypeRouter

pub fn dispatch(&self, event: SharedEvent) -> Result<(), DispatchError>

Non-blocking dispatch via try_send().

Routes the event to the correct context channel based on event type. Returns immediately without waiting for channel capacity.

pub async fn dispatch_await(&self, event: SharedEvent) -> Result<(), String>

Blocking dispatch via send().await.

Waits for channel capacity if the channel is full.

pub fn dispatch_batch(&self, events: Vec<SharedEvent>) -> Vec<DispatchError>

Batch dispatch — non-blocking, returns errors for any events that could not be sent.

Trait Implementations

impl Clone for EventTypeRouter

fn clone(&self) -> EventTypeRouter

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventTypeRouter

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.