Package Exports

async-stream-emitter
async-stream-emitter/index.js

This package does not declare an exports field, so the exports above have been automatically detected and optimized by JSPM instead. If any package subpath is missing, it is recommended to post an issue to the original package (async-stream-emitter) to support the "exports" field. If that is not possible, create a JSPM override to customize the exports field for this package.

Readme

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);
  });
}