Struct MqttClient 

pub struct MqttClient<'a, 'n, 'l, M: RawMutex, NET, DNS, const BUFFER: usize, const TOPIC: usize, const QUEUE: usize>
where
    NET: TcpConnect,
    DNS: Dns,
{ /* private fields */ }

The MQTT Client to publish messages, subscribe, unsubscribe and receive messages

Implementations

impl<'a, 'n, 'l, M: RawMutex, NET, DNS, const BUFFER: usize, const TOPIC: usize, const QUEUE: usize> MqttClient<'a, 'n, 'l, M, NET, DNS, BUFFER, TOPIC, QUEUE>

where NET: TcpConnect, DNS: Dns,

pub async fn on_auto_subscribes_done(&self)

pub async fn publish( &self, topic: &str, payload: &[u8], qos: QoS, retain: bool, ) -> Result<(), MqttError>

Publish a MQTT message with the given parameters

Waits until there is a successful publish result. The publish is successful after all acknolodgements accordings to the selected QoS have bee exchanged

pub async fn subscribe(&self, topic: &str, qos: QoS) -> Result<(), MqttError>

Subscribe to a topic

The method returns after the suback has bee received

pub async fn unsubscribe(&self, topic: &str) -> Result<(), MqttError>

unsubscribe from a topic

waits until the unsuback has bee received

pub fn disconnect(&self)

send a disconnect packet to the broker

pub fn subscribe_received_publishes( &self, ) -> Result<DynSubscriber<'_, ReceivedPublish<BUFFER, TOPIC>>, MqttError>

Subscribe to received publishes

Trait Implementations

impl<'a, 'n, 'l, M: Clone + RawMutex, NET, DNS, const BUFFER: usize, const TOPIC: usize, const QUEUE: usize> Clone for MqttClient<'a, 'n, 'l, M, NET, DNS, BUFFER, TOPIC, QUEUE>

where NET: TcpConnect + Clone, DNS: Dns + Clone,

fn clone(&self) -> MqttClient<'a, 'n, 'l, M, NET, DNS, BUFFER, TOPIC, QUEUE>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.