Module framer 

Byte-exact object framing for MoQT data streams.

ObjectFramer turns the raw bytes of one unidirectional data stream into individually addressable objects without altering them: every item it yields is a slice of the bytes that were fed in, and concatenating those items reproduces the stream exactly.

Framing is opt-in because it costs latency and memory — an object is only emitted once it is buffered whole. The proxy pays that cost only when something is observing; see session::pipe_data.

Re-exports

use std::collections::HashMap; 🔒

use std::sync::Arc; 🔒

use std::sync::Mutex; 🔒

use bytes::Buf; 🔒

use bytes::Bytes; 🔒

use bytes::BytesMut; 🔒

use moqtap_codec::dispatch::reemit_subgroup_object; 🔒

use moqtap_codec::dispatch::AnyFetchFrame; 🔒

use moqtap_codec::dispatch::AnyFetchGroupOrder; 🔒

use moqtap_codec::dispatch::AnyFetchHeader; 🔒

use moqtap_codec::dispatch::AnyFetchObjectMeta; 🔒

use moqtap_codec::dispatch::AnyFetchObjectReader; 🔒

use moqtap_codec::dispatch::AnyFetchObjectWriter; 🔒

use moqtap_codec::dispatch::AnySubgroupHeader; 🔒

use moqtap_codec::dispatch::AnySubgroupObjectMeta; 🔒

use moqtap_codec::dispatch::AnySubgroupObjectReader; 🔒

use moqtap_codec::dispatch::FetchReemit; 🔒

use moqtap_codec::version::DraftVersion; 🔒

use crate::capability::fetch_group_order_is_needed; 🔒

use crate::event::DataStreamHeaderKind; 🔒

use crate::instrument::Recorder; 🔒

use crate::parser::data::is_incomplete_error; 🔒

use crate::types::DataStreamType; 🔒

pub use crate::types::BypassReason;

pub use crate::types::ObjectMeta;

Structs

ElideCursor

The state an elide leaves behind on a subgroup stream.

FetchGroupOrders

Every fetch this session has learned a Group Order for, keyed by the Request ID that names it on both the control plane and the data stream.

FramerConfig

Configuration for ObjectFramer.

ObjectFramer

Frames a unidirectional MoQT data stream into individually addressable objects while preserving the exact wire bytes.

PaddedBuf 🔒

A slice followed by a run of zero bytes.

PendingObject 🔒

The object the framer emitted most recently, whose forward-or-elide disposition has not been committed to the cursor yet.

SubgroupContext 🔒

Identity fields the stream header contributes to every object on a subgroup stream.

Enums

FramerOut

One item produced by ObjectFramer::poll.

Meta 🔒

The codec-level framing of one object, either stream kind.

Probe 🔒

A reader clone whose decode succeeded and is ready to be adopted.

Stage 🔒

What the framer is currently decoding.

Constants

UNBOUNDED_MEASURING_PAD 🔒

Padding width that puts every wire length a varint can express within measuring reach.

ZEROS 🔒

Backing bytes for PaddedBuf’s padded region.

Functions

subgroup_context 🔒

The identity fields a subgroup header contributes to its objects.