Struct SubscriptionHeader 

pub struct SubscriptionHeader {
    pub endpoint: String,
    pub filter: String,
}

SUBSCRIBE and UNSUBSCRIBE header.

Both frames carry the same two keys: the publisher path to (un)subscribe on and the topic filter. The filter is a segmented pattern, not a byte prefix (filter): the empty filter matches every topic, * matches one whole segment and a trailing # matches zero or more.

Fields

endpoint: String

Publisher endpoint path.

filter: String

Topic filter; the empty string matches everything. A decoded header’s filter has passed filter::validate.

Implementations

impl SubscriptionHeader

pub fn new( endpoint: impl Into<String>, filter: impl Into<String>, ) -> SubscriptionHeader

A header for endpoint and filter.

pub fn encode(&self) -> Vec<u8>

Encodes the header.

pub fn encode_into(&self, out: &mut Vec<u8>)

Appends the encoded header to out, for a send path that reuses a buffer (B-250). The canonical form has one implementation and this is it; Self::encode is a wrapper.

pub fn decode(bytes: &[u8]) -> Result<SubscriptionHeader, HeaderError>

Decodes the header.

Trait Implementations

impl Clone for SubscriptionHeader

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SubscriptionHeader

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

Formats the value using the given formatter.

impl Eq for SubscriptionHeader

impl PartialEq for SubscriptionHeader

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

Equality operator ==.

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

Inequality operator !=.

impl StructuralPartialEq for SubscriptionHeader