Struct bonsaidb::core::circulate::Subscriber

pub struct Subscriber { /* private fields */ }

A subscriber for Messages published to subscribed topics.

Implementations

impl Subscriber

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

where Topic: Serialize,

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>(&self, topic: &Topic) -> Result<(), Error>

where Topic: Serialize,

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 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<(), Error>

Formats the value using the given formatter.