Struct EventListener 

pub struct EventListener {
    pub id: ListenerId,
    /* private fields */
}

Represents a single event listener.

Uses an unbounded channel intentionally: flush() is called synchronously from the handler’s poll loop and cannot await a bounded channel’s back-pressure. Bounding the channel would require either dropping events (behaviour change) or making the flush path async (large refactor). Consumers that register a listener must poll the resulting EventStream to prevent unbounded growth.

Fields

id: ListenerId

Unique id for this listener (used for immediate removal).

Implementations

impl EventListener

pub fn start_send(&mut self, event: Arc<dyn Event>)

queue in a new event

pub fn flush(&mut self) -> Result<(), SendError<Arc<dyn Event>>>

Drains all queued events, sending them synchronously via the unbounded channel. Returns Err if the receiver has been dropped.

Trait Implementations

impl Debug for EventListener

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

Formats the value using the given formatter.