Function flushQueue

src/testing/platform/testing-task-queue.ts:98–142

()

 * - Async items will be `await`ed
 */
export function flushQueue(): Promise<void> {
  return new Promise<void>((resolve, reject) => {
    async function drain() {
      try {
        if (queuedReadTasks.length > 0) {
          const readTasks = queuedReadTasks.slice();

          queuedReadTasks.length = 0;

          let cb: Function;
          while ((cb = readTasks.shift())) {
            const result = cb(Date.now());
            if (result != null && typeof result.then === 'function') {
              await result;
            }
          }
        }

        if (queuedWriteTasks.length > 0) {
          const writeTasks = queuedWriteTasks.slice();

          queuedWriteTasks.length = 0;

          let cb: Function;
          while ((cb = writeTasks.shift())) {
            const result = cb(Date.now());
            if (result != null && typeof result.then === 'function') {
              await result;
            }
          }
        }

        if (queuedReadTasks.length + queuedWriteTasks.length > 0) {
          process.nextTick(drain);
        } else {
          resolve();
        }
      } catch (e) {
        reject(`flushQueue: ${e}`);
      }
    }

    process.nextTick(drain);
  });
}

export async function flushAll(): Promise<void> {
  while (queuedTicks.length + queuedLoadModules.length + queuedWriteTasks.length + queuedReadTasks.length > 0) {