Struct MqttState 

pub struct MqttState {
    pub await_pingresp: bool,
    pub collision_ping_count: usize,
    pub collision: Option<Publish>,
    pub events: VecDeque<Event>,
    pub write: BytesMut,
    pub manual_acks: bool,
    pub broker_topic_alias_max: u16,
    pub max_outgoing_packet_size: Option<u32>,
    /* private fields */
}

State of the mqtt connection.

Fields

await_pingresp: bool

Status of last ping

collision_ping_count: usize

Collision ping count. Collisions stop user requests which inturn trigger pings. Multiple pings without resolving collisions will result in error

collision: Option<Publish>

Last collision due to broker not acking in order

events: VecDeque<Event>

Buffered incoming packets

write: BytesMut

Write buffer

manual_acks: bool

Indicates if acknowledgements should be send immediately

broker_topic_alias_max: u16

topic_alias_maximum RECEIVED via connack packet

max_outgoing_packet_size: Option<u32>

The broker’s max_packet_size received via connack

Implementations

impl MqttState

pub fn new(max_inflight: u16, manual_acks: bool) -> Self

Creates new mqtt state. Same state should be used during a connection for persistent sessions while new state should instantiated for clean sessions

pub fn clean(&mut self) -> Vec<Request>

Returns inflight outgoing packets and clears internal queues

pub fn inflight(&self) -> u16

pub fn handle_outgoing_packet( &mut self, request: Request, ) -> Result<(), StateError>

Consolidates handling of all outgoing mqtt packet logic. Returns a packet which should be put on to the network by the eventloop

pub fn handle_incoming_packet( &mut self, packet: Incoming, ) -> Result<(), StateError>

Consolidates handling of all incoming mqtt packets. Returns a Notification which for the user to consume and Packet which for the eventloop to put on the network E.g For incoming QoS1 publish packet, this method returns (Publish, Puback). Publish packet will be forwarded to user and Pubck packet will be written to network

pub fn handle_protocol_error(&mut self) -> Result<(), StateError>

Trait Implementations

impl Clone for MqttState

fn clone(&self) -> MqttState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MqttState

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

Formats the value using the given formatter.