Struct SubscriberHandle 

pub struct SubscriberHandle {
    pub interval: Duration,
    last_sent_at: Mutex<RawMutex, 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<RawMutex, Option<Instant>>

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.