Function createTickSimulator

examples/candlestick-streaming/tickSimulator.ts:22–68

(config: TickSimulatorConfig)

}

export function createTickSimulator(config: TickSimulatorConfig): TickSimulator {
  const { initialPrice, ticksPerSecond, volatility, onTick } = config;

  let price = initialPrice;
  let running = false;
  let tickCount = 0;
  let intervalId: number | null = null;

  // Use high-resolution timer for smooth ticks
  const tickIntervalMs = 1000 / ticksPerSecond;

  function generateTick() {
    const change = (Math.random() - 0.5) * 2 * volatility * price;
    price += change;
    price = Math.max(price, initialPrice * 0.01); // Floor

    const tick: Tick = {
      timestamp: Date.now(),
      price,
      volume: Math.random() * 1000 + 100,
    };

    tickCount++;
    onTick(tick);
  }

  return {
    start() {
      if (running) return;
      running = true;
      intervalId = window.setInterval(generateTick, tickIntervalMs);
    },

    stop() {
      if (!running) return;
      running = false;
      if (intervalId !== null) {
        clearInterval(intervalId);
        intervalId = null;
      }
    },

    getTickCount() {
      return tickCount;
    },
  };
}

// Aggregates ticks into candles
export interface CandleAggregator {