Function promiseWithAbort

packages/angular/ssr/src/utils/promise.ts:22–50

(
  promise: Promise<T>,
  signal: AbortSignal,
  errorMessagePrefix: string,
)

 * @throws {AbortError} If the `AbortSignal` is triggered before the `promise` resolves.
 */
export function promiseWithAbort<T>(
  promise: Promise<T>,
  signal: AbortSignal,
  errorMessagePrefix: string,
): Promise<T> {
  return new Promise<T>((resolve, reject) => {
    const abortHandler = () => {
      reject(
        new DOMException(`${errorMessagePrefix} was aborted.\n${signal.reason}`, 'AbortError'),
      );
    };

    // Check for abort signal
    if (signal.aborted) {
      abortHandler();

      return;
    }

    signal.addEventListener('abort', abortHandler, { once: true });

    promise
      .then(resolve)
      .catch(reject)
      .finally(() => {
        signal.removeEventListener('abort', abortHandler);
      });
  });
}