Struct MqttClient 

pub struct MqttClient<'a, M: RawMutex> { /* private fields */ }

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

Implementations

impl<'a, M: RawMutex> MqttClient<'a, M>

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) -> 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 async fn receive(&self) -> MqttPublish

Waits for the next message

pub async fn disconnect(&self)

send a disconnect packet to the broker

pub async fn on<F>(&self, matcher: F)

where F: Fn(&MqttEvent) -> bool,

wait for the next event matching the matcher

Trait Implementations

impl<'a, M: Clone + RawMutex> Clone for MqttClient<'a, M>

fn clone(&self) -> MqttClient<'a, M>

Returns a duplicate of the value.

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

Performs copy-assignment from source.