Struct FramedRecvStream 

pub struct FramedRecvStream {
    inner: RecvStream,
    buf: BytesMut,
}

A framed reader for a QUIC recv stream. Handles MoQT varint-length decoding.

Fields

inner: RecvStream

buf: BytesMut

Implementations

impl FramedRecvStream

pub fn new(inner: RecvStream) -> Self

async fn fill(&mut self) -> Result<bool, ConnectionError>

Read more data from the stream into the internal buffer.

async fn ensure(&mut self, n: usize) -> Result<(), ConnectionError>

Ensure at least n bytes are available in the buffer.

pub async fn read_control(&mut self) -> Result<ControlMessage, ConnectionError>

Read a control message from the stream.

pub async fn read_subgroup_header( &mut self, ) -> Result<SubgroupHeader, ConnectionError>

Read a subgroup stream header.

pub async fn read_fetch_header( &mut self, ) -> Result<FetchHeader, ConnectionError>

Read a fetch response header.

pub async fn read_object_header( &mut self, ) -> Result<ObjectHeader, ConnectionError>

Read an object header.

pub async fn read_payload( &mut self, n: usize, ) -> Result<Vec<u8>, ConnectionError>

Read exactly n bytes of object payload.