Struct redis_async::client::pubsub::PubsubConnection

pub struct PubsubConnection { /* fields omitted */ }

A shareable reference to subscribe to PUBSUB topics

Methods

impl PubsubConnection

pub fn subscribe(     &self,     topic: &str ) -> impl Future<Item = PubsubStream, Error = Error>

Subscribes to a particular PUBSUB topic.

Returns a future that resolves to a Stream that contains all the messages published on that particular topic.

pub fn unsubscribe<T: Into<String>>(&self, topic: T)

Trait Implementations

impl Clone for PubsubConnection

fn clone(&self) -> PubsubConnection

Returns a copy of the value.

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

Performs copy-assignment from source.