123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
// Copyright 2019 Yusuke Sakurai. All rights reserved. MIT license.export type Promises<T = any, R = Error> = {  promise: Promise<T>;  resolve: (t?: T) => void;  reject: (r?: R) => void;  readonly handled: boolean;};
/** Create deferred promise that can be resolved and rejected by outside */export function defer<T = void>(): Promises<T> {  let handled = false;  let resolve;  let reject;  const promise = new Promise<T>((res, rej) => {    resolve = r => {      handled = true;      res(r);    };    reject = r => {      handled = true;      rej(r);    };  });  return {    promise,    resolve,    reject,    get handled() {      return handled;    }  };}
export async function rejectify<T>(promise: Promise<T>): Promise<never> {  return new Promise<never>((resolve, reject) => {    promise.then(reject).catch(reject);  });}
export async function takeFirst<T>(promise: Promise<T>, ...racers): Promise<T> {  return new Promise((resolve, reject) => {    promise.then(resolve).catch(reject);    racers.forEach(r => r.then(reject).catch(reject));  });}
export class TimeoutError extends Error {}
/** returns curried promise factory that  */export function promiseInterrupter(opts: {  timeout: number;  cancel: Promise<void>;}): <T>(p: Promise<T>) => Promise<T> {  const { timeout, cancel } = opts;  return <T>(p) =>    new Promise<T>((resolve, reject) => {      if (timeout < 0) {        p.then(resolve).catch(reject);        cancel.then(reject).catch(reject);      } else {        const i = setTimeout(() => {          reject(new TimeoutError());        }, timeout);        const clear = () => clearTimeout(i);        p.then(resolve)          .catch(reject)          .finally(clear);        cancel          .then(reject)          .catch(reject)          .finally(clear);      }    });}