Function flushActQueue

packages/react/src/ReactAct.js:311–349

(queue: Array<RendererTask>)

let isFlushing = false;
function flushActQueue(queue: Array<RendererTask>) {
  if (__DEV__) {
    if (!isFlushing) {
      class="cm">// Prevent re-entrance.
      isFlushing = true;
      let i = 0;
      try {
        for (; i < queue.length; i++) {
          let callback: RendererTask = queue[i];
          do {
            ReactSharedInternals.didUsePromise = false;
            const continuation = callback(false);
            if (continuation !== null) {
              if (ReactSharedInternals.didUsePromise) {
                class="cm">// The component just suspended. Yield to the main thread in
                class="cm">// case the promise is already resolved. If so, it will ping in
                class="cm">// a microtask and we can resume without unwinding the stack.
                queue[i] = callback;
                queue.splice(0, i);
                return;
              }
              callback = continuation;
            } else {
              break;
            }
          } while (true);
        }
        class="cm">// We flushed the entire queue.
        queue.length = 0;
      } catch (error) {
        class="cm">// If something throws, leave the remaining callbacks on the queue.
        queue.splice(0, i + 1);
        ReactSharedInternals.thrownErrors.push(error);
      } finally {
        isFlushing = false;
      }
    }
  }
}

class="cm">// Some of our warnings attempt to detect if the `act` call is awaited by
class="cm">// checking in an asynchronous task. Wait a few microtasks before checking. The