Function processBatch

frontend/src/hooks/stream/useStreamingCSVParser.ts:240–268

()

      
      // Helper function to process a batch
      async function processBatch() {
        // Update stats
        stats.rowsProcessed += currentBatch.length;
        
        // Calculate processing speed and estimated time
        updateProcessingStats(stats);
        
        // Call custom chunk handler if provided
        if (onChunkParsed) {
          await onChunkParsed(currentBatch, headers, stats.chunksProcessed === 1);
        }
        
        // Clear the batch
        const processedBatch = currentBatch;
        currentBatch = [];
        
        // Yield control to browser if enough time has passed
        const currentTime = Date.now();
        if (currentTime - lastYieldTime > 16) { // ~60fps
          await new Promise(resolve => {
            if (typeof requestAnimationFrame !== 'undefined') {
              requestAnimationFrame(resolve);
            } else {
              setTimeout(resolve, 0);
            }
          });
          lastYieldTime = currentTime;
        }
      }
      
    } catch (err) {
      const errorMessage = err instanceof Error ? err.message : 'Unknown error parsing CSV';