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 fn build_from_url(url: impl Into<String>) -> Result<ClientBuilder>

Create a new MQTT Client from the given url of the form mqtt://example.com:1883?client_id=123

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, cap: usize, ) -> 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, cap: usize, ) -> 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 duplicate of the value.

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

Performs copy-assignment from source.