Struct ReadAtCursor 

pub struct ReadAtCursor { /* private fields */ }

Drives a stage over a random-access source.

Sequential requests read forward into a driver-owned window (a short read marks the end of the source; ReadAt::len is called only when the stage asks for the length). Range requests are coalesced (DriveOptions::max_gap) and fetched with one read_many_at per round, so a concurrent source overlaps their round trips; later ranges of the same round are served from the fetched buffers. A source already in memory (ReadAt::as_slice) is driven without copying.

Implementations

impl ReadAtCursor

pub fn new(opts: DriveOptions) -> Self

A cursor with the given read sizes.

pub fn stats(&self) -> DriveStats

Steps, reads and bytes read so far.

pub fn retained_input_capacity(&self) -> usize

Retained driver-owned payload capacity; borrowed source bytes are excluded.

pub fn next<S, Src>( &mut self, source: &mut Src, stage: &mut S, pulse: Option<&dyn Pulse>, ) -> Result<Yield<<S as ByteStepper>::Output>, DriveFailure<<S as ByteStepper>::Error, Src::Error>>

where S: ByteStepper + ?Sized, Src: ReadAt + ?Sized,

Step stage over source until it produces an output. Pass the same source on every call.

Trait Implementations

impl Debug for ReadAtCursor

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

Formats the value using the given formatter.