Struct webtransport_quinn::RecvStream

pub struct RecvStream { /* private fields */ }

A stream that can be used to recieve bytes. See quinn::RecvStream.

Implementations

impl RecvStream

pub fn stop(&mut self, code: u32) -> Result<(), UnknownStream>

Tell the other end to stop sending data with the given error code. See quinn::RecvStream::stop. This is a u32 with WebTransport since it shares the error space with HTTP/3.

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

Read some data into the buffer and return the amount read. See quinn::RecvStream::read.

pub async fn read_exact(&mut self, buf: &mut [u8]) -> Result<(), ReadExactError>

Fill the entire buffer with data. See quinn::RecvStream::read_exact.

pub async fn read_chunk( &mut self, max_length: usize, ordered: bool ) -> Result<Option<Chunk>, ReadError>

Read a chunk of data from the stream. See quinn::RecvStream::read_chunk.

pub async fn read_chunks( &mut self, bufs: &mut [Bytes] ) -> Result<Option<usize>, ReadError>

Read chunks of data from the stream. See quinn::RecvStream::read_chunks.

pub async fn read_to_end( &mut self, size_limit: usize ) -> Result<Vec<u8>, ReadToEndError>

Read until the end of the stream or the limit is hit. See quinn::RecvStream::read_to_end.

Trait Implementations

impl AsyncRead for RecvStream

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_> ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl Debug for RecvStream

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

Formats the value using the given formatter.

impl RecvStream for RecvStream

fn close(self, code: u32)

Send a STOP_SENDING QUIC code.

type Error = ReadError

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

Attempt to read from the stream into the given buffer.

fn poll_read_chunk( &mut self, cx: &mut Context<'_> ) -> Poll<Result<Option<Bytes>, Self::Error>>

Attempt to write the given buffer to the stream.

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

where B: BufMut + Send,

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