possibility to integrate with redis engine ?

[yasirhantoush]

Can this great library be integrated with redis ?

[peecky]

Do you mean this kind of things?

// main worker
const buffering = new Buffering();
buffering.on('flush', (data) => console.log(data));
redis.on('message', (channel, message) => {
    if (channel !== 'buffering') return;
    buffering.enqueue(JSON.parse(message));
});


// sub workers
redis.publish('buffering', JSON.stringify(['one', 'two']));

[yasirhantoush]

This is ineresting ...
I see the library uses memory for buffers ...
So I was thinking about using redis for storing the buffers ...
This way the buffers can survive restarts ...