Struct smol::io::Take

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

Reader for the AsyncReadExt::take() method.

Implementations

impl<R> Take<R>

pub fn limit(&self) -> u64

Returns the number of bytes before this adapter will return EOF.

Note that EOF may be reached sooner if the underlying reader is shorter than the limit.

Examples

use futures_lite::io::{AsyncReadExt, Cursor};

let reader = Cursor::new("hello");

let reader = reader.take(3);
assert_eq!(reader.limit(), 3);

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

Puts a limit on the number of bytes.

Changing the limit is equivalent to creating a new adapter with AsyncReadExt::take().

Examples

use futures_lite::io::{AsyncReadExt, Cursor};

let reader = Cursor::new("hello");

let mut reader = reader.take(10);
assert_eq!(reader.limit(), 10);

reader.set_limit(3);
assert_eq!(reader.limit(), 3);

pub fn get_ref(&self) -> &R

Gets a reference to the underlying reader.

Examples

use futures_lite::io::{AsyncReadExt, Cursor};

let reader = Cursor::new("hello");

let reader = reader.take(3);
let r = reader.get_ref();

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

Gets a mutable reference to the underlying reader.

Examples

use futures_lite::io::{AsyncReadExt, Cursor};

let reader = Cursor::new("hello");

let mut reader = reader.take(3);
let r = reader.get_mut();

pub fn into_inner(self) -> R

Unwraps the adapter, returning the underlying reader.

Examples

use futures_lite::io::{AsyncReadExt, Cursor};

let reader = Cursor::new("hello");

let reader = reader.take(3);
let reader = reader.into_inner();

Trait Implementations

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

pub fn poll_fill_buf(
    self: Pin<&mut Take<R>>,
    cx: &mut Context<'_>
) -> Poll<Result<&[u8], Error>>

Attempt to return the contents of the internal buffer, filling it with more data from the inner reader if it is empty.

pub fn consume(self: Pin<&mut Take<R>>, amt: usize)

Tells this buffer that amt bytes have been consumed from the buffer, so they should no longer be returned in calls to poll_read.

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

pub fn poll_read(
    self: Pin<&mut Take<R>>,
    cx: &mut Context<'_>,
    buf: &mut [u8]
) -> Poll<Result<usize, Error>>

Attempt to read from the AsyncRead into buf.

pub 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.

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

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

Formats the value using the given formatter.

impl<'__pin, R> Unpin for Take<R> where
    __Origin<'__pin, R>: Unpin,