Extends the node redis client with readStream, writeStream, and writeThrough functions.

Mastra Redis Streams PubSub integration

The Socket.IO adapter based on Redis Streams, allowing to broadcast events between several Socket.IO servers

An async iterable interface for redis streams

An HTTP-based realtime client powered by Redis Streams.

The Socket.IO Redis streams emitter, allowing to communicate with a group of Socket.IO servers from another Node.js process

Redis Streams Transport for NestJS.

Redis Streams Library for Node.js/Typescript with full consumer group recovery

Redis Streams-based transporter for NestJS microservices, enabling message passing via Redis Streams

Redis Streams Transport for NestJS. A drop in replacement for the built-in microservice Redis transport.

Simple NodeJs consumer and producer for Redis Streams

Redis Streams adapter for anyq

Redis streams adapter for Motia framework, enabling distributed stream management with real-time updates.

Redis Streams adapter for @connectum/events

Redis Streams plugin for NestJS RedisX with consumer groups, dead-letter queues, and backpressure

Redis Streams server destination for walkerOS (ioredis, XADD, pipeline batching)

Abstract Redis Streams post-processor base for Volontariapp microservices

A Fastify plugin for channels implementation based on Redis streams.

A message queue based on Redis streams, without dependencies.

Distributed event bus library with pluggable transports (Redis Streams / DragonflyDB)