Struct FramedRecvStream 

pub struct FramedRecvStream { /* private fields */ }

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

Implementations

impl FramedRecvStream

pub fn new(inner: RecvStream) -> Self

Create a new framed receive stream.

pub fn stream_id(&self) -> u64

Get the transport-level stream ID.

pub async fn read_control( &mut self, capture_raw: bool, ) -> Result<(AnyControlMessage, Option<Vec<u8>>), ConnectionError>

Read a control message from the stream.

When capture_raw is true, the returned tuple includes a clone of the framed wire bytes (for observer emission). When false, the second element is None and the payload clone is skipped.

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

Read a subgroup stream header.

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

Read a fetch response header.

pub async fn read_subgroup_object( &mut self, ) -> Result<SubgroupObject, ConnectionError>

Read the next draft-12 subgroup object (header + payload). The codec helper ObjectHeader::decode is called without extensions by default; callers that care about extensions should drive decoding explicitly.

pub async fn read_fetch_object( &mut self, ) -> Result<FetchObject, ConnectionError>

Read the next draft-12 fetch object (header + payload).