(symbol, limit = 500)
| 5130 | }; |
| 5131 | |
| 5132 | let getFuturesKlineSnapshot = async (symbol, limit = 500) => { |
| 5133 | let data = await promiseRequest('v1/klines', { symbol, interval, limit }, { base: fapi }); |
| 5134 | futuresKlineData(symbol, interval, data); |
| 5135 | //Binance.options.log('/futures klines at ' + Binance.futuresMeta[symbol][interval].timestamp); |
| 5136 | if (typeof Binance.futuresKlineQueue[symbol][interval] !== 'undefined') { |
| 5137 | for (let kline of Binance.futuresKlineQueue[symbol][interval]) futuresKlineHandler(symbol, kline, Binance.futuresMeta[symbol][interval].timestamp); |
| 5138 | delete Binance.futuresKlineQueue[symbol][interval]; |
| 5139 | } |
| 5140 | if (callback) callback(symbol, interval, futuresKlineConcat(symbol, interval)); |
| 5141 | }; |
| 5142 | |
| 5143 | let subscription; |
| 5144 | if (Array.isArray(symbols)) { |
no test coverage detected