Struct bonsaidb::core::circulate::Relay

pub struct Relay { /* private fields */ }

Manages subscriptions and notifications for PubSub.

Implementations

impl Relay

pub fn create_subscriber(&self) -> Subscriber

Create a new Subscriber for this relay.

pub fn publish<Topic, P>(&self, topic: &Topic, payload: &P) -> Result<(), Error>

where Topic: Serialize, P: Serialize,

Publishes a payload to all subscribers of topic.

Errors

Returns an error if topic or payload fails to serialize with pot.

pub fn publish_raw<Topic, Payload>(&self, topic: Topic, payload: Payload)

where Topic: Into<OwnedBytes>, Payload: Into<OwnedBytes>,

Publishes a payload to all subscribers of topic.

pub fn publish_to_all<'topics, Topics, Topic, Payload>( &self, topics: Topics, payload: &Payload ) -> Result<(), Error>

where Topics: IntoIterator<Item = &'topics Topic> + 'topics, Topic: Serialize + 'topics, Payload: Serialize,

Publishes a payload to all subscribers of topic.

Errors

Returns an error if topics or payload fail to serialize with pot.

pub fn publish_raw_to_all( &self, topics: impl IntoIterator<Item = OwnedBytes>, payload: impl Into<OwnedBytes> )

Publishes a payload to all subscribers of topic.

pub fn publish_message(&self, message: &Message)

Publishes a message to all subscribers of its topic.

Trait Implementations

impl Clone for Relay

fn clone(&self) -> Relay

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for Relay

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

Formats the value using the given formatter.

impl Default for Relay

fn default() -> Relay

Returns the “default value” for a type.