Struct OwnedSubscriber 

pub struct OwnedSubscriber {
    pub(crate) subscriber: Subscriber,
    pub(crate) topics: Vec<String>,
    pub(crate) mqtt: MqttClient,
}

Represents an MQTT subscriber that owns the underlying subscriber and tracks the subscribed topics. When the OwnedSubscriber is dropped, it will unsubscribe from all the subscribed topics.

Fields

subscriber: Subscriber

topics: Vec<String>

mqtt: MqttClient

Implementations

impl OwnedSubscriber

pub async fn recv(&mut self) -> Result<Publish>

Asynchronously receives a Publish message from one of the underlying receivers.

Trait Implementations

impl Debug for OwnedSubscriber

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

Formats the value using the given formatter.

impl Drop for OwnedSubscriber

fn drop(&mut self)

Executes the destructor for this type.