Enum ClientEvent 

#[non_exhaustive]
pub enum ClientEvent {
    SetupComplete {
        negotiated_version: u64,
    },
    ControlMessage {
        direction: Direction,
        message: AnyControlMessage,
        raw: Option<Vec<u8>>,
    },
    StreamOpened {
        direction: Direction,
        stream_kind: StreamKind,
        stream_id: u64,
    },
    DataStreamHeader {
        stream_id: u64,
        direction: Direction,
        header: AnySubgroupHeader,
    },
    FetchStreamHeader {
        stream_id: u64,
        direction: Direction,
        header: AnyFetchHeader,
    },
    SubgroupObjectReceived {
        stream_id: u64,
        direction: Direction,
        object: SubgroupObject,
    },
    FetchObjectReceived {
        stream_id: u64,
        direction: Direction,
        object: FetchObject,
    },
    DatagramReceived {
        direction: Direction,
        header: AnyDatagramHeader,
        payload_len: usize,
    },
    StreamClosed {
        stream_id: u64,
        error_code: u64,
    },
    PublishReceived {
        publish: Publish,
    },
    Draining {
        new_session_uri: Vec<u8>,
    },
    Closed {
        code: u32,
        reason: Vec<u8>,
    },
    Error {
        error: String,
    },
}

Events emitted by a draft-12 MoQT connection.

This enum is #[non_exhaustive] — new variants may be added in minor releases. Downstream match arms should include a wildcard _ => branch.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

SetupComplete

MoQT setup handshake completed.

Fields

negotiated_version: u64

The negotiated MoQT version.

ControlMessage

A control message was sent or received.

Fields

direction: Direction

Whether the message was sent or received.

message: AnyControlMessage

The decoded control message.

raw: Option<Vec<u8>>

The raw wire bytes of the framed message (type + length + payload). None if raw capture is not available.

StreamOpened

A data stream was opened.

Fields

direction: Direction

Whether we opened (Send) or accepted (Receive) the stream.

stream_kind: StreamKind

The type of data stream.

stream_id: u64

Transport-level stream identifier.

DataStreamHeader

A subgroup stream header was decoded after the stream opened.

Fields

stream_id: u64

Transport-level stream identifier.

direction: Direction

Whether we opened (Send) or accepted (Receive) the stream.

header: AnySubgroupHeader

The parsed subgroup header.

FetchStreamHeader

A fetch response stream header was decoded.

Fields

stream_id: u64

Transport-level stream identifier.

direction: Direction

Whether we opened (Send) or accepted (Receive) the stream.

header: AnyFetchHeader

The parsed fetch header.

SubgroupObjectReceived

A subgroup object (header + payload) was decoded on a subgroup stream.

Fields

stream_id: u64

Transport-level stream identifier.

direction: Direction

Direction (Send when emitted from a writer, Receive from a reader).

object: SubgroupObject

The decoded subgroup object.

FetchObjectReceived

A fetch object (self-contained) was decoded on a fetch stream.

Fields

stream_id: u64

Transport-level stream identifier.

direction: Direction

Direction (Send when emitted from a writer, Receive from a reader).

object: FetchObject

The decoded fetch object.

DatagramReceived

A datagram was sent or received.

Fields

direction: Direction

Whether sent or received.

header: AnyDatagramHeader

The parsed datagram header.

payload_len: usize

Size of the payload in bytes.

StreamClosed

A data stream was closed.

Fields

stream_id: u64

Transport-level stream identifier.

error_code: u64

Error code (0 = clean close).

PublishReceived

A PUBLISH message (draft-12) was received — a publisher is offering a track to this endpoint as a subscriber. The application should respond via the endpoint’s send_publish_ok / send_publish_error APIs.

Fields

publish: Publish

The decoded PUBLISH message.

Draining

Session entered draining state (GOAWAY received).

Fields

new_session_uri: Vec<u8>

The new session URI from the GOAWAY message.

Closed

Connection was closed.

Fields

code: u32

Application error code.

reason: Vec<u8>

Human-readable reason.

Error

A transport or protocol error occurred.

Fields

error: String

Error description.

Trait Implementations

impl Clone for ClientEvent

fn clone(&self) -> ClientEvent

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ClientEvent

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.