Struct circulate::Subscriber

pub struct Subscriber { /* fields omitted */ }

A subscriber for Messages published to subscribed topics.

Implementations

impl Subscriber

pub async fn subscribe_to<S: Into<String> + Send>(&self, topic: S)

Subscribe to Messages published to topic.

pub async fn unsubscribe_from(&self, topic: &str)

Unsubscribe from Messages published to topic.

pub fn receiver(&self) -> &Receiver<Arc<Message>>

Returns the receiver to receive Messages.

pub fn id(&self) -> u64

Returns the unique ID of the subscriber.

Trait Implementations

impl Clone for Subscriber

fn clone(&self) -> Subscriber

Returns a copy 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.