Struct bindle::async_util::BodyReadBuffer

pub struct BodyReadBuffer<B, T, E>(pub T)
 where
    B: Buf,
    T: Stream<Item = Result<B, E>> + Unpin,
    E: Error;

A wrapper around a Warp stream of bytes that implements AsyncRead.

This might no longer be necessary once we hit tokio 0.3 and upgrade tokio-util. Tokio util has a StreamReader wrapper we can use, but there might still be some conversion stuff to deal with

Trait Implementations

impl<'a, B, T, E> AsyncRead for BodyReadBuffer<B, T, E> where
    B: Buf,
    T: Stream<Item = Result<B, E>> + Unpin,
    E: Error + Send + Sync + 'a, 

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

Attempts to read from the AsyncRead into buf.

pub unsafe fn prepare_uninitialized_buffer(
    &self,
    buf: &mut [MaybeUninit<u8>]
) -> bool

Prepares an uninitialized buffer to be safe to pass to read. Returns true if the supplied buffer was zeroed out.

pub fn poll_read_buf<B>(
    self: Pin<&mut Self>,
    cx: &mut Context<'_>,
    buf: &mut B
) -> Poll<Result<usize, Error>> where
    B: BufMut, 

Pulls some bytes from this source into the specified BufMut, returning how many bytes were read.