redis-x-stream

An async iterable that emits redis stream entries. Requires Redis 5 or greater.

Getting Started

import streamEntries from 'redis-x-stream'

for await (const [stream, [id, keyvals]] of streamEntries('myStream')) {
  //process an entry
}