Struct MqttSink

pub struct MqttSink { /* private fields */ }

Implementations

impl MqttSink

pub fn close(&self)

Close mqtt connection

pub fn publish_qos0(&self, topic: ByteString, payload: Bytes, dup: bool)

Send publish packet with qos set to 0

pub fn publish_qos1( &mut self, topic: ByteString, payload: Bytes, dup: bool, ) -> impl Future<Output = Result<(), ()>>

Send publish packet

Trait Implementations

impl Clone for MqttSink

fn clone(&self) -> MqttSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for MqttSink

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.