Struct Unsubscribe 

pub struct Unsubscribe { /* private fields */ }

Represents an MQTT Unsubscribe packet.

Example

use mqute_codec::protocol::TopicFilters;
use mqute_codec::protocol::v4::Unsubscribe;

let unsubscribe = Unsubscribe::new(1234, vec!["topic1", "topic2"]);

let filters = TopicFilters::new(vec!["topic1", "topic2"]);

assert_eq!(unsubscribe.packet_id(), 1234u16);
assert_eq!(unsubscribe.filters(), filters);

Implementations

impl Unsubscribe

pub fn new<T: IntoIterator<Item: Into<String>>>( packet_id: u16, filters: T, ) -> Self

Creates a new Unsubscribe packet.

Panics

Panics if:

• packet_id is zero.
• The topic filters are invalid according to MQTT topic naming rules.

pub fn packet_id(&self) -> u16

Returns the packet ID of the Unsubscribe packet.

pub fn filters(&self) -> TopicFilters

Returns the list of topic filters to unsubscribe from.

Trait Implementations

impl Clone for Unsubscribe

fn clone(&self) -> Unsubscribe

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Unsubscribe

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

Formats the value using the given formatter.

impl Decode for Unsubscribe

fn decode(packet: RawPacket) -> Result<Self, Error>

Decodes an Unsubscribe packet from a raw MQTT packet.

impl Encode for Unsubscribe

fn encode(&self, buf: &mut BytesMut) -> Result<(), Error>

Encodes the Unsubscribe packet into a byte buffer.

fn payload_len(&self) -> usize

Returns the length of the payload in bytes.

impl PartialEq for Unsubscribe

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

impl StructuralPartialEq for Unsubscribe