Struct LimitedReader

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

Wraps a reader and limits the number of bytes that can be read from it. Once the limit has been reached, further calls to poll_read will return Ok(Ready(0)).

Implementations

impl<R> LimitedReader<R>

pub fn new(inner: R, limit: usize) -> LimitedReader<R>

Create a new LimitedReader, wrapping the given reader.

Trait Implementations

impl<R: AsyncRead> AsyncRead for LimitedReader<R>

fn poll_read( &mut self, cx: &mut Context<'_>, buf: &mut [u8], ) -> Poll<usize, FutIoErr>

Attempt to read from the AsyncRead into buf.

unsafe fn initializer(&self) -> Initializer

Determines if this AsyncReader can work with buffers of uninitialized memory.

fn poll_vectored_read( &mut self, cx: &mut Context<'_>, vec: &mut [&mut IoVec], ) -> Result<Async<usize>, Error>

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