Struct SubscriberHandle 

pub struct SubscriberHandle {
    pub interval: Duration,
    last_sent_at: Mutex<Option<Instant>>,
    pub subscription_id: u64,
    sender: UnboundedSender<LiveMetrics>,
}

A handle to a single live-metrics subscription.

Wraps the sender half of a tokio unbounded MPSC channel along with the subscriber’s desired emission interval. The interval is stored so the IntrospectionStream can honor per-subscriber cadence when dispatching.

Fields

interval: Duration

Desired emission interval for this subscriber.

last_sent_at: Mutex<Option<Instant>>

Last time we forwarded a metric to this subscriber.

subscription_id: u64

Unique subscription identifier (for wire-protocol correlation and teardown).

sender: UnboundedSender<LiveMetrics>

Implementations

impl SubscriberHandle

pub fn subscription_id(&self) -> u64

Subscription identifier.

pub fn is_closed(&self) -> bool

Return true if the receiver has been dropped.

fn try_send(&self, metrics: LiveMetrics) -> Result<bool, ()>

Try to deliver a metric, respecting the subscriber’s interval gate.

Returns Ok(true) if delivered, Ok(false) if suppressed by the interval gate, and Err(()) if the receiver has dropped (the caller should discard the handle).