wonka - npm Package Compare versions

Comparing version 2.0.0 to 2.0.1

dist/wonka.es.js

@@ -937,8 +937,11 @@ function pipe(source) {
               function(signal) {
-                talkback(signal);
-                if (ended[0]) {
-                  return 0;
+                if (signal) {
+                  if (ended[0]) {
+                    return 0;
+                  } else {
+                    ended[0] = !0;
+                    return f();
+                  }
                 } else {
-                  ended[0] = !0;
-                  return f();
+                  return talkback(0);
                 }
@@ -945,0 +948,0 @@ }

dist/wonka.js

@@ -925,8 +925,11 @@ function __(tag, block) {
               function(signal) {
-                talkback(signal);
-                if (ended[0]) {
-                  return 0;
+                if (signal) {
+                  if (ended[0]) {
+                    return 0;
+                  } else {
+                    ended[0] = !0;
+                    return f();
+                  }
                 } else {
-                  ended[0] = !0;
-                  return f();
+                  return talkback(0);
                 }
@@ -933,0 +936,0 @@ }

lib/js/src/operators/wonka_operator_onEnd.js

@@ -24,8 +24,11 @@ 'use strict';
                           return sink(/* Start */Block.__(0, [(function (signal) {
-                                            talkback(signal);
-                                            if (ended[0]) {
-                                              return 0;
+                                            if (signal) {
+                                              if (ended[0]) {
+                                                return /* () */0;
+                                              } else {
+                                                ended[0] = true;
+                                                return f();
+                                              }
                                             } else {
-                                              ended[0] = true;
-                                              return f();
+                                              return talkback(/* Pull */0);
                                             }
@@ -32,0 +35,0 @@ })]));

package.json

 {
   "name": "wonka",
-  "version": "2.0.0",
+  "version": "2.0.1",
   "author": "Phil Pluckthun <[e-mail]>",
@@ -5,0 +5,0 @@ "source": "./src/index.js",

src/operators/wonka_operator_onEnd.js

@@ -24,8 +24,11 @@
                           return sink(/* Start */Block.__(0, [(function (signal) {
-                                            talkback(signal);
-                                            if (ended[0]) {
-                                              return 0;
+                                            if (signal) {
+                                              if (ended[0]) {
+                                                return /* () */0;
+                                              } else {
+                                                ended[0] = true;
+                                                return f();
+                                              }
                                             } else {
-                                              ended[0] = true;
-                                              return f();
+                                              return talkback(/* Pull */0);
                                             }
@@ -32,0 +35,0 @@ })]));

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

390304

increased by0.16%

Lines of code

8941

increased by0.13%

No dependency changes