Method add

packages/start-plugin-core/src/queue.ts:68–87

(fn: () => Promise<T> | T, { priority }: { priority?: boolean } = {})

  }

  add(fn: () => Promise<T> | T, { priority }: { priority?: boolean } = {}) {
    return new Promise<any>((resolve, reject) => {
      const task = () =>
        Promise.resolve(fn())
          .then((res) => {
            resolve(res)
            return res
          })
          .catch((err) => {
            reject(err)
            throw err
          })
      if (priority) {
        this.pending.unshift(task)
      } else {
        this.pending.push(task)
      }
      this.tick()
    })
  }

  throttle(n: number) {
    this.currentConcurrency = n