Enum Packet 

pub enum Packet {
    Auth(Auth),
    Connect(Connect, Option<LastWill>, ConnectAuth),
    ConnAck(ConnAck),
    Publish(Publish),
    PubAck(PubAck),
    PingReq(PingReq),
    PingResp(PingResp),
    Subscribe(Subscribe),
    SubAck(SubAck),
    PubRec(PubRec),
    PubRel(PubRel),
    PubComp(PubComp),
    Unsubscribe(Unsubscribe),
    UnsubAck(UnsubAck),
    Disconnect(Disconnect),
}

Variants

Auth(Auth)

Connect(Connect, Option<LastWill>, ConnectAuth)

ConnAck(ConnAck)

Publish(Publish)

PubAck(PubAck)

PingReq(PingReq)

PingResp(PingResp)

Subscribe(Subscribe)

SubAck(SubAck)

PubRec(PubRec)

PubRel(PubRel)

PubComp(PubComp)

Unsubscribe(Unsubscribe)

UnsubAck(UnsubAck)

Disconnect(Disconnect)

Implementations

impl Packet

pub fn read( stream: &mut BytesMut, max_size: Option<u32>, ) -> Result<Packet, Error>

Reads the next MQTT v5 packet from the buffered stream.

Errors

Returns an error if the packet is incomplete, malformed, or exceeds the configured packet-size limit.

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

Serializes this MQTT v5 packet into the output buffer.

Errors

Returns an error if the packet cannot be encoded within the configured packet-size limit or violates MQTT encoding rules.

pub fn size(&self) -> usize

Trait Implementations

impl Clone for Packet

fn clone(&self) -> Packet

Returns a duplicate 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<(), Error>

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<(), <Codec as Encoder<Packet>>::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