Struct ara::range_reader::RangeReader

pub struct RangeReader<R> where
    R: ReadAt,  { /* fields omitted */ }

Exposes a section of a ReadAt as an AsyncRead

Implementations

impl<R> RangeReader<R> where
    R: ReadAt + Unpin + 'static, 

pub const DEFAULT_BUF_LEN: usize

pub fn new(inner: R, range: Range<u64>) -> Result<Self, Error>

Create a new instance with the default buffer length (1 KiB)

pub fn with_buf_len(
    inner: R,
    range: Range<u64>,
    buf_len: usize
) -> Result<Self, Error>

Create a new instance with a specified buffer length

Trait Implementations

impl<R> AsyncRead for RangeReader<R> where
    R: ReadAt + Unpin + 'static, 

fn poll_read(
    self: Pin<&mut Self>,
    cx: &mut Context,
    buf: &mut [u8]
) -> Poll<Result<usize>>

Attempt to read from the AsyncRead into buf.

fn poll_read_vectored(
    self: Pin<&mut Self>,
    cx: &mut Context,
    bufs: &mut [IoSliceMut]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into bufs using vectored IO operations.