Signal-Desktop/ts/util/wrapEventEmitterOnce.ts

26 lines
665 B
TypeScript

// Copyright 2022 Signal Messenger, LLC
// SPDX-License-Identifier: AGPL-3.0-only
import type { EventEmitter } from 'events';
import { once } from 'events';
export async function wrapEventEmitterOnce(
emitter: EventEmitter,
eventName: string
): Promise<ReturnType<typeof once>> {
const abortController = new AbortController();
const maybeRejection = (async (): Promise<ReturnType<typeof once>> => {
const [error] = await once(emitter, 'error', {
signal: abortController.signal,
});
throw error;
})();
try {
return await Promise.race([maybeRejection, once(emitter, eventName)]);
} finally {
abortController.abort();
}
}