Struct UnsubscribePacket 

pub struct UnsubscribePacket {
    pub packet_id: u16,
    pub filters: Vec<String>,
    pub properties: Properties,
    pub protocol_version: u8,
}

MQTT UNSUBSCRIBE packet

Fields

packet_id: u16

Packet identifier

filters: Vec<String>

Topic filters to unsubscribe from

properties: Properties

UNSUBSCRIBE properties (v5.0 only)

protocol_version: u8

Protocol version (4 = v3.1.1, 5 = v5.0)

Implementations

impl UnsubscribePacket

pub fn new(packet_id: u16) -> Self

Creates a new UNSUBSCRIBE packet (v5.0)

pub fn new_v311(packet_id: u16) -> Self

Creates a new UNSUBSCRIBE packet for v3.1.1

pub fn add_filter(self, filter: impl Into<String>) -> Self

Adds a topic filter to unsubscribe from

pub fn with_user_property(self, key: String, value: String) -> Self

Adds a user property

impl UnsubscribePacket

pub fn decode_body_with_version<B: Buf>( buf: &mut B, fixed_header: &FixedHeader, protocol_version: u8, ) -> Result<Self>

Decodes the packet body with a specific protocol version

Errors

Returns an error if decoding fails

Trait Implementations

impl Clone for UnsubscribePacket

fn clone(&self) -> UnsubscribePacket

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UnsubscribePacket

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

Formats the value using the given formatter.

impl MqttPacket for UnsubscribePacket

fn packet_type(&self) -> PacketType

Returns the packet type

fn flags(&self) -> u8

Returns the fixed header flags

fn encode_body<B: BufMut>(&self, buf: &mut B) -> Result<()>

Encodes the packet body (without fixed header)

fn decode_body<B: Buf>(buf: &mut B, fixed_header: &FixedHeader) -> Result<Self>

Decodes the packet body (without fixed header)

fn encode<B: BufMut>(&self, buf: &mut B) -> Result<()>

Encodes the complete packet (with fixed header)