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

#[cfg(all(feature = "quic"))]
pub mod quic;
#[cfg(feature = "smol")]
pub mod smol_stream;
#[cfg(feature = "tokio")]
pub mod tokio_stream;

use crate::connect_options::ConnectOptions;
use crate::packets::Connect;
use crate::packets::Packet;

pub fn create_connect_from_options(options: &ConnectOptions) -> Packet {
    let mut connect = Connect {
        client_id: options.client_id.clone(),
        clean_session: options.clean_session,
        keep_alive: options.keep_alive_interval_s as u16,
        username: options.username.clone(),
        password: options.password.clone(),
        ..Default::default()
    };

    connect.connect_properties.request_problem_information = options.request_problem_information;
    connect.connect_properties.request_response_information = options.request_response_information;

    Packet::Connect(connect)
}