Watch New Trades Only

'use strict';
import ccxt from '../../js/ccxt.js';
console.log('CCXT Version:', ccxt.version); // eslint-disable-line import/no-named-as-default-member
async function watchExchange(exchangeId, symbol) {
   const exchange = new ccxt.pro[exchangeId]({
       'newUpdates': true,
   });
   await exchange.loadMarkets();
   // exchange.verbose = true // uncomment for debugging purposes if necessary
   while (true) { // eslint-disable-line no-constant-condition
       try {
           const trades = await exchange.watchTrades(symbol);
           for (let i = 0; i < trades.length; i++) {
               const trade = trades[i];
               console.log(exchange.iso8601(exchange.milliseconds()), exchange.id, trade['symbol'], trade['id'], trade['datetime'], trade['price'], trade['amount']);
           }
       }
       catch (e) {
           console.log(symbol, e);
       }
   }
}
async function main() {
   const streams = {
       'binance': 'BTC/USDT',
       'okex': 'BTC/USDT',
       'kraken': 'BTC/USD',
   };
   const values = Object.entries(streams);
   const promises = values.map(([exchangeId, symbol]) => watchExchange(exchangeId, symbol));
   await Promise.all(promises);
}
main();