Method run

packages/task/src/task.ts:314–381

* Runs a task manually. * * This can be useful for running tasks in response to events as opposed to * automatically running when host element state changes. * * @param args an optional set of arguments to use for this task run. If args * is not given, the args function is call

(args?: T)

   *     this run.
   */
  async run(args?: T) {
    args ??= this._getArgs();

    // Remember the args for potential future automatic runs.
    // TODO (justinfagnani): add test
    this._previousArgs = args;

    if (this._status === TaskStatus.PENDING) {
      this._abortController?.abort();
    } else {
      // Clear the last complete task run in INITIAL because it may be a resolved
      // promise. Also clear if COMPLETE or ERROR because the value returned by
      // awaiting taskComplete may have changed since last run.
      this._taskComplete = undefined;
      this._resolveTaskComplete = undefined;
      this._rejectTaskComplete = undefined;
    }

    this._status = TaskStatus.PENDING;
    let result!: R | typeof initialState;
    let error: unknown;

    // Request an update to report pending state.
    if (this.autoRun === 'afterUpdate') {
      // Avoids a change-in-update warning
      queueMicrotask(() => this._host.requestUpdate());
    } else {
      this._host.requestUpdate();
    }

    const key = ++this._callId;
    this._abortController = new AbortController();
    let errored = false;
    try {
      result = await this._task(args!, {signal: this._abortController.signal});
    } catch (e) {
      errored = true;
      error = e;
    }
    // If this is the most recent task call, process this value.
    if (this._callId === key) {
      if (result === initialState) {
        this._status = TaskStatus.INITIAL;
      } else {
        if (errored === false) {
          try {
            this._onComplete?.(result as R);
          } catch {
            // Ignore user errors from onComplete.
          }
          this._status = TaskStatus.COMPLETE;
          this._resolveTaskComplete?.(result as R);
        } else {
          try {
            this._onError?.(error);
          } catch {
            // Ignore user errors from onError.
          }