Struct EventStream 

pub struct EventStream { /* private fields */ }

An async stream of events for one or more watchers. All session events flow through one broadcast channel; each EventStream filters to its subscribed watcher names, so merge is just a name union.

Implementations

impl EventStream

pub async fn next(&mut self) -> Option<Event>

Next event, or None when the session has shut down. If this consumer lags behind the broadcast buffer, missed events are skipped silently and the stream continues with the newest.

pub fn merge(self, other: EventStream) -> EventStream

Combine two streams into one that yields events from both.

Both streams must originate from the same Session: the merged stream keeps only self’s receiver and unions the name filters, which is correct because all of a session’s events flow through one broadcast channel. Merging streams from different sessions would silently drop the other session’s events.

Trait Implementations

impl Debug for EventStream

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

Formats the value using the given formatter.