Function observeTrades

Parameters

• symbol: string

• onTrade: ((trade: Trade) => void)

  • • (trade: Trade): void

    • Parameters

      • trade: Trade

      Returns void

• throttleMs: number = 0

  throttle trade updates to this many milliseconds

  function main() {
    const cancel = observeTrades(
      cryptoSource,
      'BTC/USD',
      (trade: Trade): void => {
        console.log(JSON.stringify(trade, null, 2))
      },
      500,
    )
  
    // monitor for 10 seconds
    setTimeout(() => {
      // make sure you cancel!
      cancel()
      process.exit(0)
    }, 10_000)
  }
  
  main()