Struct Publish

pub struct Publish<Bytes> { /* private fields */ }

An MQTT PUBLISH packet

Implementations

impl<Bytes> Publish<Bytes>

where Bytes: AnyVec<u8>,

pub const TYPE: u8 = 3u8

The packet type constant

pub fn new<T, P>( topic: T, payload: P, retain: bool, ) -> Result<Self, MemoryError>

where T: AsRef<[u8]>, P: AsRef<[u8]>,

Creates a new packet

pub fn with_qos(self, qos: u8, packet_id: u16, dup: bool) -> Self

Configures the packet quality-of-service level and specifies whether this packet is a duplicate transmission (aka retry) or not

QoS Levels

Valid QoS levels are:

• 0: At most one delivery
• 1: At least one delivery
• 2: Exactly one delivery

pub fn topic(&self) -> &[u8]

The message topic

pub fn payload(&self) -> &[u8]

The payload

pub fn retain(&self) -> bool

Whether the message should be retained

pub fn dup(&self) -> bool

Whether this packet is a redelivery or not

pub fn qos(&self) -> u8

The packet QoS

pub fn packet_id(&self) -> Option<u16>

The packet ID

Trait Implementations

impl<Bytes: Clone> Clone for Publish<Bytes>

fn clone(&self) -> Publish<Bytes>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Bytes: Debug> Debug for Publish<Bytes>

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

Formats the value using the given formatter.

impl<Bytes> IntoIterator for Publish<Bytes>

where Bytes: AnyVec<u8>,

type Item = u8

The type of the elements being iterated over.

type IntoIter = Chain<Chain<Chain<Chain<Chain<Empty<u8>, Once<u8>>, Take<<[u8; 4] as IntoIterator>::IntoIter>>, Chain<<[u8; 2] as IntoIterator>::IntoIter, <Bytes as IntoIterator>::IntoIter>>, Take<<[u8; 2] as IntoIterator>::IntoIter>>, <Bytes as IntoIterator>::IntoIter>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<Bytes: PartialEq> PartialEq for Publish<Bytes>

fn eq(&self, other: &Publish<Bytes>) -> 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<Bytes> TryFromIterator for Publish<Bytes>

where Bytes: AnyVec<u8>,

fn try_from_iter<T>(iter: T) -> Result<Self, DecoderError>

where T: IntoIterator<Item = u8>,

Tries to build Self from the given byte iterator

impl<Bytes: Eq> Eq for Publish<Bytes>

impl<Bytes> StructuralPartialEq for Publish<Bytes>