Struct bonsaidb_client::BlockingRemoteSubscriber

pub struct BlockingRemoteSubscriber(_);

A remote PubSub [Subscriber] that blocks the current thread when performing requests.

Trait Implementations

impl Debug for BlockingRemoteSubscriber

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Subscriber for BlockingRemoteSubscriber

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.

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

Subscribe to [Message]s published to topic.

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

Unsubscribe from [Message]s published to topic.