Struct SessionPubReceiver

pub struct SessionPubReceiver(/* private fields */);

Receive and acknowledge incoming MQTT messages.

Trait Implementations

impl PubReceiver for SessionPubReceiver

fn recv<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Option<Publish>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receives the next incoming publish.

fn recv_manual_ack<'life0, 'async_trait>( &'life0 mut self, ) -> Pin<Box<dyn Future<Output = Option<(Publish, Option<AckToken>)>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Receives the next incoming publish, and a token that can be used to manually acknowledge the publish (Quality of Service 1 or 2), or None (Quality of Service 0).

fn close(&mut self)

Close the receiver, preventing further incoming publishes.