mqrstt 0.1.3

Pure rust MQTTv5 client implementation for Smol, Tokio and soon sync too.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42

use std::collections::{BTreeMap, BTreeSet};

use async_channel::Receiver;

use crate::{
    available_packet_ids::AvailablePacketIds,
    packets::{Publish, Subscribe, Unsubscribe},
};

#[derive(Debug)]
pub struct State {
    pub(crate) apkid: AvailablePacketIds,

    /// Outgoing Subcribe requests which aren't acked yet
    pub(crate) outgoing_sub: BTreeMap<u16, Subscribe>,
    /// Outgoing Unsubcribe requests which aren't acked yet
    pub(crate) outgoing_unsub: BTreeMap<u16, Unsubscribe>,
    /// Outgoing QoS 1, 2 publishes which aren't acked yet
    pub(crate) outgoing_pub: BTreeMap<u16, Publish>,
    /// Packet ids of released QoS 2 publishes
    pub(crate) outgoing_rel: BTreeSet<u16>,

    /// Packets on incoming QoS 2 publishes
    pub(crate) incoming_pub: BTreeSet<u16>,
}

impl State {
    pub fn new(receive_maximum: u16) -> (Self, Receiver<u16>) {
        let (apkid, r) = AvailablePacketIds::new(receive_maximum);

        let state = Self {
            apkid,
            outgoing_sub: BTreeMap::new(),
            outgoing_unsub: BTreeMap::new(),
            outgoing_pub: BTreeMap::new(),
            outgoing_rel: BTreeSet::new(),
            incoming_pub: BTreeSet::new(),
        };

        (state, r)
    }
}