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

Comparing version 0.0.8 to 0.0.9

dist/index.js

@@ -279,2 +279,3 @@ 'use strict';
       transformResponse: userOptions.transformResponse,
+      handleResponseMessage: userOptions.handleResponseMessage,
       transformRequest: userOptions.transformRequest,
@@ -323,3 +324,7 @@ channelJoinAction: userOptions.channelJoinAction || defaultOptions.channelJoinAction,
           }
-          observer.next(message);
+          if (vm.options.handleResponseMessage) {
+            vm.options.handleResponseMessage(message, observer);
+          } else {
+            observer.next(message);
+          }
         };
@@ -353,3 +358,9 @@ socket.onerror = function (error) {
       }).retryWhen(function (errors) {
-        return errors.delay(Math.min(vm.retries++ * 8, 60) * 1000);
+        return Rx.Observable
+                 .range(0, 100000)
+                 .zip(errors, function (i) {
+                   return i;
+                 }).flatMap(function (i) {
+            return Rx.Observable.timer(Math.min(i * 8, 60) * 1000);
+          });
       }).share();
@@ -356,0 +367,0 @@ }

package.json

 {
   "name": "rxjs-ws-channels-filters",
-  "version": "0.0.8",
+  "version": "0.0.9",
   "description": "RxJS websockets implementation with channels and filters",
@@ -5,0 +5,0 @@ "main": "dist/index.js",

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

16719

increased by2.5%

Lines of code

335

increased by3.4%

No dependency changes