Struct EventBus 

pub struct EventBus { /* private fields */ }

Routes proxy events to multiple sinks via a bounded async channel.

The proxy hot path calls emit() which does a non-blocking channel send. A background tokio task reads from the channel and fans out to all sinks.

Implementations

impl EventBus

pub fn emit(&self, event: ProxyEvent)

Emit a proxy event. Non-blocking — drops the event if the channel is full (never blocks the proxy request path).

Trait Implementations

impl Clone for EventBus

fn clone(&self) -> EventBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.