Struct Subscriber

pub struct Subscriber { /* private fields */ }

A subscriber for Messages published to subscribed topics.

Implementations

impl Subscriber

pub fn subscribe_to<Topic: Serialize>(&self, topic: &Topic) -> Result<(), Error>

Subscribe to Messages published to topic.

Errors

Returns an error if topic fails to serialize with pot.

pub fn subscribe_to_raw(&self, topic: impl Into<OwnedBytes>)

Subscribe to Messages published to topic.

pub fn unsubscribe_from<Topic: Serialize>( &self, topic: &Topic, ) -> Result<(), Error>

Unsubscribe from Messages published to topic.

Errors

Returns an error if topic fails to serialize with pot.

pub fn unsubscribe_from_raw(&self, topic: &[u8])

Unsubscribe from Messages published to topic.

pub fn receiver(&self) -> &Receiver<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 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.