Enum ControlMessage 

pub enum ControlMessage {
    ClientSetup(ClientSetup),
    ServerSetup(ServerSetup),
    GoAway(GoAway),
    MaxRequestId(MaxRequestId),
    RequestsBlocked(RequestsBlocked),
    Subscribe(Subscribe),
    SubscribeOk(SubscribeOk),
    SubscribeError(SubscribeError),
    SubscribeUpdate(SubscribeUpdate),
    Unsubscribe(Unsubscribe),
    Publish(Publish),
    PublishOk(PublishOk),
    PublishError(PublishError),
    PublishDone(PublishDone),
    PublishNamespace(PublishNamespace),
    PublishNamespaceOk(PublishNamespaceOk),
    PublishNamespaceError(PublishNamespaceError),
    PublishNamespaceDone(PublishNamespaceDone),
    PublishNamespaceCancel(PublishNamespaceCancel),
    SubscribeNamespace(SubscribeNamespace),
    SubscribeNamespaceOk(SubscribeNamespaceOk),
    SubscribeNamespaceError(SubscribeNamespaceError),
    UnsubscribeNamespace(UnsubscribeNamespace),
    Fetch(Fetch),
    FetchOk(FetchOk),
    FetchError(FetchError),
    FetchCancel(FetchCancel),
    TrackStatus(TrackStatus),
    TrackStatusOk(TrackStatusOk),
    TrackStatusError(TrackStatusError),
}

A parsed MoQT control message (draft-14).

Variants

ClientSetup(ClientSetup)

ClientSetup (type 0x20).

ServerSetup(ServerSetup)

ServerSetup (type 0x21).

GoAway(GoAway)

GoAway (type 0x10).

MaxRequestId(MaxRequestId)

MaxRequestId (type 0x15).

RequestsBlocked(RequestsBlocked)

RequestsBlocked (type 0x1A).

Subscribe(Subscribe)

Subscribe (type 0x03).

SubscribeOk(SubscribeOk)

SubscribeOk (type 0x04).

SubscribeError(SubscribeError)

SubscribeError (type 0x05).

SubscribeUpdate(SubscribeUpdate)

SubscribeUpdate (type 0x02).

Unsubscribe(Unsubscribe)

Unsubscribe (type 0x0A).

Publish(Publish)

Publish (type 0x1D).

PublishOk(PublishOk)

PublishOk (type 0x1E).

PublishError(PublishError)

PublishError (type 0x1F).

PublishDone(PublishDone)

PublishDone (type 0x0B).

PublishNamespace(PublishNamespace)

PublishNamespace (type 0x06).

PublishNamespaceOk(PublishNamespaceOk)

PublishNamespaceOk (type 0x07).

PublishNamespaceError(PublishNamespaceError)

PublishNamespaceError (type 0x08).

PublishNamespaceDone(PublishNamespaceDone)

PublishNamespaceDone (type 0x09).

PublishNamespaceCancel(PublishNamespaceCancel)

PublishNamespaceCancel (type 0x0C).

SubscribeNamespace(SubscribeNamespace)

SubscribeNamespace (type 0x11).

SubscribeNamespaceOk(SubscribeNamespaceOk)

SubscribeNamespaceOk (type 0x12).

SubscribeNamespaceError(SubscribeNamespaceError)

SubscribeNamespaceError (type 0x13).

UnsubscribeNamespace(UnsubscribeNamespace)

UnsubscribeNamespace (type 0x14).

Fetch(Fetch)

Fetch (type 0x16).

FetchOk(FetchOk)

FetchOk (type 0x18).

FetchError(FetchError)

FetchError (type 0x19).

FetchCancel(FetchCancel)

FetchCancel (type 0x17).

TrackStatus(TrackStatus)

TrackStatus (type 0x0D).

TrackStatusOk(TrackStatusOk)

TrackStatusOk (type 0x0E).

TrackStatusError(TrackStatusError)

TrackStatusError (type 0x0F).

Implementations

impl ControlMessage

pub fn encode(&self, buf: &mut impl BufMut) -> Result<(), CodecError>

Encode this control message to bytes (including type ID and length prefix).

Draft-14 framing: type_id(vi) + payload_length(16) + payload.

pub fn decode(buf: &mut impl Buf) -> Result<Self, CodecError>

Decode a control message from bytes (reads type ID and length prefix first).

Draft-14 framing: type_id(vi) + payload_length(16) + payload.

fn encode_payload(&self, buf: &mut impl BufMut) -> Result<(), CodecError>

fn decode_payload( msg_type: MessageType, buf: &mut impl Buf, ) -> Result<Self, CodecError>

pub fn message_type(&self) -> MessageType

Get the message type ID for this message.

Trait Implementations

impl Clone for ControlMessage

fn clone(&self) -> ControlMessage

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ControlMessage

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

Formats the value using the given formatter.

impl PartialEq for ControlMessage

fn eq(&self, other: &ControlMessage) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for ControlMessage

impl StructuralPartialEq for ControlMessage