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

Mastra Redis Streams PubSub integration

An async iterable interface for redis streams

An HTTP-based realtime client powered by Redis Streams.

Redis Streams Transport for NestJS.

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

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. A drop in replacement for the built-in microservice Redis transport.

Simple NodeJs consumer and producer for Redis Streams

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

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

redis streams with events handlers

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

Redis Streams adapter for anyq

Redis Streams adapter for @connectum/events

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

Abstract Redis Streams post-processor base for Volontariapp microservices

Event-driven Redis Streams message broker for TypeScript

A message queue based on Redis streams, without dependencies.

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