Class ZoneAwarePromise

packages/zone.js/lib/common/promise.ts:326–576

    const AggregateError = global.AggregateError;

    class ZoneAwarePromise<R> implements Promise<R> {
      static toString() {
        return ZONE_AWARE_PROMISE_TO_STRING;
      }

      static resolve<R>(value: R): Promise<R> {
        if (value instanceof ZoneAwarePromise) {
          return value;
        }
        return resolvePromise(<ZoneAwarePromise<R>>new this(null as any), RESOLVED, value);
      }

      static reject<U>(error: U): Promise<U> {
        return resolvePromise(<ZoneAwarePromise<U>>new this(null as any), REJECTED, error);
      }

      static withResolvers<T>(): {
        promise: Promise<T>;
        resolve: (value?: T | PromiseLike<T>) => void;
        reject: (error?: any) => void;
      } {
        const result: any = {};
        result.promise = new ZoneAwarePromise((res, rej) => {
          result.resolve = res;
          result.reject = rej;
        });
        return result;
      }

      static any<T>(values: Iterable<PromiseLike<T>>): Promise<T> {
        if (!values || typeof values[Symbol.iterator] !== 'function') {
          return Promise.reject(new AggregateError([], 'All promises were rejected'));
        }
        const promises: Promise<PromiseLike<T>>[] = [];
        let count = 0;
        try {
          for (let v of values) {
            count++;
            promises.push(ZoneAwarePromise.resolve(v));
          }
        } catch (err) {
          return Promise.reject(new AggregateError([], 'All promises were rejected'));
        }
        if (count === 0) {
          return Promise.reject(new AggregateError([], 'All promises were rejected'));
        }
        let finished = false;
        const errors: any[] = [];
        return new ZoneAwarePromise((resolve, reject) => {
          for (let i = 0; i < promises.length; i++) {
            promises[i].then(
              (v) => {
                if (finished) {
                  return;
                }
                finished = true;
                resolve(v);
              },