Struct WebTransportRecvStream

pub struct WebTransportRecvStream { /* private fields */ }

Available on (crate features http1 or http2 or http3) and crate feature http3 and crate feature webtransport only.

A receive-only WebTransport stream.

Implementations

impl WebTransportRecvStream

pub fn into_inner(self) -> WtRecvStream<RecvStream, Bytes>

Get the inner h3_webtransport::stream::RecvStream.

Can be used to access lower-level functionality.

pub async fn read(&mut self) -> Result<Option<Bytes>, StreamErrorIncoming>

Read data from the stream.

Returns Ok(None) when the stream is finished.

Example

while let Ok(Some(data)) = recv_stream.read().await {
    println!("Received {} bytes", data.len());
}

pub async fn read_to_end(&mut self, max_size: usize) -> Result<Bytes, Error>

Read all remaining data from the stream until it’s finished.

This collects all chunks into a single Bytes object.

Returns an io::Error if the total size exceeds max_size or any read call errors.

Example

let data = recv_stream.read_to_end(1024 * 1024).await?; // max 1MB
println!("Received complete message: {} bytes", data.len());

pub fn stop_sending(&mut self, error_code: u64)

Stop receiving data on this stream with an error code.

Trait Implementations

impl Debug for WebTransportRecvStream

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

Formats the value using the given formatter.