Deferred promise

deferred_promise.js

class DeferredPromise extends Promise {

  constructor(def = (res, rej)=>{}) {
    let res, rej;
    super((resolve, reject)=>{
      def(resolve, reject);
      res = resolve;
      rej = reject;
    });
    this.resolve = res;
    this.reject = rej;
    this.isCancelled = false;
  }

  cancel(err) {
    this.isCancelled = true;
    this.reject(err || new Error("Cancelled deferred promise."));
  }

  defer(task) {
    this.task = task;
  }

  async execute(...args) {
    if (!this.task) {
      return this.reject(new Error("No task defined in deferred promise."));
    }
    try {
      args.push(this);
      const value = await this.task.call(this, ...args);
      this.resolve(value);
    } catch(err) {
      this.reject(err);
    }
  }

}

module.exports = DeferredPromise;