@lucemans/streams v1.3.0

@lucemans

Streams

How to use

On the sending end

const stream = new GenericStream(client, 'topic');
await stream.push('test-string');

On the receiving end

const stream = new GenericStream(client, 'topic');
const result = await stream.pop();
console.log(result.value);