stem-mqtt-client 0.2.3

An MQTT 3.1.1 / MQTT 5.0 client implemented in Rust with UniFFI bindings for Kotlin, Swift, and Python.
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
45
46
47
48
49
50
51

//! Error types shared across the MQTT client (and re-used by the broker
//! crate for the protocol codec it embeds).

/// Convenience alias for `Result<T, MqttError>`.
pub type MqttResult<T> = Result<T, MqttError>;

/// All errors that can be produced while encoding/decoding MQTT packets or
/// operating an [`crate::client::MqttClient`].
///
/// Exposed to foreign languages through UniFFI as a plain error enum.
#[derive(Debug, thiserror::Error, uniffi::Error)]
#[uniffi(flat_error)]
pub enum MqttError {
    /// The peer sent a packet that violates the MQTT specification.
    #[error("malformed packet: {0}")]
    MalformedPacket(String),

    /// A value could not be encoded/decoded per the wire protocol.
    #[error("protocol error: {0}")]
    Protocol(String),

    /// Underlying I/O failure (connection reset, DNS failure, etc.).
    #[error("io error: {0}")]
    Io(String),

    /// The broker rejected the connection attempt.
    #[error("connection refused: {0}")]
    ConnectionRefused(String),

    /// An operation was attempted while not connected to a broker.
    #[error("not connected")]
    NotConnected,

    /// The client is already connected.
    #[error("already connected")]
    AlreadyConnected,

    /// The peer did not acknowledge a QoS 1/2 packet before the timeout.
    #[error("operation timed out")]
    Timeout,

    /// Generic keep-alive / session error.
    #[error("session error: {0}")]
    Session(String),
}

impl From<std::io::Error> for MqttError {
    fn from(e: std::io::Error) -> Self {
        MqttError::Io(e.to_string())
    }
}