Struct LoopState 

pub struct LoopState {
    pub total_bytes: Arc<AtomicU64>,
    pub peak_bps: Arc<AtomicU64>,
    pub speed_samples: Arc<Mutex<Vec<f64>>>,
    pub start: Instant,
    pub last_sample_ms: Arc<AtomicU64>,
    pub estimated_total: u64,
    pub progress: Arc<Tracker>,
}

Shared state for a bandwidth test (download or upload).

All fields are thread-safe for use across multiple concurrent streams.

Fields

total_bytes: Arc<AtomicU64>

peak_bps: Arc<AtomicU64>

speed_samples: Arc<Mutex<Vec<f64>>>

start: Instant

last_sample_ms: Arc<AtomicU64>

estimated_total: u64

progress: Arc<Tracker>

Implementations

impl LoopState

pub fn new(estimated_total: u64, progress: Arc<Tracker>) -> Self

Create a new bandwidth measurement state.

pub fn record_bytes(&self, len: u64, sample_interval_ms: u64)

Record transferred bytes and update progress (throttled to 20 Hz).

This is the single point where all expensive operations (bandwidth calc, peak tracking, sample recording, progress update) are throttled.

Note: Uses cached sample_interval to avoid repeated TestConfig::default() calls.

pub fn finish(&self) -> BandwidthResult

Compute final results from accumulated state.