Function flushNext

core/utils/pushQueue.ts:66–95

()

  }

  async function flushNext() {
    if (isFlushing) return;
    const [nextTask] = Array.from(queue);

    if (!nextTask) return;

    isFlushing = true;

    // Get resolvable promise of original call waiting for this task to be resolved.
    const flushPromise = taskFlushedPromisesMap.get(nextTask);

    assert(flushPromise, "No flush promise for task added");

    try {
      if (IS_DEV && DEV_ARTIFICIAL_DELAY > 0) {
        await wait(DEV_ARTIFICIAL_DELAY);
      }

      // Try to execute
      const result = await nextTask();
      // Only if successful - delete task for queue to allow next tasks to be executed.
      queue.delete(nextTask);
      flushPromise.resolve(result);
      scheduleNext();
    } catch (error) {
      rejectAllAndReset(nextTask, error);
    } finally {
      isFlushing = false;
    }
  }

  function scheduleNext() {
    setTimeout(() => flushNext(), 0);