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

pub trait Packet: Sized {
    type Payload: Encodable + Decodable;
    fn fixed_header(&self) -> &FixedHeader;
    fn payload(self) -> Self::Payload;
    fn payload_ref(&self) -> &Self::Payload;
    fn encode_variable_headers<W: Write>(
        &self, 
        writer: &mut W
    ) -> Result<(), PacketError<Self>>;
    fn encoded_variable_headers_length(&self) -> u32;
    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`

Loading content...

Required methods

`fn fixed_header(&self) -> &FixedHeader`

Get a FixedHeader of this packet

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

Get the payload

`fn payload_ref(&self) -> &Self::Payload`

Get a borrow of payload

`fn encode_variable_headers<W: Write>( &self, writer: &mut W ) -> Result<(), PacketError<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<Self>>`

Deocde packet with a FixedHeader

Loading content...

Implementors

`impl Packet for ConnackPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for ConnectPacket`[src]

`type Payload = ConnectPacketPayload`

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

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

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

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

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

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

`impl Packet for DisconnectPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PingreqPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PingrespPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PubackPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PubcompPacket`[src]

`type Payload = ()`

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

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

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

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

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

`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>`

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

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

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

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

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

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

`impl Packet for PubrecPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PubrelPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for SubackPacket`[src]

`type Payload = SubackPacketPayload`

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

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

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

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

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

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

`impl Packet for SubscribePacket`[src]

`type Payload = SubscribePacketPayload`

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

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

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

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

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

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

`impl Packet for UnsubackPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for UnsubscribePacket`[src]

`type Payload = UnsubscribePacketPayload`

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

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

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

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

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

`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

Required methods

fn fixed_header(&self) -> &FixedHeader

fn payload(self) -> Self::Payload

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

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

fn encoded_variable_headers_length(&self) -> u32

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

Implementors

impl Packet for ConnackPacket[src]

type Payload = ()

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

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

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

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

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

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

impl Packet for ConnectPacket[src]

type Payload = ConnectPacketPayload

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

fn payload(self) -> ConnectPacketPayload[src]

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

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

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

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

impl Packet for DisconnectPacket[src]

type Payload = ()

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

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

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

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

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

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

impl Packet for PingreqPacket[src]

type Payload = ()

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

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

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

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

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

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

impl Packet for PingrespPacket[src]

type Payload = ()

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

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

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

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

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

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

impl Packet for PubackPacket[src]

type Payload = ()

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

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

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

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

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

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

impl Packet for PubcompPacket[src]

type Payload = ()

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

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

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

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

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

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>

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

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

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

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

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

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

impl Packet for PubrecPacket[src]

type Payload = ()

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

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

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

`type Payload: Encodable + Decodable`

`fn fixed_header(&self) -> &FixedHeader`

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

`fn payload_ref(&self) -> &Self::Payload`

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

`fn encoded_variable_headers_length(&self) -> u32`

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

`impl Packet for ConnackPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for ConnectPacket`[src]

`type Payload = ConnectPacketPayload`

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

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

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

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

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

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

`impl Packet for DisconnectPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PingreqPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PingrespPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PubackPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PubcompPacket`[src]

`type Payload = ()`

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

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

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

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

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

`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>`

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

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

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

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

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

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

`impl Packet for PubrecPacket`[src]

`type Payload = ()`

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

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

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

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

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

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

`impl Packet for PubrelPacket`[src]