Struct PositionReader 

pub struct PositionReader<R: PositionRead> { /* private fields */ }

PositionReader implements oio::Read based on PositionRead.

Implementations

impl<R: PositionRead> PositionReader<R>

pub fn new(inner: R) -> Self

Create a new PositionReader.

pub fn with_max_buf_size(self, buf_size: usize) -> Self

Set the maximum buffer size used by PositionReader.

pub fn into_inner(self) -> R

Consume the reader and return the inner PositionRead.

Panics

Panics if there are active streams that still share the inner reader.

Trait Implementations

impl<R: PositionRead> Read for PositionReader<R>

async fn open( &self, range: BytesRange, ) -> Result<(RpRead, Box<dyn ReadStreamDyn>)>

Open a range stream for the given range.

async fn read(&self, range: BytesRange) -> Result<(RpRead, Buffer)>

Read an exact bounded range into Buffer.