@teqm/redis-streams v0.1.5

@teqm/redis-streams

Installation

npm install @teqm/redis-streams

or

yarn add @teqm/redis-streams

Usage

import RedisStreams from '@teqm/redis-streams';

const streams = new RedisStreams();

const stream = streams.stream('stream');

const group = await stream.createGroup('group');

const consumer = group.consumer('consumer');

consumer.on('message', async (message) => {
  console.log(message);

  await group.ack(message.id);
});

consumer.on('error', (err) => {
  console.error(err);

  streams.disconnect();
})

await stream.publish('foo');