Struct rumqttc_async_std::MqttState

pub struct MqttState {
    pub await_pingresp: bool,
    pub collision_ping_count: usize,
    pub collision: Option<Publish>,
    pub events: VecDeque<Event>,
    pub write: BytesMut,
    // some fields omitted
}

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

Implementations

impl MqttState

pub fn new(max_inflight: u16) -> 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

Trait Implementations

impl Clone for MqttState

fn clone(&self) -> MqttState

Returns a copy of the value.

pub 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.