Struct RateEstimator 

pub struct RateEstimator { /* private fields */ }

Rolling window of (timestamp, cumulative bytes) observations.

Implementations

impl RateEstimator

pub fn new() -> Self

pub fn observe(&mut self, at_ms: u64, bytes: u64)

Records a cumulative byte count seen at at_ms (any monotonic millisecond clock; only differences matter).

Two inputs are rejected rather than trusted: a sample older than the newest one (a non-monotonic clock would otherwise produce a negative span), and a byte count below the newest one, which means the transfer restarted – averaging across that discontinuity would report a rate that never happened, so the window is cleared and measurement starts over.

pub fn reset(&mut self)

Clears the window; the next report is warming again. For a job that pauses, where the elapsed idle time would otherwise be charged against the rate.

pub fn bytes_done(&self) -> Option<u64>

Latest observed cumulative byte count, if any.

pub fn report(&self, total_bytes: Option<u64>) -> RateReport

total_bytes is optional because plenty of real downloads have no Content-Length; without it there is a rate but no ETA, and the UI should show exactly that rather than a fabricated one.

Trait Implementations

impl Clone for RateEstimator

fn clone(&self) -> RateEstimator

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RateEstimator

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

Formats the value using the given formatter.

impl Default for RateEstimator

fn default() -> RateEstimator

Returns the “default value” for a type.