Method flushOrdered

src/extraction/index.ts:1393–1402

()

    // after the drain). storeResult / recordParseFailure run here single-threaded,
    // so shared counters and SQLite writes never race despite parallel parsing.
    const flushOrdered = (): void => {
      if (aborted) return;
      while (completed.has(nextToStore)) {
        const item = completed.get(nextToStore)!;
        completed.delete(nextToStore);
        nextToStore++;
        if (item.ok) storeResult(item.filePath, item.content, item.stats, item.result);
        else recordParseFailure(item.filePath, item.err);
      }
    };

    // Dispatch one file's parse (parses run concurrently across the pool), tagged
    // with its file-order sequence so flushOrdered commits results in order. The