Struct MediaBitrateCounter 

pub(super) struct MediaBitrateCounter {
    origin: Instant,
    window_start_nanos: AtomicU64,
    last_observed_nanos: AtomicU64,
    bytes_in_window: AtomicU64,
    completed_bps: AtomicU64,
    observed: AtomicBool,
}

Fields

origin: Instant

window_start_nanos: AtomicU64

last_observed_nanos: AtomicU64

bytes_in_window: AtomicU64

completed_bps: AtomicU64

observed: AtomicBool

Implementations

impl MediaBitrateCounter

pub(super) fn new(now: Instant) -> Self

pub(super) fn record( &self, now: Instant, payload_bytes: usize, ) -> IncomingBitrateObservation

The packet loop is the only writer. Cross-thread readers consume the completed sample and freshness atomics, never the in-progress byte bucket.

Exact saturating addition is not part of the observable contract because one RTP bitrate window cannot approach u64::MAX.

pub(super) fn last_observed_age(&self, now: Instant) -> Option<Duration>

fn snapshot(&self, now: Instant) -> Bitrate

fn nanos_since_origin(&self, now: Instant) -> u64

Trait Implementations

impl Debug for MediaBitrateCounter

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

Formats the value using the given formatter.