Struct MqttSubscriber

pub struct MqttSubscriber<T, F> { /* private fields */ }

Typed MQTT subscriber for topic patterns.

Created via MqttClient::subscribe(). Automatically deserializes messages.

Implementations

impl<T, F> MqttSubscriber<T, F>

where T: Send + Sync + 'static, F: MessageSerializer<T>,

pub fn new(subscriber: Subscriber<Bytes>, serializer: F) -> MqttSubscriber<T, F>

Creates typed subscriber from raw byte subscriber.

pub async fn receive( &mut self, ) -> Option<(Arc<TopicMatch>, Result<T, <F as MessageSerializer<T>>::DeserializeError>)>

Receive next message from subscription.

Returns None when subscription is closed or cancelled.

pub async fn cancel(self) -> Result<(), SendError<SubscriptionId>>

Cancels subscription and unsubscribes from MQTT broker.