Function rejectAllAndReset

core/utils/pushQueue.ts:43–64

* If one task in queue failed - reject all pending tasks. * * We start rejecting in reverse order (starting from last added). * * eg. if you add topic, then message - if topic fails > we first reject (and undo) adding message and then topic. * * In a way like CMD+Z undo works - you

(
    failedTask: Task<unknown>,
    failedTaskError: unknown
  )

   * In a way like CMD+Z undo works - you first undo last actions.
   */
  function rejectAllAndReset(
    failedTask: Task<unknown>,
    failedTaskError: unknown
  ) {
    const tasksFromNewest = Array.from(queue).reverse();

    // Run in action so all fails are flushed to UI at once.
    runInAction(() => {
      for (const taskToReject of tasksFromNewest) {
        const taskPromise = taskFlushedPromisesMap.get(taskToReject);
        assert(taskPromise, "Incorrect state - no task promise");

        queue.delete(taskToReject);

        if (taskToReject === failedTask) {
          taskPromise.reject(failedTaskError);
        } else {
          taskPromise.reject(new Error(`Previous task in queue failed`));
        }
      }
    });
  }

  async function flushNext() {
    if (isFlushing) return;