Function timeout

packages/node-core/src/utils/promise.ts:11–30

(promise: Promise<T>, sec: number, errMsg = 'timeout')

}

export async function timeout<T>(promise: Promise<T>, sec: number, errMsg = 'timeout'): Promise<T> {
  // so we can have a more comprehensive error stack
  const err = new Error(errMsg);
  let timeout: NodeJS.Timeout;
  return Promise.race([
    promise.then(
      (r) => {
        clearTimeout(timeout);
        return r;
      },
      (e) => {
        clearTimeout(timeout);
        throw e;
      }
    ),
    new Promise<never>((resolve, reject) => {
      timeout = setTimeout(() => reject(err), sec * 1000);
    }),
  ]);
}

export class BackoffError extends Error {
  readonly lastError: any;