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::draft23::endpoint::Endpoint; 🔒

use crate::draft23::endpoint::EndpointError; 🔒

use crate::draft23::endpoint::FetchExistence; 🔒

use crate::draft23::endpoint::TrackExistence; 🔒

use crate::draft23::event::ClientEvent; 🔒

use crate::draft23::event::Direction; 🔒

use crate::draft23::event::StreamKind; 🔒

use crate::draft23::fill::LocationFilter; 🔒

use crate::draft23::observer::ConnectionObserver; 🔒

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

use crate::draft23::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::draft23::data_stream::FetchHeader; 🔒

use moqtap_codec::draft23::data_stream::FetchObject; 🔒

use moqtap_codec::draft23::data_stream::FetchObjectHeader; 🔒

use moqtap_codec::draft23::data_stream::FetchObjectReader; 🔒

use moqtap_codec::draft23::data_stream::GroupOrder; 🔒

use moqtap_codec::draft23::data_stream::SubgroupObject; 🔒

use moqtap_codec::draft23::data_stream::SubgroupObjectReader; 🔒

use moqtap_codec::draft23::error_codes::SessionErrorCode; 🔒

use moqtap_codec::draft23::error_codes::StreamResetErrorCode; 🔒

use moqtap_codec::draft23::message::max_control_message_size; 🔒

use moqtap_codec::draft23::message::ControlMessage; 🔒

use moqtap_codec::draft23::message::MessageType; 🔒

use moqtap_codec::draft23::message::Namespace; 🔒

use moqtap_codec::draft23::message::NamespaceDone; 🔒

use moqtap_codec::draft23::message::PublishSkipped; 🔒

use moqtap_codec::draft23::message::RequestError; 🔒

use moqtap_codec::draft23::message::RequestOk; 🔒

use moqtap_codec::draft23::message::SubscribeOk; 🔒

use moqtap_codec::draft23::message::DEFAULT_MAX_CONTROL_MESSAGE_SIZE; 🔒

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.

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.

RequestStream

One request and its answer, on a bidirectional stream of their own.

Enums

ConnectionError

Errors from the connection layer.

RequestKind

Which of the seven message types draft-23 Section 6.3 lets a bidirectional stream begin with opened a request stream.

RequestOrigin

Which side opened the bidirectional stream a request travels on.

TransportType

Transport type for the connection.

Constants

CONTROL_STREAM_TYPE

The unidirectional stream type that marks one direction of the control plane, and the SETUP message type. On draft-23 they are one number, 0x2F00: Section 6.4.1 (Unidirectional Stream Types) lists it as the type of a SETUP stream, and Section 9.1 gives it as the SETUP message’s own type field.

FETCH_STREAM_TYPE 🔒

The unidirectional stream type of FETCH_HEADER, 0x05 (draft-23 Section 6.4.1).

MAX_QUIC_VARINT 🔒

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

MOQT_ALPN

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

REQUEST_CANCELLED

The application error code a request stream is reset with when the requester abandons it: CANCELLED, 0x1.

REQUEST_UNANSWERED

The application error code a request stream the peer opened is reset with when this endpoint abandons it: INTERNAL_ERROR, 0x0.

Functions

belongs_on_a_request_stream 🔒

Whether draft-23 Table 5 places this message on a request stream that is already open.

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.

starts_a_request_stream

Whether ty is one of the seven message types draft-23 Section 6.3 lets a bidirectional stream begin with.