Struct TelemetryBus 

pub struct TelemetryBus { /* private fields */ }

Cheap-to-clone broadcast bus. Wraps a tokio::sync::broadcast sender plus a slot for attached exporters (synchronous callbacks).

Implementations

impl TelemetryBus

pub fn new(capacity: usize) -> Self

pub fn publish(&self, event: TelemetryEvent)

pub fn subscribe(&self) -> Receiver<TelemetryEvent>

pub fn subscribe_topic( &self, wanted: &'static str, ) -> UnboundedReceiver<TelemetryEvent>

Subscribe to a single topic. The returned receiver yields only events whose topic() matches wanted. Backed by a forwarder task that filters the broadcast stream — drop the receiver to stop the forwarder.

pub fn receiver_count(&self) -> usize

Trait Implementations

impl Clone for TelemetryBus

fn clone(&self) -> TelemetryBus

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.