async-stream-emitter

EventEmitter using ConsumableStream.

Main methods:

emit(eventName, data)
listener(eventName)
closeListener(eventName)
closeAllListeners()
killListener(eventName)
killAllListeners()
getListenerBackpressure(eventName)
getAllListenersBackpressure()

Usage examples

let emitter = new AsyncStreamEmitter();

(async () => {
  await wait(10);
  emitter.emit('foo', 'hello');

  // This will cause all for-await-of loops for that event to exit.
  // Note that you can also use the 'break' statement inside
  // individual for-await-of loops.
  emitter.closeListener('foo');
})();

(async () => {
  for await (let data of emitter.listener('foo')) {
    // data is 'hello'
  }
  console.log('The listener was closed.');
})();

// Utility function.
function wait(duration) {
  return new Promise((resolve) => {
    setTimeout(() => {
      resolve();
    }, duration);
  });
}

Current Tags

7.0.1 ... latest (2 years ago)

async-stream-emitter

Main methods:

Usage examples

Current Tags

17 Versions