Struct RecvStream 

pub struct RecvStream { /* private fields */ }

A stream for receiving data using QUIC

Implementations

impl RecvStream

pub fn new(id: String, recv: RecvStream) -> Self

Creates a new RecvStream with the given ID and QUIC receive stream

Arguments

• id - Unique identifier for this stream
• recv - The underlying QUIC receive stream

pub fn id(&self) -> &str

Returns the ID of this stream

pub async fn is_closed(&self) -> bool

Checks if the stream is closed

pub async fn close(&self)

Marks the stream as closed

pub async fn recv(&self) -> Result<Bytes, Error>

Receives the next frame from the stream

Returns

• Ok(Bytes) containing the frame payload if successful
• Err if there was an error reading

pub async fn recv_exact(&self, _: usize) -> Result<Bytes, Error>

Receives a frame of exact size from the stream

Arguments

• _ - Expected size of frame (currently unused)

Returns

• Ok(Bytes) containing the frame payload if successful
• Err if there was an error reading

pub async fn recv_config_frame(&self) -> Result<Bytes, Error>

Receives a configuration frame from the stream

Returns

• Ok(Bytes) containing the configuration data if successful
• Err if there was an error reading

pub async fn recv_message(&self) -> Result<Message, Error>

Receives a message from the stream

Returns

• Ok(Message) if successful
• Err if there was an error reading