[−][src]Trait mqtt::packet::Packet

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

Methods for encoding and decoding a packet

Associated Types

`type Payload: Encodable + Decodable`[src]

Loading content...

Required methods

`pub fn fixed_header(&self) -> &FixedHeader`[src]

Get a FixedHeader of this packet

`pub fn payload(self) -> Self::Payload`[src]

Get the payload

`pub fn payload_ref(&self) -> &Self::Payload`[src]

Get a borrow of payload

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

Encode variable headers to writer

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

Length of bytes after encoding variable header

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

Deocde packet with a FixedHeader

Loading content...

Implementors

`impl Packet for ConnackPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for ConnectPacket`[src]

`type Payload = ConnectPacketPayload`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> ConnectPacketPayload`[src]

`pub fn payload_ref(&self) -> &ConnectPacketPayload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for DisconnectPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PingreqPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PingrespPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubackPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubcompPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PublishPacket`[src]

`type Payload = Vec<u8>`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubrecPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubrelPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for SubackPacket`[src]

`type Payload = SubackPacketPayload`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for SubscribePacket`[src]

`type Payload = SubscribePacketPayload`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for UnsubackPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for UnsubscribePacket`[src]

`type Payload = UnsubscribePacketPayload`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

Loading content...

[−][src]Trait mqtt::packet::Packet

Associated Types

type Payload: Encodable + Decodable[src]

Required methods

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

Implementors

impl Packet for ConnackPacket[src]

type Payload = ()

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for ConnectPacket[src]

type Payload = ConnectPacketPayload

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> ConnectPacketPayload[src]

pub fn payload_ref(&self) -> &ConnectPacketPayload[src]

pub fn encode_variable_headers<W: Write>( &self, writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for DisconnectPacket[src]

type Payload = ()

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for PingreqPacket[src]

type Payload = ()

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for PingrespPacket[src]

type Payload = ()

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for PubackPacket[src]

type Payload = ()

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for PubcompPacket[src]

type Payload = ()

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for PublishPacket[src]

type Payload = Vec<u8>

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

pub fn encode_variable_headers<W: Write>( &self, writer: &mut W) -> Result<(), PacketError<Self>>[src]

pub fn encoded_variable_headers_length(&self) -> u32[src]

pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader) -> Result<Self, PacketError<Self>>[src]

impl Packet for PubrecPacket[src]

type Payload = ()

pub fn fixed_header(&self) -> &FixedHeader[src]

pub fn payload(self) -> Self::Payload[src]

pub fn payload_ref(&self) -> &Self::Payload[src]

`type Payload: Encodable + Decodable`[src]

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for ConnackPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for ConnectPacket`[src]

`type Payload = ConnectPacketPayload`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> ConnectPacketPayload`[src]

`pub fn payload_ref(&self) -> &ConnectPacketPayload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for DisconnectPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PingreqPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PingrespPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, _writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( _reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubackPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubcompPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PublishPacket`[src]

`type Payload = Vec<u8>`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubrecPacket`[src]

`type Payload = ()`

`pub fn fixed_header(&self) -> &FixedHeader`[src]

`pub fn payload(self) -> Self::Payload`[src]

`pub fn payload_ref(&self) -> &Self::Payload`[src]

`pub fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<Self>>`[src]

`pub fn encoded_variable_headers_length(&self) -> u32`[src]

`pub fn decode_packet<R: Read>( reader: &mut R, fixed_header: FixedHeader ) -> Result<Self, PacketError<Self>>`[src]

`impl Packet for PubrelPacket`[src]