mqtt-wasi 0.1.0

Minimal MQTT v5.0 client that compiles to wasm32-wasip2
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
52

//! Minimal MQTT v5.0 client that compiles to `wasm32-wasip2`.
//!
//! Two client modes:
//! - [`MqttClient`] — synchronous, blocking pub/sub
//! - [`AsyncMqttClient`] — cooperative non-blocking request/reply for concurrent
//!   calls via `tokio::join!`
//!
//! Optional TLS via the `tls` feature (pure Rust crypto, Wasm-compatible).
//!
//! See the [README](https://github.com/mmbarness/mqtt-wasi) for full usage examples.

#![cfg_attr(not(feature = "std"), no_std)]

#[cfg(not(feature = "std"))]
extern crate alloc;

pub mod codec;
pub mod error;
pub mod trace;

#[cfg(feature = "std")]
pub mod transport;
#[cfg(feature = "std")]
pub mod client;
#[cfg(feature = "std")]
pub mod options;
#[cfg(feature = "std")]
pub mod frame;
#[cfg(feature = "std")]
pub mod async_client;
#[cfg(feature = "std")]
pub mod request;
#[cfg(feature = "tls")]
pub mod tls;

// Re-exports for convenience
pub use crate::codec::types::{Packet, QoS};
pub use crate::error::Error;
pub use crate::trace::TraceContext;

#[cfg(feature = "std")]
pub use crate::client::{Message, MqttClient, RawMessage, Subscription};
#[cfg(feature = "std")]
pub use crate::options::ConnectOptions;
#[cfg(feature = "std")]
pub use crate::transport::Transport;
#[cfg(feature = "std")]
pub use crate::async_client::AsyncMqttClient;
#[cfg(feature = "std")]
pub use crate::request::{RequestEnvelope, ReplyEnvelope};
#[cfg(feature = "tls")]
pub use crate::tls::TlsTransport;