Struct ProgressThrottle 

pub struct ProgressThrottle {
    pub last_emitted_at_ms: i64,
    pub last_emitted_bytes: u64,
}

Tracks when the last progress event was emitted so emit_progress can apply the 250 ms / 256 KB throttle.

Instantiate one ProgressThrottle per transfer at the start of the stream loop and pass it mutably to each emit_progress call.

Fields

last_emitted_at_ms: i64

Millisecond timestamp of the last emitted event (0 = never).

last_emitted_bytes: u64

transferred_bytes value at the time of the last emitted event.

Implementations

impl ProgressThrottle

pub fn new() -> Self

Create a new throttle state. now_ms is the current time in ms.

pub fn should_emit(&self, now_ms: i64, bytes_done: u64) -> bool

Returns true when a progress event should be emitted now.

The gate opens when:

• no event has been emitted yet (last_emitted_at_ms == 0), OR
• at least 250 ms have elapsed since the last emission, OR
• at least 256 KB more have been transferred since the last emission.

pub fn record_emission(&mut self, now_ms: i64, bytes_done: u64)

Record that an event was just emitted.

Trait Implementations

impl Debug for ProgressThrottle

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

Formats the value using the given formatter.

impl Default for ProgressThrottle

fn default() -> Self

Returns the “default value” for a type.