@tanbo/stream - npm Package Compare versions

Comparing version 1.2.5 to 1.2.6

bundles/index.esm.js

@@ -1022,2 +1022,3 @@ class Subscriber {
             let isComplete = false;
+            let nextCompleted = false;
             let sub = null;
@@ -1038,2 +1039,5 @@ const obs = {
                             subscriber.error(err);
+                        },
+                        complete() {
+                            nextCompleted = true;
                         }
@@ -1047,2 +1051,5 @@ });
                     isComplete = true;
+                    if (nextCompleted) {
+                        subscriber.complete();
+                    }
                 }
@@ -1049,0 +1056,0 @@ };

bundles/index.js

@@ -1024,2 +1024,3 @@ 'use strict';
             let isComplete = false;
+            let nextCompleted = false;
             let sub = null;
@@ -1040,2 +1041,5 @@ const obs = {
                             subscriber.error(err);
+                        },
+                        complete() {
+                            nextCompleted = true;
                         }
@@ -1049,2 +1053,5 @@ });
                     isComplete = true;
+                    if (nextCompleted) {
+                        subscriber.complete();
+                    }
                 }
@@ -1051,0 +1058,0 @@ };

package.json

 {
   "name": "@tanbo/stream",
-  "version": "1.2.5",
+  "version": "1.2.6",
   "description": "A data stream lib",
@@ -5,0 +5,0 @@ "main": "./bundles/index.js",

No alert changes

Improved metrics

Total package byte prevSize

96067

increased by0.55%

Lines of code

2619

increased by0.54%

No dependency changes