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

use bytes::{Bytes, BytesMut};

use super::error::{DeserializeError, SerializeError};

pub trait VariableHeaderRead: Sized {
    fn read(flags: u8, remaining_length: usize, buf: Bytes) -> Result<Self, DeserializeError>;
}

pub trait VariableHeaderWrite: Sized {
    fn write(&self, buf: &mut BytesMut) -> Result<(), SerializeError>;
}

pub trait WireLength {
    fn wire_len(&self) -> usize;
}

pub trait MqttRead: Sized {
    fn read(buf: &mut Bytes) -> Result<Self, DeserializeError>;
}

pub trait MqttWrite: Sized {
    fn write(&self, buf: &mut BytesMut) -> Result<(), SerializeError>;
}

#[deprecated(note = "Implement MqttRead or MqttWrite.")]
pub trait SimpleSerialize: Sized {
    fn read(buf: &mut Bytes) -> Result<Self, String>;

    fn write(&self, buf: &mut BytesMut);
}