Struct EventStream 

pub struct EventStream { /* private fields */ }

A receiver that surfaces lag as data: when this consumer falls behind the bounded channel, the next recv yields the count of samples it missed — dropped samples are never invisible (RFC 05 §3.1’s honesty, applied to a UI).

Implementations

impl EventStream

pub fn into_stream(self) -> impl Stream<Item = StreamItem> + Send

The same items as a Stream (#343).

Consuming rather than borrowing, because the consumer that wanted this is a UI subscription that must own a 'static stream — a borrowing adapter could not be handed to one. Take a second EventStream from Monitor::events if the original is still needed for a recv loop; each receiver has its own place in the ring.

unfold rather than a hand-written poll_next: a broadcast receiver has no poll_recv, so a direct impl would have to store the borrowed recv future beside the receiver it borrows from — a self-referential struct, and unsafe for nothing. Lag still folds into the monitor’s dropped counter and still arrives as StreamItem::Dropped, since this drives the same recv that does both. A generic broadcast-to-stream adapter would surface lag as an error instead, which is the one thing this type exists to prevent.

pub async fn recv(&mut self) -> Option<StreamItem>

None when the monitor stopped.