Function processRealTimeBarMsg

packages/ibkr/src/decoder/historical.ts:188–207

(d: Decoder, fields: Iterator<string>)

}

function processRealTimeBarMsg(d: Decoder, fields: Iterator<string>): void {
  decodeInt(fields) // msgId
  decodeInt(fields) // version
  const reqId = decodeInt(fields)

  const bar = new RealTimeBar()
  bar.time = decodeInt(fields)
  bar.open_ = decodeFloat(fields)
  bar.high = decodeFloat(fields)
  bar.low = decodeFloat(fields)
  bar.close = decodeFloat(fields)
  bar.volume = decodeDecimal(fields)
  bar.wap = decodeDecimal(fields)
  bar.count = decodeInt(fields)

  d.wrapper.realtimeBar(
    reqId, bar.time, bar.open_, bar.high, bar.low, bar.close,
    bar.volume, bar.wap, bar.count,
  )
}

function processHeadTimestamp(d: Decoder, fields: Iterator<string>): void {
  decodeInt(fields) // msgId