| 5117 | } |
| 5118 | |
| 5119 | let handleFuturesKlineStream = kline => { |
| 5120 | let symbol = kline.s, interval = kline.k.i; |
| 5121 | if (!Binance.futuresMeta[symbol][interval].timestamp) { |
| 5122 | if (typeof (Binance.futuresKlineQueue[symbol][interval]) !== 'undefined' && kline !== null) { |
| 5123 | Binance.futuresKlineQueue[symbol][interval].push(kline); |
| 5124 | } |
| 5125 | } else { |
| 5126 | //Binance.options.log('futures klines at ' + kline.k.t); |
| 5127 | futuresKlineHandler(symbol, kline); |
| 5128 | if (callback) callback(symbol, interval, futuresKlineConcat(symbol, interval)); |
| 5129 | } |
| 5130 | }; |
| 5131 | |
| 5132 | let getFuturesKlineSnapshot = async (symbol, limit = 500) => { |
| 5133 | let data = await promiseRequest('v1/klines', { symbol, interval, limit }, { base: fapi }); |
nothing calls this directly
no test coverage detected