Struct MqttClient

pub struct MqttClient { /* private fields */ }

Implementations

impl MqttClient

pub fn set_on_message_callback<F>(&self, callback: F)

where F: Fn(&Message) + Send + Sync + 'static,

pub fn set_on_connected_callback<F>(&self, callback: F)

where F: Fn() + Send + Sync + 'static,

pub fn publish_raw(&self, message: Message) -> Result<()>

Publish MQTT message

pub fn tx_pending(&self) -> usize

How many messages are waiting to be send

pub fn publish_json<S, T>( &self, topic: S, payload: &T, retained: bool, qos: QoS, expiry_interval: Option<Duration>, ) -> Result<()>

where S: Into<String>, T: ?Sized + Serialize,

Publish message as json (feature json has to be enabled)

Trait Implementations

impl Clone for MqttClient

fn clone(&self) -> MqttClient

Returns a duplicate of the value.

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

Performs copy-assignment from source.