Struct RedisSubscriber 

pub struct RedisSubscriber { /* private fields */ }

A Redis Streams subscription bound to a consumer group.

Constructed by crate::RedisBroker::subscribe from a crate::RedisStream descriptor. The read mode (fresh tail vs reclaim) is fixed at construction.

Trait Implementations

impl BatchSubscriber for RedisSubscriber

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

Yields one batch per non-empty read (XREADGROUP COUNT / XAUTOCLAIM), up to RedisStream::count entries. Never yields an empty batch.

Cancel safety

Same as Subscriber::stream: dropping the stream mid-read leaves fetched-but-unacked entries in the pending list.

type Batch = Vec<RedisMessage>

Container yielded by batches. Implementations choose between Vec, custom iterators, or anything else that yields the underlying Subscriber::Message.

impl Debug for RedisSubscriber

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

Formats the value using the given formatter.

impl Subscriber for RedisSubscriber

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

Yields one message per entry, refilling from Redis when the local buffer drains.

Cancel safety

Dropping the returned stream between items is safe. Dropping it while a read is in flight drops the read future; entries already delivered to this consumer but not yet acked stay in the group’s pending list and are redelivered (fresh mode) or reclaimable (reclaim mode).

type Message = RedisMessage

The message type yielded by this subscriber.

type Error = RedisError

The error type yielded by the stream when delivery fails.