Struct FramedSendStream 

pub struct FramedSendStream {
    inner: SendStream,
    draft: DraftVersion,
    subgroup_io: Option<SubgroupObjectReader>,
}

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

Fields

inner: SendStream

draft: DraftVersion

subgroup_io: Option<SubgroupObjectReader>

Stateful subgroup object writer (tracks delta encoding state and extension-presence flag, seeded from the stream’s SubgroupHeader).

Implementations

impl FramedSendStream

pub fn new(inner: SendStream, draft: DraftVersion) -> Self

Create a new framed send stream for the given draft version.

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. Also initializes the internal delta-encoding state used by FramedSendStream::write_subgroup_object.

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-15 subgroup object to the stream. Uses the stateful writer seeded from FramedSendStream::write_subgroup_header to produce correct delta-encoded object IDs.

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

Finish the stream (send FIN).

pub fn draft(&self) -> DraftVersion

Returns the draft version this stream is framed for.