Struct AsyncReadSource 

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

A sequential AsyncSource over any AsyncRead (an HTTP body, a socket). Reads ahead of the stream position skip forward; reads behind it fail with SourceError::BeyondWindow, and the length is known only once the stream has ended.

Implementations

impl<R> AsyncReadSource<R>

pub fn new(reader: R) -> Self

Wrap reader, positioned at offset 0.

Trait Implementations

impl<R: AsyncRead + Unpin + Send> AsyncSource for AsyncReadSource<R>

async fn read_at( &mut self, offset: u64, out: &mut [u8], ) -> Result<usize, BoxedError>

Read up to out.len() bytes at offset into out and return the count. Like AsyncRead, a read may return fewer bytes than asked: whatever has arrived, so a decoder can start on it. Zero means the source ends at offset.

fn len_hint(&self) -> Option<u64>

Total length if known without reading ahead.

async fn len(&mut self) -> Result<u64, BoxedError>

Total length. Sequential sources can only answer once they reached the end; they return an error before that.

fn read_ranges( &mut self, reqs: &mut [(u64, &mut [u8])], ) -> impl Future<Output = Result<(), BoxedError>> + Send

Fill each buffer from its offset. Sources that can serve ranges concurrently (HTTP/2, object stores) override this to overlap them; the default reads them one after another.

impl<R: Debug> Debug for AsyncReadSource<R>

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

Formats the value using the given formatter.