Struct FramedSendStream 

pub struct FramedSendStream {
    inner: SendStream,
}

A framed writer for a send stream. Handles MoQT length-prefixed framing.

Fields

inner: SendStream

Implementations

impl FramedSendStream

pub fn new(inner: SendStream) -> Self

Create a new framed send stream.

pub fn stream_id(&self) -> u64

Get the transport-level stream ID.

pub async fn write_control( &mut self, msg: &AnyControlMessage, ) -> Result<Vec<u8>, ConnectionError>

Write a control message to the stream with type+length framing. Returns the raw bytes that were written (for event capture).

pub async fn write_subgroup_header( &mut self, header: &AnySubgroupHeader, ) -> Result<(), ConnectionError>

Write a subgroup stream header.

pub async fn write_fetch_header( &mut self, header: &AnyFetchHeader, ) -> Result<(), ConnectionError>

Write a fetch response header.

pub async fn write_subgroup_object( &mut self, object: &SubgroupObject, ) -> Result<(), ConnectionError>

Append a draft-08 subgroup object (header + payload) to the stream. Draft-08 subgroup objects are stateless — no header-dependent bookkeeping.

pub async fn write_fetch_object( &mut self, object: &FetchObject, ) -> Result<(), ConnectionError>

Append a draft-08 fetch object (header + payload) to the stream.

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

Finish the stream (send FIN).