Struct EventEmitter 

pub struct EventEmitter {
    pub max_workers: usize,
    /* private fields */
}

Manages event subscribers and dispatches events.

Fields

max_workers: usize

Implementations

impl EventEmitter

pub fn new() -> EventEmitter

Create a new event emitter.

pub fn subscribe(&mut self, subscriber: Box<dyn EventSubscriber>)

Add a subscriber (matching Python’s void return signature).

pub fn unsubscribe(&mut self, subscriber: &dyn EventSubscriber) -> bool

Remove the first subscriber whose subscriber_id() matches the given subscriber’s ID, matching Python’s identity-based removal semantics.

pub fn unsubscribe_by_id(&mut self, subscriber_id: &str) -> bool

Remove the first subscriber whose subscriber_id() matches the given ID string.

pub async fn emit(&self, event: &ApCoreEvent) -> Result<(), ModuleError>

Emit an event to all subscribers whose pattern matches the event type.

Errors from individual subscribers are logged but not propagated (error isolation), matching Python’s behaviour.

pub async fn emit_filtered( &self, event: &ApCoreEvent, pattern: &str, ) -> Result<(), ModuleError>

Emit an event to subscribers matching both the caller’s filter pattern AND the subscriber’s own event_pattern.

pub async fn flush(&self, _timeout_ms: u64) -> Result<(), ModuleError>

Flush all pending events, waiting up to timeout_ms milliseconds.

Trait Implementations

impl Debug for EventEmitter

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

Formats the value using the given formatter.

impl Default for EventEmitter

fn default() -> EventEmitter

Returns the “default value” for a type.