Trait MqttPubSub

pub trait MqttPubSub {
    // Required methods
    fn publish<'life0, 'async_trait>(
        &'life0 self,
        topic: impl 'async_trait + Into<String> + Send,
        qos: QoS,
        retain: bool,
        payload: impl 'async_trait + Into<Bytes> + Send,
    ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn publish_with_properties<'life0, 'async_trait>(
        &'life0 self,
        topic: impl 'async_trait + Into<String> + Send,
        qos: QoS,
        retain: bool,
        payload: impl 'async_trait + Into<Bytes> + Send,
        properties: PublishProperties,
    ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn subscribe<'life0, 'async_trait>(
        &'life0 self,
        topic: impl 'async_trait + Into<String> + Send,
        qos: QoS,
    ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn subscribe_with_properties<'life0, 'async_trait>(
        &'life0 self,
        topic: impl 'async_trait + Into<String> + Send,
        qos: QoS,
        properties: SubscribeProperties,
    ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn unsubscribe<'life0, 'async_trait>(
        &'life0 self,
        topic: impl 'async_trait + Into<String> + Send,
    ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
    fn unsubscribe_with_properties<'life0, 'async_trait>(
        &'life0 self,
        topic: impl 'async_trait + Into<String> + Send,
        properties: UnsubscribeProperties,
    ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait;
}

MQTT publish, subscribe and unsubscribe functionality

Required Methods

fn publish<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, retain: bool, payload: impl 'async_trait + Into<Bytes> + Send, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

MQTT Publish

If connection is unavailable, publish will be queued and delivered when connection is re-established. Blocks if at capacity for queueing.

fn publish_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, retain: bool, payload: impl 'async_trait + Into<Bytes> + Send, properties: PublishProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

MQTT Publish

If connection is unavailable, publish will be queued and delivered when connection is re-established. Blocks if at capacity for queueing.

fn subscribe<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

MQTT Subscribe

If connection is unavailable, subscribe will be queued and delivered when connection is re-established. Blocks if at capacity for queueing.

fn subscribe_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, properties: SubscribeProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

MQTT Subscribe

If connection is unavailable, subscribe will be queued and delivered when connection is re-established. Blocks if at capacity for queueing.

fn unsubscribe<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

MQTT Unsubscribe

If connection is unavailable, unsubscribe will be queued and delivered when connection is re-established. Blocks if at capacity for queueing.

fn unsubscribe_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, properties: UnsubscribeProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

MQTT Unsubscribe

If connection is unavailable, unsubscribe will be queued and delivered when connection is re-established. Blocks if at capacity for queueing.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl MqttPubSub for AsyncClient

fn publish<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, retain: bool, payload: impl 'async_trait + Into<Bytes> + Send, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn publish_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, retain: bool, payload: impl 'async_trait + Into<Bytes> + Send, properties: PublishProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, PublishError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn subscribe_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, qos: QoS, properties: SubscribeProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, SubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn unsubscribe<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

fn unsubscribe_with_properties<'life0, 'async_trait>( &'life0 self, topic: impl 'async_trait + Into<String> + Send, properties: UnsubscribeProperties, ) -> Pin<Box<dyn Future<Output = Result<CompletionToken, UnsubscribeError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Implementors

impl MqttPubSub for MockClient

impl MqttPubSub for azure_iot_operations_mqtt::session::SessionManagedClient

impl<PS> MqttPubSub for azure_iot_operations_mqtt::session::managed_client::SessionManagedClient<PS>

where PS: MqttPubSub + Clone + Send + Sync,