mqrstt 0.4.2

Pure rust MQTTv5 client implementation Smol and Tokio
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
43
44

use async_channel::{Receiver, Sender, TrySendError};

#[cfg(feature = "logs")]
use tracing::{debug, error};

use crate::error::HandlerError;

#[derive(Debug, Clone)]
pub(crate) struct AvailablePacketIds {
    sender: Sender<u16>,
}

impl AvailablePacketIds {
    pub fn new(max_inflight: u16) -> (Self, Receiver<u16>) {
        let (s, r) = async_channel::bounded(max_inflight as usize);

        for pkid in 1..=max_inflight {
            s.send_blocking(pkid).unwrap();
        }

        let apkid = Self { sender: s };
        (apkid, r)
    }

    pub(crate) fn mark_available(&self, pkid: u16) -> Result<(), HandlerError> {
        match self.sender.try_send(pkid) {
            Ok(_) => {
                #[cfg(feature = "logs")]
                debug!("Marked packet id as available: {}", pkid);
                Ok(())
            }
            Err(TrySendError::Closed(pkid)) => {
                #[cfg(feature = "logs")]
                error!("Packet Id channel was closed");
                Err(HandlerError::PacketIdChannelError(pkid))
            }
            Err(TrySendError::Full(_)) => {
                // There can never be more than the predetermined number of packet ids.
                // Meaning that they then all fit in the channel
                unreachable!()
            }
        }
    }
}