rxjs-ws-channels-filters - npm Package Compare versions

Comparing version 0.4.2 to 0.4.3

dist/index.js

@@ -311,3 +311,3 @@ 'use strict';
     var vm = this;
-    vm.retries = 0;
+    vm.retries = false;
     vm.openedOnce = false;
@@ -327,12 +327,7 @@
       .retryWhen(function (errors) {
-        return rxSocket.Rx.Observable
-                       .range(0, 100000)
-                       .zip(errors, function (i) {
-                         return i;
-                       })
-                       .flatMap(function (i) {
-                         vm.retries = i;
-                         vm.connectionStatus.next(connectionStatusOptions.connectionRetry);
-                         return rxSocket.Rx.Observable.timer(5 * 1000);
-                       });
+        return errors.flatMap(function () {
+          vm.retries = true;
+          vm.connectionStatus.next(connectionStatusOptions.connectionRetry);
+          return rxSocket.Rx.Observable.timer(5 * 1000);
+        });
       }).share().publishReplay(1000).refCount();
@@ -347,3 +342,3 @@
           vm.openedOnce && vm.retries ? connectionStatusOptions.openedAfterRetry : connectionStatusOptions.open);
-        vm.retries = 0;
+        vm.retries = false;
         vm.openedOnce = true;
@@ -350,0 +345,0 @@ inputSubscription = vm.subject.subscribe(function (data) {

package.json

 {
   "name": "rxjs-ws-channels-filters",
-  "version": "0.4.2",
+  "version": "0.4.3",
   "description": "RxJS websockets implementation with channels and filters",
@@ -10,4 +10,4 @@ "main": "dist/index.js",
   "devDependencies": {
-    "connect": "3.6.5",
-    "eslint": "4.17.0",
+    "connect": "3.6.6",
+    "eslint": "4.18.1",
     "gulp": "3.9.1",
@@ -14,0 +14,0 @@ "gulp-clean": "0.4.0",

No alert changes

Worsened metrics

Total package byte prevSize

17931

decreased by-1.34%

Lines of code

350

decreased by-1.41%

No dependency changes