Function startStreaming

examples/live-streaming/main.ts:136–160

()

  // Streaming loop: append small batches frequently.
  let intervalId: number | null = null;
  const startStreaming = (): void => {
    if (intervalId !== null) return;
    intervalId = window.setInterval(() => {
      const batch: DataPoint[] = new Array(streamCfg.pointsPerTick);
      for (let i = 0; i < streamCfg.pointsPerTick; i++) {
        nextX += 0.02;
        const y =
          Math.sin(nextX) * 0.8 +
          Math.sin(nextX * 0.23 + 1.2) * 0.25 +
          Math.sin(nextX * 2.1) * 0.08 +
          (Math.random() - 0.5) * 0.04;
        batch[i] = [nextX, y] as const;
      }

      chart.appendData(0, batch);
      rawData.push(...batch);

      // Keep the example bounded: periodically re-seed the chart with a sliding window.
      // This keeps memory stable while still exercising streaming + autoScroll behavior.
      if (rawData.length > streamCfg.maxPoints) {
        rawData = rawData.slice(rawData.length - streamCfg.maxPoints);
        applyOptions();
      }
    }, streamCfg.tickMs);
  };

  const stopStreaming = (): void => {
    if (intervalId === null) return;