123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
// deno-lint-ignore-file no-explicit-anyimport { ResolvablePromise } from 'https://ghuc.cc/worker-tools/resolvable-promise/index.ts';
// const queueMicrotask = typeof globalThis.queueMicrotask === "function"//   ? globalThis.queueMicrotask//   : (callback: VoidFunction) => Promise.resolve().then(callback).catch(e => setTimeout(() => { throw e }));
export class ExtendablePromise<T = unknown> implements Promise<PromiseSettledResult<T>[]> {  #values: PromiseSettledResult<T>[] = [];  #promise: ResolvablePromise<PromiseSettledResult<T>[]>;  #numAdded = 0;  #numSettled = 0;
  constructor(f?: T | PromiseLike<T>) {    // super(_ => _(void 0 as any));    this.#promise = new ResolvablePromise();    this.waitUntil(f);    // queueMicrotask(() => {    //   if (this.#numAdded === 0) {    //     this.#promise.resolve([]);    //   }    // });  }
  #fulfill(i: number, value: T) {    this.#values[i] = { status: 'fulfilled', value };    if (++this.#numSettled === this.#numAdded) {      this.#promise.resolve(this.#values);    }  }
  #reject(i: number, reason: any) {    this.#values[i] = { status: 'rejected', reason };    if (++this.#numSettled === this.#numAdded) {      this.#promise.resolve(this.#values);    }  }
  waitUntil(f?: T | PromiseLike<T>) {    if (f != null) {      const i = this.#numAdded;      Promise.resolve(f)        .then(v => this.#fulfill(i, v), r => this.#reject(i, r))      this.#numAdded++;    }  }
  /** @deprecated Name of this property might change */  get settled() { return this.#promise.settled }
  then<TResult1 = PromiseSettledResult<T>[], TResult2 = never>(onfulfilled?: ((value: PromiseSettledResult<T>[]) => TResult1 | PromiseLike<TResult1>) | null, onrejected?: ((reason: any) => TResult2 | PromiseLike<TResult2>) | null): Promise<TResult1 | TResult2> {    return this.#promise.then(onfulfilled, onrejected);  }  catch<TResult = never>(onrejected?: ((reason: any) => TResult | PromiseLike<TResult>) | null): Promise<PromiseSettledResult<T>[] | TResult> {    return this.#promise.catch(onrejected);  }  finally(onfinally?: (() => void) | null): Promise<PromiseSettledResult<T>[]> {    return this.#promise.finally(onfinally);  }
  readonly [Symbol.toStringTag] = 'ExtendablePromise'}
export interface PromiseFulfilledResult<T> {    status: "fulfilled";    value: T;}
export interface PromiseRejectedResult {    status: "rejected";    reason: any;}
export type PromiseSettledResult<T> = PromiseFulfilledResult<T> | PromiseRejectedResult;