Trait bonsaidb_core::pubsub::Subscriber

pub trait Subscriber {
    // Required methods
    fn subscribe_to_bytes(&self, topic: Vec<u8>) -> Result<(), Error>;
    fn unsubscribe_from_bytes(&self, topic: &[u8]) -> Result<(), Error>;
    fn receiver(&self) -> &Receiver ;

    // Provided methods
    fn subscribe_to<Topic: Serialize>(&self, topic: &Topic) -> Result<(), Error> { ... }
    fn unsubscribe_from<Topic: Serialize>(
        &self,
        topic: &Topic
    ) -> Result<(), Error> { ... }
}

A subscriber to one or more topics.

Required Methods

fn subscribe_to_bytes(&self, topic: Vec<u8>) -> Result<(), Error>

Subscribe to [Message]s published to topic.

fn unsubscribe_from_bytes(&self, topic: &[u8]) -> Result<(), Error>

Unsubscribe from [Message]s published to topic.

fn receiver(&self) -> &Receiver

Returns the receiver to receive [Message]s.

Provided Methods

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

Subscribe to [Message]s published to topic.

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

Unsubscribe from [Message]s published to topic.

Object Safety

This trait is not object safe.

Implementors