Struct EventHub 

pub struct EventHub { /* private fields */ }

Publish/subscribe fan-out for ClientEvent values.

EventHub is used by managed sessions internally and is also exported for callers that want the same bounded subscription behavior around their own event producer. Publishing clones each event once per subscriber.

Implementations

impl EventHub

pub fn new() -> Self

Create an empty event hub with no subscribers.

pub fn subscribe( &self, config: SubscriberConfig, ) -> Result<EventSubscription, ClientError>

Register a new subscriber with its own bounded queue.

Returns an error when config.capacity is zero.

pub fn publish(&self, event: ClientEvent)

Publish an event to all currently connected subscribers.

Slow subscribers are handled according to their SubscriberOverflow policy. Publishing does not block waiting for a subscriber to consume queued events.

pub fn disconnect_all(&self)

Disconnect all subscribers after leaving their already queued events available to drain.

Trait Implementations

impl Clone for EventHub

fn clone(&self) -> EventHub

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for EventHub

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

Formats the value using the given formatter.

impl Default for EventHub

fn default() -> Self

Returns the “default value” for a type.