Struct MqttSubscriber 

pub struct MqttSubscriber { /* private fields */ }

A subscription to one MQTT topic filter; yields MqttMessages.

Delivery back-pressure is the protocol’s receive-maximum: the broker bounds unacked QoS 1/2 deliveries, so unsettled messages cap what sits in this subscriber’s queue (QoS 0 has no such bound by design). Dropping the subscriber unsubscribes the filter.

Implementations

impl MqttSubscriber

pub fn filter(&self) -> &str

The plain topic filter this subscription matches.

Trait Implementations

impl Debug for MqttSubscriber

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

Formats the value using the given formatter.

impl Drop for MqttSubscriber

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Subscriber for MqttSubscriber

type Message = MqttMessage

The message type yielded by this subscriber.

type Error = MqttError

The error type yielded by the stream when delivery fails.

fn stream( &mut self, ) -> impl Stream<Item = Result<MqttMessage, MqttError>> + Send + '_

Returns a stream of broker deliveries.