Struct esp_idf_svc::mqtt::client::EspAsyncMqttClient

pub struct EspAsyncMqttClient(/* private fields */);

Implementations

impl EspAsyncMqttClient

pub fn new( url: &str, conf: &MqttClientConfiguration<'_> ) -> Result<(Self, EspAsyncMqttConnection), EspError>

pub async fn subscribe( &mut self, topic: &str, qos: QoS ) -> Result<MessageId, EspError>

pub async fn unsubscribe(&mut self, topic: &str) -> Result<MessageId, EspError>

pub async fn publish( &mut self, topic: &str, qos: QoS, retain: bool, payload: &[u8] ) -> Result<MessageId, EspError>

Trait Implementations

impl Client for EspAsyncMqttClient

async fn subscribe( &mut self, topic: &str, qos: QoS ) -> Result<MessageId, Self::Error>

async fn unsubscribe(&mut self, topic: &str) -> Result<MessageId, Self::Error>

impl ErrorType for EspAsyncMqttClient

type Error = EspError

impl Publish for EspAsyncMqttClient

async fn publish( &mut self, topic: &str, qos: QoS, retain: bool, payload: &[u8] ) -> Result<MessageId, Self::Error>