Method tick

packages/start-plugin-core/src/queue.ts:33–66

()

  }

  private tick() {
    if (!this.running) {
      return
    }
    while (
      this.active.length < this.currentConcurrency &&
      this.pending.length
    ) {
      const nextFn = this.pending.shift()
      if (!nextFn) {
        throw new Error('Found task that is not a function')
      }
      this.active.push(nextFn)
      ;(async () => {
        let success = false
        let res!: T
        let error: any
        try {
          res = await nextFn()
          success = true
        } catch (e) {
          error = e
        }
        this.active = this.active.filter((d) => d !== nextFn)
        if (success) {
          this.onSuccesses.forEach((d) => d(res, nextFn))
        } else {
          this.onErrors.forEach((d) => d(error, nextFn))
        }
        this.onSettles.forEach((d) => d(res, error))
        this.tick()
      })()
    }
  }

  add(fn: () => Promise<T> | T, { priority }: { priority?: boolean } = {}) {
    return new Promise<any>((resolve, reject) => {