Struct Subscribe

pub struct Subscribe<Seq, Bytes> { /* private fields */ }

An MQTT SUBSCRIBE packet

Implementations

impl<Seq, Bytes> Subscribe<Seq, Bytes>

where Seq: AnyVec<(Bytes, u8)>, Bytes: AnyVec<u8>,

pub const TYPE: u8 = 8u8

The packet type constant

pub fn new<S, T>(packet_id: u16, topics: S) -> Result<Self, MemoryError>

where S: IntoIterator<Item = (T, u8)>, T: AsRef<[u8]>,

Creates a new packet

QoS Levels

Valid QoS levels are:

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

pub fn packet_id(&self) -> u16

The packet ID

pub fn topics_qos(&self) -> &Seq

A list of (topic, qos)-tuples

Trait Implementations

impl<Seq: Clone, Bytes: Clone> Clone for Subscribe<Seq, Bytes>

fn clone(&self) -> Subscribe<Seq, Bytes>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<Seq: Debug, Bytes: Debug> Debug for Subscribe<Seq, Bytes>

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

Formats the value using the given formatter.

impl<Seq, Bytes> IntoIterator for Subscribe<Seq, Bytes>

where Seq: AnyVec<(Bytes, u8)>, Bytes: AnyVec<u8>,

type Item = u8

The type of the elements being iterated over.

type IntoIter = Chain<Chain<Chain<Chain<Empty<u8>, Once<u8>>, Take<<[u8; 4] as IntoIterator>::IntoIter>>, <[u8; 2] as IntoIterator>::IntoIter>, FlatMap<<Seq as IntoIterator>::IntoIter, Chain<Chain<<[u8; 2] as IntoIterator>::IntoIter, <Bytes as IntoIterator>::IntoIter>, Once<u8>>, fn((Bytes, u8)) -> Chain<Chain<<[u8; 2] as IntoIterator>::IntoIter, <Bytes as IntoIterator>::IntoIter>, Once<u8>>>>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.

impl<Seq: PartialEq, Bytes: PartialEq> PartialEq for Subscribe<Seq, Bytes>

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

where Seq: AnyVec<(Bytes, u8)>, 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<Seq: Eq, Bytes: Eq> Eq for Subscribe<Seq, Bytes>

impl<Seq, Bytes> StructuralPartialEq for Subscribe<Seq, Bytes>