Method onError

packages/start-plugin-core/src/queue.ts:100–105

(cb: (error: any, task: () => Promise<any>) => void)

  }

  onError(cb: (error: any, task: () => Promise<any>) => void) {
    this.onErrors.push(cb)
    return () => {
      this.onErrors = this.onErrors.filter((d) => d !== cb)
    }
  }

  onSuccess(cb: (result: any, task: () => Promise<any>) => void) {
    this.onSuccesses.push(cb)