Struct AsyncCursor 

pub struct AsyncCursor { /* private fields */ }

Drives any ByteStepper from an AsyncSource: the async twin of ReadAtCursor.

Each next steps the stage on the calling task and awaits the source only when the stage needs bytes, so a container demuxer (cheap per step) streams packets from a socket or an object store without holding a thread during I/O and without becoming async itself. Range requests are coalesced and fetched with one AsyncSource::read_ranges per round. CPU-heavy stages (image decoders) use decode_async, which moves the work off the async runtime.

Implementations

impl AsyncCursor

pub fn new(opts: DriveOptions) -> Self

A cursor with the given read sizes.

pub fn retained_input_capacity(&self) -> usize

Retained driver-owned payload capacity, excluding source caches and outputs.

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

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

Step stage until it produces an output, awaiting source for every request. Pass the same source on every call.

Trait Implementations

impl Debug for AsyncCursor

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

Formats the value using the given formatter.