Trait bonsaidb::core::pubsub::PubSub

pub trait PubSub {
    type Subscriber: Subscriber;

    fn create_subscriber(&self) -> Result<Self::Subscriber, Error>;
    fn publish_bytes(
        &self,
        topic: Vec<u8, Global>,
        payload: Vec<u8, Global>
    ) -> Result<(), Error>;
    fn publish_bytes_to_all(
        &self,
        topics: impl IntoIterator<Item = Vec<u8, Global>> + Send,
        payload: Vec<u8, Global>
    ) -> Result<(), Error>;

    fn publish<Topic, Payload>(
        &self,
        topic: &Topic,
        payload: &Payload
    ) -> Result<(), Error>
    where
        Topic: Serialize,
        Payload: Serialize,
    { ... }
    fn publish_to_all<'topics, Topics, Topic, Payload>(
        &self,
        topics: Topics,
        payload: &Payload
    ) -> Result<(), Error>
    where
        Topics: 'topics + IntoIterator<Item = &'topics Topic>,
        Topic: 'topics + Serialize,
        Payload: Serialize,
    { ... }
}

Publishes and Subscribes to messages on topics.

Required Associated Types

type Subscriber: Subscriber

The Subscriber type for this PubSub connection.

Required Methods

fn create_subscriber(&self) -> Result<Self::Subscriber, Error>

Create a new Subscriber for this relay.

fn publish_bytes(
    &self,
    topic: Vec<u8, Global>,
    payload: Vec<u8, Global>
) -> Result<(), Error>

Publishes a payload to all subscribers of topic.

fn publish_bytes_to_all(
    &self,
    topics: impl IntoIterator<Item = Vec<u8, Global>> + Send,
    payload: Vec<u8, Global>
) -> Result<(), Error>

Publishes a payload to all subscribers of all topics.

Provided Methods

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

Publishes a payload to all subscribers of topic.

fn publish_to_all<'topics, Topics, Topic, Payload>(
    &self,
    topics: Topics,
    payload: &Payload
) -> Result<(), Error>where
    Topics: 'topics + IntoIterator<Item = &'topics Topic>,
    Topic: 'topics + Serialize,
    Payload: Serialize,

Publishes a payload to all subscribers of all topics.

Implementors

impl PubSub for RemoteDatabase

type Subscriber = RemoteSubscriber

impl PubSub for Database

type Subscriber = Subscriber