Struct Subscriber

pub struct Subscriber<T> { /* private fields */ }

Low-level MQTT message subscriber with manual unsubscription

Implementations

impl<T> Subscriber<T>

pub fn new( receiver: Receiver<(Arc<TopicMatch>, Arc<T>)>, unsubscribe_tx: Sender<SubscriptionId>, id: SubscriptionId, ) -> Subscriber<T>

Creates a new subscriber with the given channels.

pub async fn recv(&mut self) -> Option<(Arc<TopicMatch>, Arc<T>)>

Receives the next message from subscription.

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

Unsubscribes from the topic pattern.

pub fn unsubscribe_immediate( &mut self, ) -> Result<(), TrySendError<SubscriptionId>>

Immediately unsubscribes without waiting.

Trait Implementations

impl<T> Debug for Subscriber<T>

where T: Debug,

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

Formats the value using the given formatter.

impl<T> Drop for Subscriber<T>

fn drop(&mut self)

Executes the destructor for this type.