Struct SessionManagedClient

pub struct SessionManagedClient<PS>
where
    PS: MqttPubSub + Clone + Send + Sync,
{ /* private fields */ }

An MQTT client that has it’s connection state externally managed by a Session. Can be used to send messages and create receivers for incoming messages.

Trait Implementations

impl<PS> Clone for SessionManagedClient<PS>

where PS: MqttPubSub + Clone + Send + Sync + Clone,

fn clone(&self) -> SessionManagedClient<PS>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<PS> ManagedClient for SessionManagedClient<PS>

where PS: MqttPubSub + Clone + Send + Sync,

type PubReceiver = SessionPubReceiver

The type of receiver used by this client

fn client_id(&self) -> &str

Get the client id for the MQTT connection

fn create_filtered_pub_receiver( &self, topic_filter: &str, ) -> Result<SessionPubReceiver, TopicParseError>

Creates a new PubReceiver that receives messages on a specific topic

fn create_unfiltered_pub_receiver(&self) -> SessionPubReceiver

Creates a new PubReceiver that receives all messages not sent to other filtered receivers.

impl<PS> MqttPubSub for SessionManagedClient<PS>

where PS: MqttPubSub + Clone + Send + Sync,

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

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

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

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

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

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