Struct RedisPubSub

pub struct RedisPubSub<'a, K: Clone + Eq + Hash, V: Clone + Eq + Hash + DeserializeOwned + Serialize, D: DeserializeOwned + Serialize> {
    pub hive: Hive<K, V, D>,
    /* private fields */
}

Available on crate feature redis-backend only.

Redis pubsub

Fields

hive: Hive<K, V, D>

Implementations

impl<'a, K: Clone + Eq + Hash, V: Clone + Eq + Hash + DeserializeOwned + Serialize + From<String>, D: DeserializeOwned + Serialize> RedisPubSub<'a, K, V, D>

pub fn new<F: 'static + Fn(Vec<K>, D) + Send>( callback: F, pool: &'a Pool<RedisConnectionManager>, pubsub: Arc<Mutex<RedisPS>>, ) -> RedisPubSub<'a, K, V, D>

pub async fn listen(&mut self) -> Result<(), String>

Subscribe to all incoming data.

pub fn set_source(&mut self, source: String)

Set the id of this source.

Used for testing.

Trait Implementations

impl<'a, K: Clone + Clone + Eq + Hash, V: Clone + Clone + Eq + Hash + DeserializeOwned + Serialize, D: Clone + DeserializeOwned + Serialize> Clone for RedisPubSub<'a, K, V, D>

fn clone(&self) -> RedisPubSub<'a, K, V, D>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<'a, K: Clone + Eq + Hash, V: Clone + Eq + Hash + DeserializeOwned + Serialize, D: DeserializeOwned + Serialize> PubSub<K, V, D> for RedisPubSub<'a, K, V, D>

fn drop_client(&self, id: &K) -> Result<(), String>

Remove a client from the Hive.

fn drop_topic(&self, id: &V) -> Result<(), String>

Remove a topic from the hive.

fn subscribe(&self, client: K, topic: V) -> Result<(), String>

Add a subscription to a topic.

fn subscribe_multiple(&self, client: K, topics: Vec<V>) -> Result<(), String>

Add several subscriptions to a topic.

fn unsubscribe(&self, client: &K, topic: &V) -> Result<(), String>

Remove a subscription to a topic.

fn unsubscribe_multiple( &self, client: &K, topics: &Vec<V>, ) -> Result<(), String>

Remove several subscriptions to a topic.

fn publish(&self, _topic: &V, _data: D) -> Result<(), String>

Publish a message for a topic in the Hive.