Struct EventEmitter 

pub struct EventEmitter { /* private fields */ }

Event bus. One instance per session.

Implementations

impl EventEmitter

pub fn new() -> Self

pub fn with_capacity(capacity: usize) -> Self

pub fn subscribe(&self) -> BoxStream<'static, AgentEvent>

Subscribes a new listener. The returned stream ends naturally when Self is dropped.

pub async fn emit(&self, event: AgentEvent)

Delivers the event to every subscriber.

Awaits each sender serially. If a subscriber’s channel is full, this call blocks until the subscriber consumes — this is intentional backpressure.

Trait Implementations

impl Default for EventEmitter

fn default() -> Self

Returns the “default value” for a type.