Struct Client

pub struct Client { /* private fields */ }

Handle to the connection

Implementations

impl Client

pub fn build( node_id: impl Into<String>, hostname: impl Into<String>, port: u16, ) -> ClientBuilder

Create a new MQTT Client, with the given name to connect at the given and MQTT broker

pub async fn publish_raw( self, topic: impl Into<String>, qos: QoS, retain: bool, payload: impl Into<Bytes>, properties: Option<PublishProperties>, ) -> Result<()>

Publish a message on a topic

pub async fn create_raw_subscription( self, topic: impl Into<String>, qos: QoS, ) -> Result<Receiver<RawMessage>>

Create a raw subscription

pub fn get_raw_subscription( &self, topic: impl Into<String>, ) -> Result<Receiver<RawMessage>>

Get an existing subscription

pub async fn get_or_create_raw_subscription( self, topic: impl Into<String>, qos: QoS, ) -> Result<Receiver<RawMessage>>

Get an existing subscription, or create a new one with the given QoS This function is guaranteed to return, however if the subscription already exists, the QoS is ignored.

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.