cloudmqtt 0.4.0

A pure Rust MQTT client and server library
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

//
//   This Source Code Form is subject to the terms of the Mozilla Public
//   License, v. 2.0. If a copy of the MPL was not distributed with this
//   file, You can obtain one at http://mozilla.org/MPL/2.0/.
//

use mqtt_format::v3::connect_return::MConnectReturnCode;

use crate::PacketIOError;

#[derive(Debug, thiserror::Error)]
pub enum MqttError {
    #[error("An error occured during the handling of a packet")]
    Packet(#[from] PacketIOError),
    #[error("An IO Error occurred")]
    Io(#[from] std::io::Error),
    #[error("An error during writing to Buffer occurred")]
    Buffer(#[from] mqtt_format::v3::errors::MPacketWriteError),
    #[error("An invalid packet was received")]
    InvalidPacket,
    #[error("The connection was already closed")]
    ConnectionClosed,
    #[error("The client is already listening for packets")]
    AlreadyListening,
    #[error("The server responded with an invalid CONNACK packet")]
    InvalidConnectionResponse,
    #[error("The server rejected the connection with the given code")]
    ConnectionRejected(MConnectReturnCode),
    #[error("Duplex source closed unexpectedly")]
    DuplexSourceClosed,
}