node-redis-stream-list

Node readable and writable streams for redis list

Readable

Readable stream read all list elements using redis lpop. When there is no more elements in the list, stream emits an end event.

Writable

Writable stream push elements at the end of the list using redis rpush. When all elements are pushed, stream emit a finish event.

Usage

In this sample you will see how to write object and read object from a list

const writeStream = new Writable({
    "redisClient": redisClient,
    "listKey": "sample-list-key",
    "objectMode": true
});
const input = new PassThrough({"objectMode": true});
input.write({"data": "data1"});
input.write({"data": "data1"});
input.push(null);
input.pipe(writeStream).on("finish", () => {
    process.stdout.write("write finish\n");
    const readStream = new Readable({
        "redisClient": redisClient,
        "objectMode": true,
        "listKey": "sample-list-key"
    });
    readStream.on("data", (data) => {
        process.stdout.write("data: " + JSON.stringify(data) + "\n");
    });
    readStream.on("end", () => {
        process.stdout.write("read end\n");
        redisClient.quit();
    });
});