bitmex_liquidations_monitor.js

const { streamNormalized, normalizeLiquidations } = require('tardis-dev')

async function monitorBitMEXLiquidations() {
  const bitmexLiquidations = streamNormalized(
    {
      exchange: 'bitmex',
      symbols: ['XBTUSD', 'ETHUSD']
    },
    normalizeLiquidations
  )

  console.log('BitMEX liquidations monitor started...')

  for await (const liquidation of bitmexLiquidations) {
    console.log(liquidation)
  }
}

monitorBitMEXLiquidations()