Struct mqtt::control::fixed_header::FixedHeader

pub struct FixedHeader {
    pub packet_type: PacketType,
    pub remaining_length: u32,
}

Fixed header for each MQTT control packet

Format:

7                          3                          0
+--------------------------+--------------------------+
| MQTT Control Packet Type | Flags for each type      |
+--------------------------+--------------------------+
| Remaining Length ...                                |
+-----------------------------------------------------+

Fields

packet_type: PacketType

Packet Type

remaining_length: u32

The Remaining Length is the number of bytes remaining within the current packet, including data in the variable header and the payload. The Remaining Length does not include the bytes used to encode the Remaining Length.

Methods

impl FixedHeader

pub fn new(packet_type: PacketType, remaining_length: u32) -> FixedHeader

pub fn parse<A: AsyncRead>(     rdr: A ) -> impl Future<Item = (A, Self, Vec<u8>), Error = FixedHeaderError>

Asynchronously parse a single fixed header from an AsyncRead type, such as a network socket.

Trait Implementations

impl Debug for FixedHeader

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

Formats the value using the given formatter.

impl Clone for FixedHeader

fn clone(&self) -> FixedHeader

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Copy for FixedHeader

impl Eq for FixedHeader

impl PartialEq for FixedHeader

fn eq(&self, other: &FixedHeader) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &FixedHeader) -> bool

This method tests for !=.

impl Encodable for FixedHeader

type Err = FixedHeaderError

fn encode<W: Write>(&self, wr: &mut W) -> Result<(), FixedHeaderError>

Encodes to writer

fn encoded_length(&self) -> u32

Length of bytes after encoded

impl Decodable for FixedHeader

type Err = FixedHeaderError

type Cond = ()

fn decode_with<R: Read>(     rdr: &mut R,     _rest: Option<()> ) -> Result<FixedHeader, FixedHeaderError>

Decodes object with additional data (or hints)

fn decode<R: Read>(reader: &mut R) -> Result<Self, Self::Err>

Decodes object from reader