Trait hyper_static_server::tokio::io::AsyncBufRead

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

Reads bytes asynchronously.

This trait is analogous to std::io::BufRead, 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.

Utilities for working with AsyncBufRead values are provided by AsyncBufReadExt.

Required methods

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

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

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

Loading content...

Implementations on Foreign Types

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

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

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

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

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

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

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

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

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

impl<'_> AsyncBufRead for &'_ [u8]

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

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

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

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

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

impl<L, R> AsyncBufRead for Either<L, R> where
    R: AsyncBufRead,
    L: AsyncBufRead, 

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

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

Loading content...

Implementors

impl AsyncBufRead for Empty

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

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

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

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

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

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

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

impl<RW> AsyncBufRead for BufStream<RW> where
    RW: AsyncRead + AsyncWrite, 

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

pub fn consume(self: Pin<&mut BufStream<RW>>, amt: usize)

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

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

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

Loading content...