Trait bonsaidb::core::pubsub::Subscriber[][src]

pub trait Subscriber {
    fn subscribe_to_bytes(&self, topic: Vec<u8, Global>) -> Result<(), Error>;
fn unsubscribe_from_bytes(&self, topic: &[u8]) -> Result<(), Error>;
fn receiver(&self) -> &Receiver
Notable traits for Receiver
impl Iterator for Receiver type Item = Message;
; fn subscribe_to<Topic>(&self, topic: &Topic) -> Result<(), Error>
    where
        Topic: Serialize
, { ... }
fn unsubscribe_from<Topic>(&self, topic: &Topic) -> Result<(), Error>
    where
        Topic: Serialize
, { ... } }
Expand description

A subscriber to one or more topics.

Required methods

Subscribe to Messages published to topic.

Unsubscribe from Messages published to topic.

Returns the receiver to receive Messages.

Provided methods

Subscribe to Messages published to topic.

Unsubscribe from Messages published to topic.

Implementors