Struct EventHub 

pub struct EventHub { /* private fields */ }

Central event hub for managing subscriptions and dispatching events

Implementations

impl EventHub

pub fn new() -> Self

Create a new event hub

pub fn start_event_loop(&self, stop_signal: Arc<AtomicBool>) -> JoinHandle<()>

Start the event processing loop.

Returns a JoinHandle so the caller can join the thread on shutdown. The loop checks stop_signal between receives via a timeout, ensuring it will exit even if no events arrive.

pub fn send_event(&self, event: Event)

Send an event to the queue

pub fn get_queue(&self) -> Queue

pub fn subscribe_receiver(&self) -> Receiver<Event>

Get a direct event receiver.

The receiver blocks on recv() until an event arrives — no polling needed. Important: flume uses MPMC semantics — each event is delivered to exactly one receiver. Multiple cloned receivers compete for events rather than each receiving a copy. Ensure only one consumer calls subscribe_receiver().

Trait Implementations

impl Default for EventHub

fn default() -> Self

Returns the “default value” for a type.