Struct redis_async::client::pubsub::PubsubConnection [−][src]
pub struct PubsubConnection { /* fields omitted */ }
Expand description
A shareable reference to subscribe to PUBSUB topics
Implementations
Subscribes to a particular PUBSUB topic.
Returns a future that resolves to a Stream
that contains all the messages published on
that particular topic.
The resolved stream will end with redis_async::error::Error::EndOfStream
if the
underlying connection is lost for unexpected reasons. In this situation, clients should
subscribe
to re-subscribe; the underlying connect will automatically reconnect. However,
clients should be aware that resubscriptions will only succeed if the underlying connection
has re-established, so multiple calls to subscribe
may be required.
Tells the client to unsubscribe from a particular topic. This will return immediately, the
actual unsubscription will be confirmed when the stream returned from subscribe
ends.
Trait Implementations
Auto Trait Implementations
impl !RefUnwindSafe for PubsubConnection
impl Send for PubsubConnection
impl Sync for PubsubConnection
impl Unpin for PubsubConnection
impl !UnwindSafe for PubsubConnection
Blanket Implementations
Mutably borrows from an owned value. Read more