Struct compio_io::util::Take

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

Read up to a limit number of bytes from reader.

Implementations

impl<T> Take<T>

pub fn limit(&self) -> u64

Returns the number of bytes that can be read before this instance will return EOF.

Note

This instance may reach EOF after reading fewer bytes than indicated by this method if the underlying AsyncRead instance reaches EOF.

pub fn set_limit(&mut self, limit: u64)

Sets the number of bytes that can be read before this instance will return EOF. This is the same as constructing a new Take instance, so the amount of bytes read and the previous limit value don’t matter when calling this method.

pub fn into_inner(self) -> T

Consumes the Take, returning the wrapped reader.

pub fn get_ref(&self) -> &T

Gets a reference to the underlying reader.

pub fn get_mut(&mut self) -> &mut T

Gets a mutable reference to the underlying reader.

Care should be taken to avoid modifying the internal I/O state of the underlying reader as doing so may corrupt the internal limit of this Take.

Trait Implementations

impl<R: AsyncBufRead> AsyncBufRead for Take<R>

async fn fill_buf(&mut self) -> Result<&[u8]>

Try fill the internal buffer with data

fn consume(&mut self, amount: usize)

Mark how much data is read

impl<R: AsyncRead> AsyncRead for Take<R>

async fn read<B: IoBufMut>(&mut self, buf: B) -> BufResult<usize, B>

Read some bytes from this source into the IoBufMut buffer and return a BufResult, consisting of the buffer and a usize indicating how many bytes were read.

async fn read_vectored<V: IoVectoredBufMut>( &mut self, buf: V, ) -> BufResult<usize, V>

Like read, except that it reads into a type implements IoVectoredBufMut.

impl<R: Debug> Debug for Take<R>

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

Formats the value using the given formatter.