Skip to main content

sysinfo_stream

Function sysinfo_stream 

Source
pub(crate) fn sysinfo_stream(
    broker: Arc<Broker>,
    since: Option<i64>,
    lease: FeedLease,
    timing: SysinfoTiming,
) -> impl Stream<Item = Result<Bytes, Infallible>> + Send + 'static
Expand 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.