Skip to content

Commit ccbec80

Browse files
committed
fix(client): upgrade allTickers to miniTicker because stream was deprecated
1 parent 4d144ed commit ccbec80

1 file changed

Lines changed: 28 additions & 0 deletions

File tree

src/websocket.js

Lines changed: 28 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -378,6 +378,33 @@ const ticker = (payload, cb, transform = true, variator) => {
378378
}
379379

380380
const allTickers = (cb, transform = true, variator) => {
381+
const w = new openWebSocket(
382+
`${
383+
variator === 'futures'
384+
? endpoints.futures
385+
: variator === 'delivery'
386+
? endpoints.delivery
387+
: endpoints.base
388+
}/!miniTicker@arr`,
389+
)
390+
391+
w.onmessage = msg => {
392+
const arr = JSONbig.parse(msg.data)
393+
cb(
394+
transform
395+
? variator === 'futures'
396+
? arr.map(m => futuresTickerTransform(m))
397+
: variator === 'delivery'
398+
? arr.map(m => deliveryTickerTransform(m))
399+
: arr.map(m => tickerTransform(m))
400+
: arr,
401+
)
402+
}
403+
404+
return options => w.close(1000, 'Close handle was called', { keepClosed: true, ...options })
405+
}
406+
407+
const allTickersDeprecated = (cb, transform = true, variator) => {
381408
const w = new openWebSocket(
382409
`${
383410
variator === 'futures'
@@ -980,6 +1007,7 @@ export default opts => {
9801007
bookTicker,
9811008
ticker,
9821009
allTickers,
1010+
allTickersDeprecated, // uses deprecated stream
9831011
miniTicker,
9841012
allMiniTickers,
9851013
customSubStream,

0 commit comments

Comments
 (0)