Struct RecvStreamAsyncStreamReader 

pub struct RecvStreamAsyncStreamReader<R>(/* private fields */);

Implementations

impl<R: RecvStream> RecvStreamAsyncStreamReader<R>

pub fn new(inner: R) -> Self

pub fn into_inner(self) -> R

Trait Implementations

impl<R: RecvStream> AsyncStreamReader for RecvStreamAsyncStreamReader<R>

async fn read_bytes(&mut self, len: usize) -> Result<Bytes>

Read at most len bytes. To read to the end, pass u64::MAX.

async fn read<const L: usize>(&mut self) -> Result<[u8; L]>

Read a fixed size buffer.

fn read_bytes_exact( &mut self, len: usize, ) -> impl Future<Output = Result<Bytes, Error>>

Variant of read_bytes that returns an error if less than len bytes are read.

fn read_exact<const L: usize>( &mut self, ) -> impl Future<Output = Result<[u8; L], Error>>

Variant of read that returns an error if less than L bytes are read.

impl<R: Debug> Debug for RecvStreamAsyncStreamReader<R>

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

Formats the value using the given formatter.