Module connection 

Outbound MoQT connection with MoQT framing over QUIC.

Re-exports

use std::collections::VecDeque; 🔒

use std::sync::Mutex; 🔒

use bytes::Buf; 🔒

use bytes::Bytes; 🔒

use bytes::BytesMut; 🔒

use crate::draft16::endpoint::Endpoint; 🔒

use crate::draft16::endpoint::EndpointError; 🔒

use crate::draft16::event::ClientEvent; 🔒

use crate::draft16::event::Direction; 🔒

use crate::draft16::event::StreamKind; 🔒

use crate::draft16::observer::ConnectionObserver; 🔒

use crate::draft16::session::request_id::Role; 🔒

use crate::draft16::session::setup; 🔒

use crate::malformed_tracks::MalformedTrackCondition; 🔒

use crate::track_locations::ObjectLocation; 🔒

use crate::track_locations::ObjectRole; 🔒

use crate::track_locations::TrackObjects; 🔒

use crate::transport::RecvStream; 🔒

use crate::transport::SendStream; 🔒

use crate::transport::Transport; 🔒

use crate::transport::TransportError; 🔒

use moqtap_codec::dispatch::AnyControlMessage; 🔒

use moqtap_codec::dispatch::AnyDatagramHeader; 🔒

use moqtap_codec::dispatch::AnyFetchHeader; 🔒

use moqtap_codec::dispatch::AnySubgroupHeader; 🔒

use moqtap_codec::draft16::data_stream::FetchHeader; 🔒

use moqtap_codec::draft16::data_stream::FetchObjectHeader; 🔒

use moqtap_codec::draft16::data_stream::SubgroupObject; 🔒

use moqtap_codec::draft16::data_stream::SubgroupObjectReader; 🔒

use moqtap_codec::draft16::error_codes::DataStreamResetErrorCode; 🔒

use moqtap_codec::draft16::message::ControlMessage; 🔒

use moqtap_codec::draft16::message::MessageType; 🔒

use moqtap_codec::draft16::message::RequestError; 🔒

use moqtap_codec::draft16::message::RequestOk; 🔒

use moqtap_codec::error::CodecError; 🔒

use moqtap_codec::kvp::KeyValuePair; 🔒

use moqtap_codec::varint::VarInt; 🔒

use moqtap_codec::version::DraftVersion; 🔒

use moqtap_codec::types::*; 🔒

Structs

ClientConfig

Configuration for a MoQT client connection.

Connection

A live MoQT connection over QUIC or WebTransport, combining the endpoint state machine with actual network I/O.

FramedRecvStream

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

FramedSendStream

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

NamespaceStream

One SUBSCRIBE_NAMESPACE and everything answering it, on a bidirectional stream of their own.

PendingInbound 🔒

Holds a peer-opened stream pair while its first message is being read, and puts it back on the connection’s queue if that read is abandoned.

Enums

ConnectionError

Errors from the connection layer.

RequestOrigin

Which side opened the bidirectional stream a namespace subscription travels on.

TransportType

Transport type for the connection.

Constants

MAX_QUIC_VARINT 🔒

The largest value a QUIC application error code can carry, 2^62 - 1.

MOQT_ALPN

The ALPN identifier draft-16 uses on raw QUIC, moqt-16.

STREAM_ABANDONED 🔒

The application error code a namespace subscription’s stream is abandoned with when this endpoint never served it: INTERNAL_ERROR, 0x0.

Functions

empty_datagram_extensions 🔒

ConnectionError::EmptyDatagramExtensions for a datagram the header decoder refused as InvalidField, when its empty extension block was the fault.

malformed_track_condition 🔒

The Malformed Track condition a codec refusal on a data path is, on this draft, or None for a refusal that is not one.

object_role 🔒

What an Object Status makes of an object here.

varint_len 🔒

Determine the encoded length of a varint from its first byte.