Struct MqttState

pub struct MqttState {
    pub connection_status: MqttConnectionStatus,
    pub await_pingresp: bool,
    pub last_incoming: Instant,
    pub last_outgoing: Instant,
    pub last_pkid: PacketIdentifier,
    pub outgoing_pub: VecDeque<Publish>,
    pub outgoing_rel: VecDeque<PacketIdentifier>,
    pub incoming_pub: VecDeque<PacketIdentifier>,
}

State of the mqtt connection.

Fields

connection_status: MqttConnectionStatus

Connection status

await_pingresp: bool

Status of last ping

last_incoming: Instant

Last incoming packet time

last_outgoing: Instant

Last outgoing packet time

last_pkid: PacketIdentifier

Packet id of the last outgoing packet

outgoing_pub: VecDeque<Publish>

Outgoing QoS 1, 2 publishes which aren’t acked yet

outgoing_rel: VecDeque<PacketIdentifier>

Packet ids of released QoS 2 publishes

incoming_pub: VecDeque<PacketIdentifier>

Packet ids on incoming QoS 2 publishes

Implementations

impl MqttState

pub fn new() -> 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 handle_outgoing_connect(&mut self) -> Result<(), StateError>

pub fn handle_incoming_connack( &mut self, packet: Packet, ) -> Result<(), StateError>

Trait Implementations

impl Clone for MqttState

fn clone(&self) -> MqttState

Returns a copy 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.