Trait bevy::tasks::futures_lite::prelude::AsyncBufRead

pub trait AsyncBufRead: AsyncRead {
    // Required methods
    fn poll_fill_buf(
        self: Pin<&mut Self>,
        cx: &mut Context<'_>,
    ) -> Poll<Result<&[u8], Error>>;
    fn consume(self: Pin<&mut Self>, amt: usize);
}
Expand description

Read bytes asynchronously.

This trait is analogous to the std::io::BufRead trait, but integrates with the asynchronous task system. In particular, the poll_fill_buf method, unlike BufRead::fill_buf, will automatically queue the current task for wakeup and return if data is not yet available, rather than blocking the calling thread.

Required Methods§

fn poll_fill_buf( self: Pin<&mut Self>, 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.

On success, returns Poll::Ready(Ok(buf)).

If no data is available for reading, the method returns Poll::Pending and arranges for the current task (via cx.waker().wake_by_ref()) to receive a notification when the object becomes readable or is closed.

This function is a lower-level call. It needs to be paired with the consume method to function properly. When calling this method, none of the contents will be “read” in the sense that later calling poll_read may return the same contents. As such, consume must be called with the number of bytes that are consumed from this buffer to ensure that the bytes are never returned twice.

An empty buffer returned indicates that the stream has reached EOF.

§Implementation

This function may not return errors of kind WouldBlock or Interrupted. Implementations must convert WouldBlock into Poll::Pending and either internally retry or convert Interrupted into another error kind.

fn consume(self: Pin<&mut Self>, 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.

This function is a lower-level call. It needs to be paired with the poll_fill_buf method to function properly. This function does not perform any I/O, it simply informs this object that some amount of its buffer, returned from poll_fill_buf, has been consumed and should no longer be returned. As such, this function may do odd things if poll_fill_buf isn’t called before calling it.

The amt must be <= the number of bytes in the buffer returned by poll_fill_buf.

Implementations on Foreign Types§

§

impl AsyncBufRead for &[u8]

§

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

§

fn consume(self: Pin<&mut &[u8]>, amt: usize)

§

impl AsyncBufRead for Empty

§

fn poll_fill_buf<'a>( self: Pin<&'a mut Empty>, _: &mut Context<'_>, ) -> Poll<Result<&'a [u8], Error>>

§

fn consume(self: Pin<&mut Empty>, _: usize)

§

impl AsyncBufRead for Empty

§

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

§

fn consume(self: Pin<&mut Empty>, _: usize)

§

impl<A, B> AsyncBufRead for Either<A, B>

§

fn poll_fill_buf( self: Pin<&mut Either<A, B>>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8], Error>>

§

fn consume(self: Pin<&mut Either<A, B>>, amt: usize)

§

impl<P> AsyncBufRead for Pin<P>
where P: DerefMut + Unpin, <P as Deref>::Target: AsyncBufRead,

§

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

§

fn consume(self: Pin<&mut Pin<P>>, amt: usize)

§

impl<R1, R2> AsyncBufRead for Chain<R1, R2>
where R1: AsyncBufRead, R2: AsyncBufRead,

§

fn poll_fill_buf( self: Pin<&mut Chain<R1, R2>>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8], Error>>

§

fn consume(self: Pin<&mut Chain<R1, R2>>, amt: usize)

§

impl<R> AsyncBufRead for BufReader<R>
where R: AsyncRead,

§

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

§

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

§

impl<R> AsyncBufRead for BufReader<R>
where R: AsyncRead,

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

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

§

impl<St> AsyncBufRead for IntoAsyncRead<St>
where St: TryStream<Error = Error>, <St as TryStream>::Ok: AsRef<[u8]>,

§

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

§

fn consume(self: Pin<&mut IntoAsyncRead<St>>, amount: usize)

§

impl<T> AsyncBufRead for &mut T
where T: AsyncBufRead + Unpin + ?Sized,

§

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

§

fn consume(self: Pin<&mut &mut T>, amt: usize)

§

impl<T> AsyncBufRead for Box<T>
where T: AsyncBufRead + Unpin + ?Sized,

§

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

§

fn consume(self: Pin<&mut Box<T>>, amt: usize)

§

impl<T> AsyncBufRead for AllowStdIo<T>
where T: BufRead,

§

fn poll_fill_buf( self: Pin<&mut AllowStdIo<T>>, _: &mut Context<'_>, ) -> Poll<Result<&[u8], Error>>

§

fn consume(self: Pin<&mut AllowStdIo<T>>, amt: usize)

§

impl<T> AsyncBufRead for Cursor<T>
where T: AsRef<[u8]> + Unpin,

§

fn poll_fill_buf( self: Pin<&mut Cursor<T>>, _: &mut Context<'_>, ) -> Poll<Result<&[u8], Error>>

§

fn consume(self: Pin<&mut Cursor<T>>, amt: usize)

§

impl<T> AsyncBufRead for Cursor<T>
where T: AsRef<[u8]> + Unpin,

§

fn poll_fill_buf( self: Pin<&mut Cursor<T>>, _: &mut Context<'_>, ) -> Poll<Result<&[u8], Error>>

§

fn consume(self: Pin<&mut Cursor<T>>, amt: usize)

§

impl<T, U> AsyncBufRead for Chain<T, U>

§

fn poll_fill_buf( self: Pin<&mut Chain<T, U>>, cx: &mut Context<'_>, ) -> Poll<Result<&[u8], Error>>

§

fn consume(self: Pin<&mut Chain<T, U>>, amt: usize)

§

impl<W> AsyncBufRead for BufWriter<W>
where W: AsyncBufRead,

§

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

§

fn consume(self: Pin<&mut BufWriter<W>>, amt: usize)

Implementors§

§

impl AsyncBufRead for bevy::tasks::futures_lite::io::Empty

§

impl<R1, R2> AsyncBufRead for bevy::tasks::futures_lite::io::Chain<R1, R2>
where R1: AsyncBufRead, R2: AsyncBufRead,

§

impl<R> AsyncBufRead for bevy::tasks::futures_lite::io::BufReader<R>
where R: AsyncRead,

§

impl<R> AsyncBufRead for bevy::tasks::futures_lite::io::Take<R>
where R: AsyncBufRead,

§

impl<T> AsyncBufRead for bevy::tasks::futures_lite::io::Cursor<T>
where T: AsRef<[u8]> + Unpin,