Function processTurn

packages/core/src/app/createApp/eventLoop.ts:413–484

(items: readonly WorkItem[])

  }

  function processTurn(items: readonly WorkItem[]): void {
    options.setRenderRequestQueuedForCurrentTurn(false);
    const releasedBatches = new Set<BackendEventBatch>();
    const runtimeState = options.getRuntimeState();
    if (runtimeState === "Disposed" || runtimeState === "Faulted") {
      drainIgnored(items, releasedBatches);
      return;
    }

    let sawKick = false;
    for (const item of items) {
      if (options.getRuntimeState() === "Faulted" || options.getRuntimeState() === "Disposed") {
        drainIgnored(items, releasedBatches);
        return;
      }

      switch (item.kind) {
        case "fatal": {
          options.doFatal(item.code, item.detail);
          drainIgnored(items, releasedBatches);
          return;
        }
        case "eventBatch": {
          if (options.getRuntimeState() !== "Running") {
            releasedBatches.add(item.batch);
            try {
              item.batch.release();
            } catch {
              // ignore
            }
            break;
          }
          processEventBatch(item.batch, releasedBatches);
          if (options.getRuntimeState() !== "Running") {
            drainIgnored(items, releasedBatches);
            return;
          }
          commitUpdates();
          break;
        }
        case "userCommit": {
          options.setUserCommitScheduled(false);
          if (options.getRuntimeState() === "Running") commitUpdates();
          break;
        }
        case "kick": {
          sawKick = true;
          break;
        }
        case "renderRequest": {
          break;
        }
        case "frameDone": {
          options.setFramesInFlight(Math.max(0, options.getFramesInFlight() - 1));
          break;
        }
        case "frameError": {
          options.setFramesInFlight(Math.max(0, options.getFramesInFlight() - 1));