Enum Packet

pub enum Packet {
    Connect(Connect),
    ConnAck(ConnAck),
    Publish(Publish),
    PubAck(PubAck),
    PubRec(PubRec),
    PubRel(PubRel),
    PubComp(PubComp),
    Subscribe(Subscribe),
    SubAck(SubAck),
    Unsubscribe(Unsubscribe),
    UnsubAck(UnsubAck),
    PingReq,
    PingResp,
    Disconnect,
}

Encapsulates all MQTT packet types

Variants

Connect(Connect)

ConnAck(ConnAck)

Publish(Publish)

PubAck(PubAck)

PubRec(PubRec)

PubRel(PubRel)

PubComp(PubComp)

Subscribe(Subscribe)

SubAck(SubAck)

Unsubscribe(Unsubscribe)

UnsubAck(UnsubAck)

PingReq

PingResp

Disconnect

Implementations

impl Packet

pub fn size(&self) -> usize

pub fn read(stream: &mut BytesMut, max_size: usize) -> Result<Self, Error>

Reads a stream of bytes and extracts next MQTT packet out of it

pub fn write( &self, stream: &mut BytesMut, max_size: usize, ) -> Result<usize, Error>

Serializes the MQTT packet into a stream of bytes

Trait Implementations

impl Clone for Packet

fn clone(&self) -> Packet

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Packet

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

Formats the value using the given formatter.

impl Encoder<Packet> for Codec

type Error = Error

The type of encoding errors.

fn encode( &mut self, item: Packet, dst: &mut BytesMut, ) -> Result<(), Self::Error>

Encodes a frame into the buffer provided.

impl PartialEq for Packet

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

impl StructuralPartialEq for Packet