Struct SubscribeMessage

pub struct SubscribeMessage {
    pub subject: String,
    pub queue_group: Option<String>,
    pub subscription_id: usize,
}

A struct that represents a subscription message. This message conforms to the following format from the NATS protocol definition:

SUB <subject> [queue group] <sid>\r\n

Fields

subject: String

queue_group: Option<String>

subscription_id: usize

Implementations

impl SubscribeMessage

pub fn new( subject: String, queue_group: Option<String>, subscription_id: usize, ) -> SubscribeMessage

Constructor to create a new subscription message

pub fn as_vec( subject: &str, queue_group: Option<&str>, subscription_id: usize, ) -> Result<Vec<u8>, Box<dyn Error>>

Efficient single-allocation conversion into a byte vector suitable for network transmission

Trait Implementations

impl Clone for SubscribeMessage

fn clone(&self) -> SubscribeMessage

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for SubscribeMessage

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

Formats the value using the given formatter.

impl Display for SubscribeMessage

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

Formats the value using the given formatter.

impl FromStr for SubscribeMessage

type Err = NatsParseError

The associated error which can be returned from parsing.

fn from_str(s: &str) -> Result<Self, <Self as FromStr>::Err>

Parses a string s to return a value of this type.

impl PartialEq for SubscribeMessage

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