spine-high-templar - npm Package Compare versions

Comparing version 0.1.0 to 0.2.0

dist/spine-high-templar.es.js

@@ -35,5 +35,5 @@ import mitt from 'mitt';
         this.publishHandlers = {};
+        this.pendingSendMessages = [];
         this.pingInterval = 30000;
         this.reconnectInterval = 2000;
-        this.connectDelay = 200;
 
@@ -55,3 +55,3 @@ this._events = mitt();
 
-            var _arr = ['pingInterval', 'reconnectInterval', 'connectDelay'];
+            var _arr = ['pingInterval', 'reconnectInterval'];
             for (var _i = 0; _i < _arr.length; _i++) {
@@ -66,2 +66,3 @@ var propName = _arr[_i];
                 _this._events.emit('open');
+                _this._sendPendingMessages();
                 _this._initiatePingInterval();
@@ -105,4 +106,2 @@ };
         value: function send(options) {
-            var _this2 = this;
-
             var msg = {
@@ -117,7 +116,6 @@ type: options.type,
             if (this.instance.readyState !== 1) {
-                setTimeout(function () {
-                    _this2._sendDirectly(msg);
-                }, this.connectDelay);
+                this.pendingSendMessages.push(msg);
                 return;
             }
+
             this._sendDirectly(msg);
@@ -176,2 +174,30 @@ }
     }, {
+        key: '_sendPendingMessages',
+        value: function _sendPendingMessages() {
+            var _iteratorNormalCompletion = true;
+            var _didIteratorError = false;
+            var _iteratorError = undefined;
+
+            try {
+                for (var _iterator = this.pendingSendMessages[Symbol.iterator](), _step; !(_iteratorNormalCompletion = (_step = _iterator.next()).done); _iteratorNormalCompletion = true) {
+                    var msg = _step.value;
+
+                    this._sendDirectly(msg);
+                }
+            } catch (err) {
+                _didIteratorError = true;
+                _iteratorError = err;
+            } finally {
+                try {
+                    if (!_iteratorNormalCompletion && _iterator.return) {
+                        _iterator.return();
+                    }
+                } finally {
+                    if (_didIteratorError) {
+                        throw _iteratorError;
+                    }
+                }
+            }
+        }
+    }, {
         key: '_sendDirectly',
@@ -184,6 +210,6 @@ value: function _sendDirectly(msg) {
         value: function _initiatePingInterval() {
-            var _this3 = this;
+            var _this2 = this;
 
             this.pingIntervalHandle = setInterval(function () {
-                _this3.instance.send('ping');
+                _this2.instance.send('ping');
             }, this.pingInterval);
@@ -190,0 +216,0 @@ }

dist/spine-high-templar.umd.js

@@ -41,5 +41,5 @@ (function (global, factory) {
         this.publishHandlers = {};
+        this.pendingSendMessages = [];
         this.pingInterval = 30000;
         this.reconnectInterval = 2000;
-        this.connectDelay = 200;
 
@@ -61,3 +61,3 @@ this._events = mitt();
 
-            var _arr = ['pingInterval', 'reconnectInterval', 'connectDelay'];
+            var _arr = ['pingInterval', 'reconnectInterval'];
             for (var _i = 0; _i < _arr.length; _i++) {
@@ -72,2 +72,3 @@ var propName = _arr[_i];
                 _this._events.emit('open');
+                _this._sendPendingMessages();
                 _this._initiatePingInterval();
@@ -111,4 +112,2 @@ };
         value: function send(options) {
-            var _this2 = this;
-
             var msg = {
@@ -123,7 +122,6 @@ type: options.type,
             if (this.instance.readyState !== 1) {
-                setTimeout(function () {
-                    _this2._sendDirectly(msg);
-                }, this.connectDelay);
+                this.pendingSendMessages.push(msg);
                 return;
             }
+
             this._sendDirectly(msg);
@@ -182,2 +180,30 @@ }
     }, {
+        key: '_sendPendingMessages',
+        value: function _sendPendingMessages() {
+            var _iteratorNormalCompletion = true;
+            var _didIteratorError = false;
+            var _iteratorError = undefined;
+
+            try {
+                for (var _iterator = this.pendingSendMessages[Symbol.iterator](), _step; !(_iteratorNormalCompletion = (_step = _iterator.next()).done); _iteratorNormalCompletion = true) {
+                    var msg = _step.value;
+
+                    this._sendDirectly(msg);
+                }
+            } catch (err) {
+                _didIteratorError = true;
+                _iteratorError = err;
+            } finally {
+                try {
+                    if (!_iteratorNormalCompletion && _iterator.return) {
+                        _iterator.return();
+                    }
+                } finally {
+                    if (_didIteratorError) {
+                        throw _iteratorError;
+                    }
+                }
+            }
+        }
+    }, {
         key: '_sendDirectly',
@@ -190,6 +216,6 @@ value: function _sendDirectly(msg) {
         value: function _initiatePingInterval() {
-            var _this3 = this;
+            var _this2 = this;
 
             this.pingIntervalHandle = setInterval(function () {
-                _this3.instance.send('ping');
+                _this2.instance.send('ping');
             }, this.pingInterval);
@@ -196,0 +222,0 @@ }

package.json

 {
   "name": "spine-high-templar",
-  "version": "0.1.0",
+  "version": "0.2.0",
   "license": "MIT",
@@ -5,0 +5,0 @@ "author": "Jasper Stam <[e-mail]>",

No alert changes

Improved metrics

Total package byte prevSize

17800

increased by12.01%

Lines of code

403

increased by13.52%

No dependency changes