Struct EventHubClient 

pub struct EventHubClient { /* private fields */ }

EventHubClient - handles event passing from backend to UI Subscribe callbacks to specific event origins and start the event loop.

Implementations

impl EventHubClient

pub fn new(event_hub: &EventHub) -> Self

Create a new event hub client

pub fn subscribe<F>(&self, origin: Origin, callback: F) -> SubscriptionToken

where F: Fn(Event) + Send + 'static,

Subscribe a callback to an origin. The returned SubscriptionToken removes the callback from the subscribers map when dropped — hold it for as long as you want the callback to fire, then drop it to unsubscribe.

pub fn start(&self, shutdown_rx: Receiver<()>)

Start the event loop in a background thread.

The thread blocks on a flume::Selector that waits on either an incoming event or the shutdown receiver. Zero CPU while idle — no polling, no timeout. The thread exits when the matching shutdown Sender is dropped (which makes shutdown_rx Disconnected) or when the event hub’s sender drops.

Trait Implementations

impl Clone for EventHubClient

fn clone(&self) -> EventHubClient

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.