binance-api-node - npm Package Compare versions

Comparing version 0.11.18 to 0.11.19

dist/websocket.js

@@ -747,8 +747,15 @@ "use strict";
 
+var userOpenHandler = function userOpenHandler(cb) {
+  var transform = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : true;
+  return function () {
+    cb(_defineProperty({}, transform ? 'eventType' : 'type', 'open'));
+  };
+};
+
 var userErrorHandler = function userErrorHandler(cb) {
   var transform = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : true;
   return function (error) {
-    var _cb;
+    var _cb2;
 
-    cb((_cb = {}, _defineProperty(_cb, transform ? 'eventType' : 'type', 'error'), _defineProperty(_cb, "error", error), _cb));
+    cb((_cb2 = {}, _defineProperty(_cb2, transform ? 'eventType' : 'type', 'error'), _defineProperty(_cb2, "error", error), _cb2));
   };
@@ -813,24 +820,26 @@ };
 
-    var closeStream = function closeStream(options) {
-      var catchErrors = arguments.length > 1 && arguments[1] !== undefined ? arguments[1] : false;
+    var closeStream = function closeStream(options, catchErrors) {
       var setKeepClosed = arguments.length > 2 && arguments[2] !== undefined ? arguments[2] : false;
       keepClosed = setKeepClosed;
 
-      if (currentListenKey) {
-        clearInterval(int);
-        var p = closeDataStream({
-          listenKey: currentListenKey
-        });
+      if (!currentListenKey) {
+        return Promise.resolve();
+      }
 
-        if (catchErrors) {
-          p.catch(function (f) {
-            return f;
-          });
-        }
+      clearInterval(int);
+      var p = closeDataStream({
+        listenKey: currentListenKey
+      });
 
-        w.close(1000, 'Close handle was called', _objectSpread({
-          keepClosed: true
-        }, options));
-        currentListenKey = null;
+      if (catchErrors) {
+        p.catch(function (f) {
+          return f;
+        });
       }
+
+      w.close(1000, 'Close handle was called', _objectSpread({
+        keepClosed: true
+      }, options));
+      currentListenKey = null;
+      return p;
     };
@@ -856,2 +865,8 @@
 
+        if (opts.emitSocketOpens) {
+          w.onopen = function () {
+            return userOpenHandler(cb, transform)();
+          };
+        }
+
         if (opts.emitSocketErrors) {
@@ -858,0 +873,0 @@ w.onerror = function (_ref4) {

package.json

 {
   "name": "binance-api-node",
-  "version": "0.11.18",
+  "version": "0.11.19",
   "description": "A node API wrapper for Binance",
@@ -5,0 +5,0 @@ "main": "dist",

No alert changes

Improved metrics

Total package byte prevSize

213787

increased by0.16%

Lines of code

3243

increased by0.37%

No dependency changes