Struct nats_types::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

Methods

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 PartialEq<SubscribeMessage> for SubscribeMessage

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

This method tests for self and other values to be equal, and is used by ==.

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

This method tests for !=.

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 Display for SubscribeMessage

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

Formats the value using the given formatter.

impl Debug for SubscribeMessage

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

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::Err>

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