Struct RecvStream 

pub struct RecvStream { /* private fields */ }

The receive half of a multiplexed stream.

Trait Implementations

impl Drop for RecvStream

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl RecvStream for RecvStream

type Error = Error

async fn read_chunk( &mut self, max: usize, ) -> Result<Option<Bytes>, <RecvStream as RecvStream>::Error>

Read the next chunk of data, up to the max size.

async fn read_buf<B>( &mut self, buf: &mut B, ) -> Result<Option<usize>, <RecvStream as RecvStream>::Error>

where B: BufMut + Send,

Read some data into the provided buffer.

async fn read( &mut self, buf: &mut [u8], ) -> Result<Option<usize>, <RecvStream as RecvStream>::Error>

Read the next chunk of data, up to the max size.

fn stop(&mut self, code: u32)

Send a STOP_SENDING QUIC code, informing the peer that no more data will be read.

async fn closed(&mut self) -> Result<(), <RecvStream as RecvStream>::Error>

Block until the stream has been closed by either side.

fn read_all( &mut self, ) -> impl Future<Output = Result<Bytes, Self::Error>> + MaybeSend

A helper to keep reading until the stream is closed.

fn read_all_buf<B>( &mut self, buf: &mut B, ) -> impl Future<Output = Result<usize, Self::Error>> + MaybeSend

where B: BufMut + MaybeSend,

A helper to keep reading until the buffer is full.