event-emitter-promisify

Utility to resolve EventEmitters as a promise

Usage

By default promisifyEventEmitter returns a promise which resolves to undefined if the end event is called, and rejects if the error event is called.

1import { promisifyEventEmitter } from 'event-emitter-promisify'
2
3const stream = new Readable();
4stream.push(null);
5await promisifyEventEmitter(stream.on('data', () => {}));

The return value on end can also be customized. For instance:

1export default function arrayifyStream<T = any>(stream: EventEmitter): Promise<T[]> {
2  const array: T[] = [];
3  return promisifyEventEmitter(stream.on('data', data => array.push(data)), array);
4}

License

©2022–present Jesse Wright, MIT License.