Function handleStartStreaming

examples/worker-rendering/main.ts:614–664

()

}

async function handleStartStreaming(): Promise<void> {
  if (state.streaming) {
    showStatus('Already streaming', 'warning');
    return;
  }

  const streamRate = parseInt((document.getElementById('streamRate') as HTMLInputElement).value);
  const streamDuration = parseInt((document.getElementById('streamDuration') as HTMLInputElement).value);
  const dataType = (document.getElementById('dataType') as HTMLSelectElement).value as DataType;
  const renderMode = (document.getElementById('renderMode') as HTMLSelectElement).value as RenderMode;

  if (!state.chart) {
    showStatus('Generate data first', 'warning');
    return;
  }

  state.streaming = true;
  let frameCount = 0;
  let nextX = state.totalPointsGenerated;

  const streamFrame = (): void => {
    if (!state.streaming || !state.chart || frameCount >= streamDuration) {
      stopStreaming();
      showStatus('Streaming complete', 'success');
      return;
    }

    frameCount++;

    // Generate batch
    const batch = generateChunk(nextX, streamRate, dataType);
    nextX += streamRate;

    // Append to chart
    state.chart.appendData(0, batch);

    state.totalPointsGenerated += streamRate;
    
    // Update live point count display (throttled)
    updateTotalPointsDisplay(state.totalPointsGenerated);
    
    showStatus(
      `Streaming... ${frameCount}/${streamDuration} frames (${formatNumber(state.totalPointsGenerated)} points total)`,
      'warning'
    );
  };

  // Start streaming at ~60fps
  state.streamingIntervalId = window.setInterval(streamFrame, 16);
  showStatus('Streaming started', 'success');
}

function stopStreaming(): void {
  state.streaming = false;