Struct mqtt_service::Connection

pub struct Connection { /* private fields */ }

Handle to the connection

Implementations

impl Connection

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

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

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

Implement call service using the MQTT Request-Response pattern

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

Create a new service on the topic, the handler will be called