Struct redis_async::client::pubsub::PubsubConnection
[−]
[src]
pub struct PubsubConnection { /* fields omitted */ }
Methods
impl PubsubConnection[src]
fn subscribe<T: Into<String>>(
&self,
topic: T
) -> Box<Future<Item = Box<Stream<Item = RespValue, Error = ()>>, Error = Error>>[src]
&self,
topic: T
) -> Box<Future<Item = Box<Stream<Item = RespValue, Error = ()>>, 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.
Trait Implementations
impl Clone for PubsubConnection[src]
fn clone(&self) -> PubsubConnection[src]
Returns a copy of the value. Read more
fn clone_from(&mut self, source: &Self)1.0.0[src]
Performs copy-assignment from source. Read more