12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455 |
- /**
- * @fileoverview A set of helper functions to make it easier to work
- * with events in async/await manner.
- */
- /**
- * @param {!EventTarget} target
- * @param {string} eventName
- * @return {!Promise<!Event>}
- */
- export const waitForEvent = (target: EventTarget, eventName: string) => {
- return new Promise(resolve => {
- target.addEventListener(eventName, resolve, { once: true });
- });
- };
- /**
- * @param {!EventEmitter} emitter
- * @param {string} eventName
- * @return {!Promise<!Array>} With Event as the first item.
- */
- export const emittedOnce = (emitter: NodeJS.EventEmitter, eventName: string, trigger?: () => void) => {
- return emittedNTimes(emitter, eventName, 1, trigger).then(([result]) => result);
- };
- export const emittedNTimes = async (emitter: NodeJS.EventEmitter, eventName: string, times: number, trigger?: () => void) => {
- const events: any[][] = [];
- const p = new Promise<any[][]>(resolve => {
- const handler = (...args: any[]) => {
- events.push(args);
- if (events.length === times) {
- emitter.removeListener(eventName, handler);
- resolve(events);
- }
- };
- emitter.on(eventName, handler);
- });
- if (trigger) {
- await Promise.resolve(trigger());
- }
- return p;
- };
- export const emittedUntil = async (emitter: NodeJS.EventEmitter, eventName: string, untilFn: Function) => {
- const p = new Promise<any[]>(resolve => {
- const handler = (...args: any[]) => {
- if (untilFn(...args)) {
- emitter.removeListener(eventName, handler);
- resolve(args);
- }
- };
- emitter.on(eventName, handler);
- });
- return p;
- };
|