mesquitte-core 0.1.0

MQTT v3.1.1/v5.0 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

use std::sync::Arc;

use state::GlobalState;
use tokio::io::{split, AsyncRead, AsyncWrite};

use crate::protocols::v4::read_write_loop::read_write_loop;

pub mod config;
#[cfg(feature = "quic")]
pub mod quic;
#[cfg(feature = "rustls")]
pub mod rustls;
pub mod state;
#[cfg(any(feature = "mqtt", feature = "mqtts"))]
pub mod tcp;
#[cfg(any(feature = "ws", feature = "wss"))]
pub mod ws;

async fn process_client<S>(stream: S, global: Arc<GlobalState>)
where
    S: AsyncRead + AsyncWrite + Send + 'static,
{
    let (rd, wr) = split(stream);
    read_write_loop(rd, wr, global).await;
}