Struct RedisPubSubSubscriber 

pub struct RedisPubSubSubscriber { /* private fields */ }

A Pub/Sub subscription backed by a dedicated fred client, so its message stream and channel state are isolated from other subscribers and from the publishing pool.

Trait Implementations

impl Debug for RedisPubSubSubscriber

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Drop for RedisPubSubSubscriber

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl Subscriber for RedisPubSubSubscriber

fn stream( &mut self, ) -> impl Stream<Item = Result<Self::Message, Self::Error>> + Send + '_

Yields one message per Pub/Sub delivery.

Cancel safety

Dropping the returned stream between items is safe. Because Pub/Sub has no buffering, any message published while no stream is polling is lost (this is Redis Pub/Sub semantics, not a limitation of this client).

type Message = RedisPubSubMessage

The message type yielded by this subscriber.

type Error = RedisError

The error type yielded by the stream when delivery fails.