Enum Message 

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

All supported message types.

Variants

GoAway(GoAway)

MaxRequestId(MaxRequestId)

RequestsBlocked(RequestsBlocked)

SubscribeUpdate(SubscribeUpdate)

Subscribe(Subscribe)

Unsubscribe(Unsubscribe)

SubscribeOk(SubscribeOk)

SubscribeError(SubscribeError)

PublishNamespace(PublishNamespace)

PublishNamespaceDone(PublishNamespaceDone)

PublishNamespaceOk(PublishNamespaceOk)

PublishNamespaceError(PublishNamespaceError)

PublishNamespaceCancel(PublishNamespaceCancel)

TrackStatus(TrackStatus)

TrackStatusOk(TrackStatusOk)

TrackStatusError(TrackStatusError)

SubscribeNamespace(SubscribeNamespace)

UnsubscribeNamespace(UnsubscribeNamespace)

SubscribeNamespaceOk(SubscribeNamespaceOk)

SubscribeNamespaceError(SubscribeNamespaceError)

Fetch(Fetch)

FetchCancel(FetchCancel)

FetchOk(FetchOk)

FetchError(FetchError)

Publish(Publish)

PublishDone(PublishDone)

PublishOk(PublishOk)

PublishError(PublishError)

Implementations

impl Message

pub fn id(&self) -> u64

pub fn name(&self) -> &'static str

Trait Implementations

impl Clone for Message

fn clone(&self) -> Message

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Message

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

Formats the value using the given formatter.

impl Decode for Message

fn decode<R: Buf>(r: &mut R) -> Result<Self, DecodeError>

fn decode_remaining<B: Buf>( buf: &mut B, required: usize, ) -> Result<(), DecodeError>

impl Encode for Message

fn encode<W: BufMut>(&self, w: &mut W) -> Result<(), EncodeError>

fn encode_remaining<W: BufMut>( buf: &mut W, required: usize, ) -> Result<(), EncodeError>

impl From<Fetch> for Message

fn from(m: Fetch) -> Self

Converts to this type from the input type.

impl From<FetchCancel> for Message

fn from(m: FetchCancel) -> Self

Converts to this type from the input type.

impl From<FetchError> for Message

fn from(m: FetchError) -> Self

Converts to this type from the input type.

impl From<FetchOk> for Message

fn from(m: FetchOk) -> Self

Converts to this type from the input type.

impl From<GoAway> for Message

fn from(m: GoAway) -> Self

Converts to this type from the input type.

impl From<MaxRequestId> for Message

fn from(m: MaxRequestId) -> Self

Converts to this type from the input type.

impl From<Publish> for Message

fn from(m: Publish) -> Self

Converts to this type from the input type.

impl From<PublishDone> for Message

fn from(m: PublishDone) -> Self

Converts to this type from the input type.

impl From<PublishError> for Message

fn from(m: PublishError) -> Self

Converts to this type from the input type.

impl From<PublishNamespace> for Message

fn from(m: PublishNamespace) -> Self

Converts to this type from the input type.

impl From<PublishNamespaceCancel> for Message

fn from(m: PublishNamespaceCancel) -> Self

Converts to this type from the input type.

impl From<PublishNamespaceDone> for Message

fn from(m: PublishNamespaceDone) -> Self

Converts to this type from the input type.

impl From<PublishNamespaceError> for Message

fn from(m: PublishNamespaceError) -> Self

Converts to this type from the input type.

impl From<PublishNamespaceOk> for Message

fn from(m: PublishNamespaceOk) -> Self

Converts to this type from the input type.

impl From<PublishOk> for Message

fn from(m: PublishOk) -> Self

Converts to this type from the input type.

impl From<Publisher> for Message

fn from(p: Publisher) -> Self

Converts to this type from the input type.

impl From<RequestsBlocked> for Message

fn from(m: RequestsBlocked) -> Self

Converts to this type from the input type.

impl From<Subscribe> for Message

fn from(m: Subscribe) -> Self

Converts to this type from the input type.

impl From<SubscribeError> for Message

fn from(m: SubscribeError) -> Self

Converts to this type from the input type.

impl From<SubscribeNamespace> for Message

fn from(m: SubscribeNamespace) -> Self

Converts to this type from the input type.

impl From<SubscribeNamespaceError> for Message

fn from(m: SubscribeNamespaceError) -> Self

Converts to this type from the input type.

impl From<SubscribeNamespaceOk> for Message

fn from(m: SubscribeNamespaceOk) -> Self

Converts to this type from the input type.

impl From<SubscribeOk> for Message

fn from(m: SubscribeOk) -> Self

Converts to this type from the input type.

impl From<SubscribeUpdate> for Message

fn from(m: SubscribeUpdate) -> Self

Converts to this type from the input type.

impl From<Subscriber> for Message

fn from(p: Subscriber) -> Self

Converts to this type from the input type.

impl From<TrackStatus> for Message

fn from(m: TrackStatus) -> Self

Converts to this type from the input type.

impl From<TrackStatusError> for Message

fn from(m: TrackStatusError) -> Self

Converts to this type from the input type.

impl From<TrackStatusOk> for Message

fn from(m: TrackStatusOk) -> Self

Converts to this type from the input type.

impl From<Unsubscribe> for Message

fn from(m: Unsubscribe) -> Self

Converts to this type from the input type.

impl From<UnsubscribeNamespace> for Message

fn from(m: UnsubscribeNamespace) -> Self

Converts to this type from the input type.

impl TryFrom<Message> for Publisher

type Error = Message

The type returned in the event of a conversion error.

fn try_from(m: Message) -> Result<Self, Self::Error>

Performs the conversion.

impl TryFrom<Message> for Subscriber

type Error = Message

The type returned in the event of a conversion error.

fn try_from(m: Message) -> Result<Self, Self::Error>

Performs the conversion.