Struct EventBus 

pub struct EventBus {
    sender: Sender<MemoryEvent>,
}

Central event bus for broadcasting memory events.

Fields

sender: Sender<MemoryEvent>

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

Creates a new event bus with the given buffer capacity.

pub fn publish(&self, event: MemoryEvent)

Publishes an event to all subscribers (best effort).

pub fn subscribe(&self) -> Receiver<MemoryEvent>

Subscribes to the event bus.

pub fn subscribe_filtered<F>(&self, predicate: F) -> FilteredReceiver<F>

where F: Fn(&MemoryEvent) -> bool,

Subscribes with a predicate to filter events by type or attributes.

pub fn subscribe_event_type( &self, event_type: &'static str, ) -> FilteredReceiver<impl Fn(&MemoryEvent) -> bool>

Subscribes to events matching the provided event type.

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.