Fetch Ohlcv Many Exchanges Continuosly

import ccxt from '../../js/ccxt.js';
// AUTO-TRANSPILE //
// fetch and handle constinuosly
async function fetchOHLCVContinuously(exchange, symbol) {
   while (true) {
       try {
           const ohlcv = await exchange.fetchOHLCV(symbol);
           const ohlcvLength = ohlcv.length;
           console.log('Fetched ', exchange.id, ' - ', symbol, ' candles. last candle: ', ohlcv[ohlcvLength - 1]);
       }
       catch (e) {
           console.log(e);
           break;
       }
   }
}
// start exchanges and fetch OHLCV loop
async function startExchange(exchangeName, symbols) {
   const ex = new ccxt[exchangeName]({});
   const promises = [];
   for (let i = 0; i < symbols.length; i++) {
       const symbol = symbols[i];
       promises.push(fetchOHLCVContinuously(ex, symbol));
   }
   await Promise.all(promises);
   await ex.close();
}
// main function
async function example() {
   const exchanges = ['binance', 'okx', 'kraken'];
   const symbols = ['BTC/USDT', 'ETH/USDT'];
   const promises = [];
   for (let i = 0; i < exchanges.length; i++) {
       const exchangeName = exchanges[i];
       promises.push(startExchange(exchangeName, symbols));
   }
   await Promise.all(promises);
}
await example();