Skip to main content

telemetry_channel

Function telemetry_channel 

Source
pub fn telemetry_channel<T, S: Copy + PartialEq>(
    capacity: NonZeroUsize,
    status: S,
) -> (TelemetryPublisher<T, S>, TelemetryReader<T, S>)
Expand description

Creates a preallocated circular delivery buffer and independent status slot.

The publisher and reader are deliberately not cloneable. Use T for your typed frame (including its session identity) and a small Copy type for receiver status. An initial status notification is available immediately.