redis-x-stream

An async iterable interface for Redis streams, built on top of ioredis and msgpackr. Version 4.1.0 supports Redis 5+ (6.2+ for claimIdleTime). Provides high-level modules for job queues with workers, retries, backoff, dead-letter queues (import from 'redis-x-stream/queue') and a distributed single-flight cache with two-tier storage (import from 'redis-x-stream/cache'). Features typed parsing, consumer group support with automatic PEL re-delivery, dynamic stream addition, dead consumer recovery via XAUTOCLAIM, flush timers for pending acks, and observability methods (info, groups, consumers, pending). Ships TypeScript declarations. Releases follow semver with monthly cadence.