Struct Subscriber 

pub struct Subscriber(pub(crate) Vec<Receiver<Result<Publish>>>);

Represents an MQTT subscriber that can receive Publish messages.

Tuple Fields

0: Vec<Receiver<Result<Publish>>>

Implementations

impl Subscriber

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

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

Trait Implementations

impl Clone for Subscriber

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Subscriber

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

Formats the value using the given formatter.