Struct CountingReader 

pub struct CountingReader<R> { /* private fields */ }

Wraps a reader and tallies how many ranges were requested and how many bytes were returned — the metric that matters for a range-streamed format. Atomically counted, so it stays Sync (a lazily-faulting remote index holds its reader behind a shared loader).

Implementations

impl<R: RangeReader> CountingReader<R>

pub fn new(inner: R) -> Self

pub fn requests(&self) -> u64

Number of read_at calls made so far.

pub fn bytes_read(&self) -> u64

Total bytes returned so far.

Trait Implementations

impl<R: RangeReader> RangeReader for CountingReader<R>

fn read_many(&self, ranges: &[(u64, u64)]) -> Result<Vec<Vec<u8>>>

Delegate to the inner reader (preserving its parallelism) and tally each returned range as one request — the count reflects the coalesced spans actually fetched, however the inner reader issues them.

fn len(&self) -> u64

Total resource length in bytes.

fn read_at(&self, offset: u64, len: u64) -> Result<Vec<u8>>

Read len bytes starting at offset. Implementations should error on an out-of-bounds range rather than truncating.

fn concurrency(&self) -> usize

How many ranges this reader can usefully have in flight at once — the planner’s hint for probe-vs-scan and batch-size decisions (a phone’s serial sync-XHR reader reports 1; the CLI’s threaded HTTP client and the browser’s concurrent-fetch variants report their fan-out). Purely advisory: correctness never depends on it. Defaults to 1 (sequential).

fn is_empty(&self) -> bool

True when the resource is empty.