Function add

core/utils/pushQueue.ts:101–109

(task: Task<T>)

  }

  async function add<T>(task: Task<T>) {
    queue.add(task);
    const flushPromise = createResolvablePromise<T>();
    taskFlushedPromisesMap.set(task, flushPromise);

    scheduleNext();

    return flushPromise.promise;
  }

  async function waitForFlush() {
    const allPromises = Array.from(queue).map((task) => {