Enum SubscriptionEvent 

pub enum SubscriptionEvent {
    Subscribe(Bytes),
    Unsubscribe(Bytes),
}

Subscription event for XPUB socket

Variants

Subscribe(Bytes)

A peer subscribed to a topic

Unsubscribe(Bytes)

A peer unsubscribed from a topic

Implementations

impl SubscriptionEvent

pub fn from_message(msg: &[u8]) -> Option<Self>

Create a subscription event from a ZMTP subscription message

Format: [0x01|0x00] [topic prefix…]

pub fn to_message(&self) -> Bytes

Encode this event as a ZMTP subscription message

pub const fn prefix(&self) -> &Bytes

Get the topic prefix

pub const fn is_subscribe(&self) -> bool

Check if this is a subscribe event

pub const fn is_unsubscribe(&self) -> bool

Check if this is an unsubscribe event

Trait Implementations

impl Clone for SubscriptionEvent

fn clone(&self) -> SubscriptionEvent

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionEvent

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

Formats the value using the given formatter.

impl Eq for SubscriptionEvent

impl PartialEq for SubscriptionEvent

fn eq(&self, other: &SubscriptionEvent) -> 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 StructuralPartialEq for SubscriptionEvent