Struct Client

pub struct Client { /* private fields */ }

Handle to the connection

Implementations

impl Client

pub fn new(client: Client) -> Client

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

pub async fn call_raw_service( self, topic: impl Into<String>, message: impl Into<Bytes>, content_type: Option<String>, ) -> Result<Bytes, Error>

Implement call service using the MQTT Request-Response pattern

pub async fn create_raw_service( self, topic: impl Into<String>, handler: Box<dyn Send + Sync + Fn(Bytes) -> (Bytes, Option<String>)>, cap: usize, ) -> Result<(), Error>

Create a new service on the topic, the handler will be called cap is the capacity of the input channel

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.