Struct SubMonitorCell 

pub struct SubMonitorCell {
    pub max_age_ms: AtomicU32,
}

One contracted subscriber’s take-age accumulator (W3b.5). The take path records epoch_now - header.stamp per message (fetch_max); the age check drains it (swap 0) per window.

Fields

max_age_ms: AtomicU32

Max observed take-age (ms) in the current check window.

Implementations

impl SubMonitorCell

pub const fn new() -> SubMonitorCell

pub fn observe(&self, stamp_us: u64, epoch_now_us: u64)

Take-path hook: record one message’s age. stamp_us is the peeked header.stamp as µs since the UNIX epoch, epoch_now_us the receive-side wall clock. A stamp from the future clamps to 0.

Trait Implementations

impl Debug for SubMonitorCell

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for SubMonitorCell

fn default() -> SubMonitorCell

Returns the “default value” for a type.