From 0850bb2e31e6a1bac9667559bd06d9316be0fc0f Mon Sep 17 00:00:00 2001 From: Benny Neugebauer Date: Sat, 24 Feb 2018 22:55:42 +0100 Subject: [PATCH 1/2] Fix close handle for `client.ws.depth` --- src/websocket.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/websocket.js b/src/websocket.js index 3e214283..6b2560c8 100644 --- a/src/websocket.js +++ b/src/websocket.js @@ -6,7 +6,7 @@ import httpMethods from 'http' const BASE = 'wss://stream.binance.com:9443/ws' const depth = (payload, cb) => { - const cache = (Array.isArray(payload) ? payload : [payload]).forEach(symbol => { + const cache = (Array.isArray(payload) ? payload : [payload]).map(symbol => { const w = new WebSocket(`${BASE}/${symbol.toLowerCase()}@depth`) w.on('message', msg => { const { From bf91f08eaac452a78e8a4ffe2b5c775a4967a05a Mon Sep 17 00:00:00 2001 From: Benny Neugebauer Date: Sat, 24 Feb 2018 23:03:10 +0100 Subject: [PATCH 2/2] return w --- src/websocket.js | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/websocket.js b/src/websocket.js index 6b2560c8..bf5cbf2d 100644 --- a/src/websocket.js +++ b/src/websocket.js @@ -27,6 +27,8 @@ const depth = (payload, cb) => { askDepth: askDepth.map(a => zip(['price', 'quantity'], a)), }) }) + + return w }) return () => cache.forEach(w => w.close())