pub(crate) fn sysinfo_stream(
broker: Arc<Broker>,
since: Option<i64>,
lease: FeedLease,
timing: SysinfoTiming,
) -> impl Stream<Item = Result<Bytes, Infallible>> + Send + 'staticExpand description
The kept samples after since (all of them with none), then each new
one; a heartbeat when nothing new came for timing.heartbeat. Ends when
the device is revoked or goes away.