CancelableAsyncTask

CancelableAsyncTask.ts

export default class CancelableAsyncTask {
  private do: (...args: any[]) => Promise<any>;
  private running: boolean;
  private args: any[];
  constructor(doPromise: (...args: any[]) => Promise<any>, ...args: any[]) {
    this.do = doPromise;
    this.running = false;
    this.args = args;
  }
  private afterTimeDo(
    time: number,
    doSomething: (...args: any[]) => Promise<any>,
    args: any[],
  ) {
    return new Promise<any>((resolve, reject) => {
      setTimeout(async () => {
        try {
          const value = await doSomething(...args);
          resolve(value);
        } catch (error) {
          reject(error);
        }
      }, time);
    });
  }
  public async executePerTime(time: number, cb: (value: any) => void) {
    this.running = true;
    cb(await this.do(...this.args));
    while (this.running) {
      cb(await this.afterTimeDo(time, this.do, this.args));
    }
  }
  public cancel() {
    this.running = false;
  }
}