Struct for_mqtt_client::Client

pub struct Client { /* private fields */ }

Implementations

impl Client

pub async fn publish<T: Into<Arc<String>>, D: Into<Bytes>>( &self, topic: T, qos: QoS, payload: D, retain: bool ) -> Result<u32, ClientErr>

pub async fn publish_with_trace_id<T: Into<Arc<String>>, D: Into<Bytes>>( &self, topic: T, qos: QoS, payload: D, retain: bool, trace_id: u32 ) -> Result<(), ClientErr>

pub async fn publish_by_arc<T: Into<Arc<String>>>( &self, topic: T, qos: QoS, payload: Arc<Bytes>, retain: bool ) -> Result<u32, ClientErr>

pub async fn to_subscribe<T: Into<String>>( &self, topic: T, qos: QoS ) -> Result<u32, ClientErr>

pub async fn to_subscribe_with_trace_id<T: Into<String>>( &self, topic: T, qos: QoS, id: u32 ) -> Result<(), ClientErr>

pub async fn unsubscribe(&self, topic: String) -> Result<u32, ClientErr>

pub async fn unsubscribe_with_trace_id( &self, topic: String, id: u32 ) -> Result<(), ClientErr>

pub async fn disconnect(&self) -> Result<(), ClientErr>

Trait Implementations

impl Clone for Client

fn clone(&self) -> Client

Returns a copy of the value.

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

Performs copy-assignment from source.

impl ToWorker for Client

fn name() -> String