Trait mqtt::packet::Packet

pub trait Packet<'a>: Sized {
    type Payload: Encodable<'a> + Decodable<'a> + 'a;
    fn fixed_header(&self) -> &FixedHeader;
    fn payload(&self) -> &Self::Payload;
    fn encode_variable_headers<W: Write>(
        &self, 
        writer: &mut W
    ) -> Result<(), PacketError<'a, Self>>;
    fn encoded_variable_headers_length(&self) -> u32;
    fn decode_packet<R: Read>(
        reader: &mut R, 
        fixed_header: FixedHeader
    ) -> Result<Self, PacketError<'a, Self>>;
}

Methods for encoding and decoding a packet

Associated Types

type Payload: Encodable<'a> + Decodable<'a> + 'a

Required Methods

fn fixed_header(&self) -> &FixedHeader

Get a FixedHeader of this packet

fn payload(&self) -> &Self::Payload

Get payload

fn encode_variable_headers<W: Write>(
    &self,
    writer: &mut W
) -> Result<(), PacketError<'a, Self>>

Encode variable headers to writer

fn encoded_variable_headers_length(&self) -> u32

Length of bytes after encoding variable header

fn decode_packet<R: Read>(
    reader: &mut R,
    fixed_header: FixedHeader
) -> Result<Self, PacketError<'a, Self>>

Deocde packet with a FixedHeader

Implementors

• impl<'a> Packet<'a> for ConnectPacket
• impl<'a> Packet<'a> for ConnackPacket
• impl<'a> Packet<'a> for PublishPacket
• impl<'a> Packet<'a> for PubackPacket
• impl<'a> Packet<'a> for PubrecPacket
• impl<'a> Packet<'a> for PubrelPacket
• impl<'a> Packet<'a> for PubcompPacket
• impl<'a> Packet<'a> for PingreqPacket
• impl<'a> Packet<'a> for PingrespPacket
• impl<'a> Packet<'a> for DisconnectPacket
• impl<'a> Packet<'a> for SubscribePacket
• impl<'a> Packet<'a> for SubackPacket
• impl<'a> Packet<'a> for UnsubackPacket
• impl<'a> Packet<'a> for UnsubscribePacket