wonka - npm Package Compare versions

Comparing version 1.3.2 to 1.4.0

dist/wonka.es.js

@@ -277,3 +277,3 @@ function pipe(source) {
   return function(sink) {
-    var teardown = _1(f, [
+    var teardown = f([
       function(value) {
@@ -290,3 +290,3 @@ return sink(__(1, [value]));
           if (signal) {
-            return _1(teardown, 0);
+            return teardown();
           } else {
@@ -424,7 +424,3 @@ return 0;
         tmp =
-          "number" == typeof signal
-            ? 0
-            : signal.tag
-            ? __(1, [_1(f, signal[0])])
-            : __(0, [signal[0]]);
+          "number" == typeof signal ? 0 : signal.tag ? __(1, [f(signal[0])]) : __(0, [signal[0]]);
         return sink(tmp);
@@ -440,3 +436,3 @@ });
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !signal.tag || _1(f, signal[0])) {
+        if ("number" == typeof signal || !signal.tag || f(signal[0])) {
           return sink(signal);
@@ -491,3 +487,3 @@ } else {
           } else {
-            (innerSource = _1(f, signal[0])),
+            (innerSource = f(signal[0])),
               (talkback = [talkbackPlaceholder]),
@@ -558,4 +554,4 @@ _1(innerSource, function(signal) {
 function merge(sources) {
-  return mergeMap(function(prim) {
-    return prim;
+  return mergeMap(function(x) {
+    return x;
   })(fromArray(sources));
@@ -565,4 +561,4 @@ }
 function mergeAll(source) {
-  return mergeMap(function(prim) {
-    return prim;
+  return mergeMap(function(x) {
+    return x;
   })(source);
@@ -582,3 +578,3 @@ }
             if (void 0 !== match) {
-              return applyInnerSource(_1(f, valFromOption(match)));
+              return applyInnerSource(f(valFromOption(match)));
             } else if (state[5]) {
@@ -629,3 +625,3 @@ return sink(0);
             } else {
-              applyInnerSource(_1(f, x));
+              applyInnerSource(f(x));
             }
@@ -665,4 +661,4 @@ return state[1](0);
 function concatAll(source) {
-  return concatMap(function(prim) {
-    return prim;
+  return concatMap(function(x) {
+    return x;
   })(source);
@@ -672,4 +668,4 @@ }
 function concat(sources) {
-  return concatMap(function(prim) {
-    return prim;
+  return concatMap(function(x) {
+    return x;
   })(fromArray(sources));
@@ -702,26 +698,25 @@ }
             }
-            (innerSource = _1(f, signal[0])),
-              _1(innerSource, function(signal) {
-                if ("number" == typeof signal) {
-                  state[2] = !1;
-                  state[1] = talkbackPlaceholder;
-                  if (state[4]) {
-                    return sink(0);
-                  } else {
-                    return 0;
-                  }
-                } else if (signal.tag) {
-                  if (state[3]) {
-                    return 0;
-                  } else {
-                    sink(__(1, [signal[0]]));
-                    return state[1](0);
-                  }
+            _1(f(signal[0]), function(signal) {
+              if ("number" == typeof signal) {
+                state[2] = !1;
+                state[1] = talkbackPlaceholder;
+                if (state[4]) {
+                  return sink(0);
                 } else {
-                  var tb = signal[0];
-                  state[2] = !0;
-                  state[1] = tb;
-                  return tb(0);
+                  return 0;
                 }
-              });
+              } else if (signal.tag) {
+                if (state[3]) {
+                  return 0;
+                } else {
+                  sink(__(1, [signal[0]]));
+                  return state[1](0);
+                }
+              } else {
+                var tb = signal[0];
+                state[2] = !0;
+                state[1] = tb;
+                return tb(0);
+              }
+            });
             return state[0](0);
@@ -734,3 +729,2 @@ }
         }
-        var innerSource;
       });
@@ -1009,3 +1003,3 @@ return sink(
 
-function takeWhile(predicate) {
+function takeWhile(f) {
   return function(source) {
@@ -1026,3 +1020,3 @@ return function(sink) {
             return 0;
-          } else if (_1(predicate, signal[0])) {
+          } else if (f(signal[0])) {
             return sink(signal);
@@ -1128,3 +1122,3 @@ } else {
 
-function skipWhile(predicate) {
+function skipWhile(f) {
   return function(source) {
@@ -1136,3 +1130,3 @@ return function(sink) {
           return sink(signal);
-        } else if (_1(predicate, signal[0])) {
+        } else if (f(signal[0])) {
           return talkback(0);
@@ -1369,3 +1363,3 @@ } else {
 
-function debounce(debounceF) {
+function debounce(f) {
   return function(source) {
@@ -1404,3 +1398,3 @@ return function(sink) {
               }
-            }, _1(debounceF, signal[0]))
+            }, f(signal[0]))
           );
@@ -1428,3 +1422,3 @@ return 0;
 
-function throttle(throttleF) {
+function throttle(f) {
   return function(source) {
@@ -1458,3 +1452,3 @@ return function(sink) {
                 return 0;
-              }, _1(throttleF, signal[0]))
+              }, f(signal[0]))
             );
@@ -1461,0 +1455,0 @@ return sink(signal);

dist/wonka.js

@@ -279,3 +279,3 @@ function __(tag, block) {
           } else {
-            (innerSource = _1(f, signal[0])),
+            (innerSource = f(signal[0])),
               (talkback = [talkbackPlaceholder]),
@@ -346,4 +346,4 @@ _1(innerSource, function(signal) {
 function mergeAll(source) {
-  return mergeMap(function(prim) {
-    return prim;
+  return mergeMap(function(x) {
+    return x;
   })(source);
@@ -363,3 +363,3 @@ }
             if (void 0 !== match) {
-              return applyInnerSource(_1(f, valFromOption(match)));
+              return applyInnerSource(f(valFromOption(match)));
             } else if (state[5]) {
@@ -410,3 +410,3 @@ return sink(0);
             } else {
-              applyInnerSource(_1(f, x));
+              applyInnerSource(f(x));
             }
@@ -619,3 +619,3 @@ return state[1](0);
   return function(sink) {
-    var teardown = _1(f, [
+    var teardown = f([
       function(value) {
@@ -632,3 +632,3 @@ return sink(__(1, [value]));
           if (signal) {
-            return _1(teardown, 0);
+            return teardown();
           } else {
@@ -730,7 +730,3 @@ return 0;
         tmp =
-          "number" == typeof signal
-            ? 0
-            : signal.tag
-            ? __(1, [_1(f, signal[0])])
-            : __(0, [signal[0]]);
+          "number" == typeof signal ? 0 : signal.tag ? __(1, [f(signal[0])]) : __(0, [signal[0]]);
         return sink(tmp);
@@ -746,3 +742,3 @@ });
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !signal.tag || _1(f, signal[0])) {
+        if ("number" == typeof signal || !signal.tag || f(signal[0])) {
           return sink(signal);
@@ -803,26 +799,25 @@ } else {
             }
-            (innerSource = _1(f, signal[0])),
-              _1(innerSource, function(signal) {
-                if ("number" == typeof signal) {
-                  state[2] = !1;
-                  state[1] = talkbackPlaceholder;
-                  if (state[4]) {
-                    return sink(0);
-                  } else {
-                    return 0;
-                  }
-                } else if (signal.tag) {
-                  if (state[3]) {
-                    return 0;
-                  } else {
-                    sink(__(1, [signal[0]]));
-                    return state[1](0);
-                  }
+            _1(f(signal[0]), function(signal) {
+              if ("number" == typeof signal) {
+                state[2] = !1;
+                state[1] = talkbackPlaceholder;
+                if (state[4]) {
+                  return sink(0);
                 } else {
-                  var tb = signal[0];
-                  state[2] = !0;
-                  state[1] = tb;
-                  return tb(0);
+                  return 0;
                 }
-              });
+              } else if (signal.tag) {
+                if (state[3]) {
+                  return 0;
+                } else {
+                  sink(__(1, [signal[0]]));
+                  return state[1](0);
+                }
+              } else {
+                var tb = signal[0];
+                state[2] = !0;
+                state[1] = tb;
+                return tb(0);
+              }
+            });
             return state[0](0);
@@ -835,3 +830,2 @@ }
         }
-        var innerSource;
       });
@@ -865,4 +859,4 @@ return sink(
 exports.merge = function merge(sources) {
-  return mergeMap(function(prim) {
-    return prim;
+  return mergeMap(function(x) {
+    return x;
   })(fromArray(sources));
@@ -872,4 +866,4 @@ };
 exports.concat = function concat(sources) {
-  return concatMap(function(prim) {
-    return prim;
+  return concatMap(function(x) {
+    return x;
   })(fromArray(sources));
@@ -883,4 +877,4 @@ };
 exports.concatAll = function concatAll(source) {
-  return concatMap(function(prim) {
-    return prim;
+  return concatMap(function(x) {
+    return x;
   })(source);
@@ -1078,3 +1072,3 @@ };
 
-exports.takeWhile = function takeWhile(predicate) {
+exports.takeWhile = function takeWhile(f) {
   return function(source) {
@@ -1095,3 +1089,3 @@ return function(sink) {
             return 0;
-          } else if (_1(predicate, signal[0])) {
+          } else if (f(signal[0])) {
             return sink(signal);
@@ -1197,3 +1191,3 @@ } else {
 
-exports.skipWhile = function skipWhile(predicate) {
+exports.skipWhile = function skipWhile(f) {
   return function(source) {
@@ -1205,3 +1199,3 @@ return function(sink) {
           return sink(signal);
-        } else if (_1(predicate, signal[0])) {
+        } else if (f(signal[0])) {
           return talkback(0);
@@ -1385,3 +1379,3 @@ } else {
 
-exports.debounce = function debounce(debounceF) {
+exports.debounce = function debounce(f) {
   return function(source) {
@@ -1420,3 +1414,3 @@ return function(sink) {
               }
-            }, _1(debounceF, signal[0]))
+            }, f(signal[0]))
           );
@@ -1444,3 +1438,3 @@ return 0;
 
-exports.throttle = function throttle(throttleF) {
+exports.throttle = function throttle(f) {
   return function(source) {
@@ -1474,3 +1468,3 @@ return function(sink) {
                 return 0;
-              }, _1(throttleF, signal[0]))
+              }, f(signal[0]))
             );
@@ -1477,0 +1471,0 @@ return sink(signal);

lib/js/src/web/wonkaJs.js

@@ -85,3 +85,3 @@ 'use strict';
 
-function debounce(debounceF) {
+function debounce(f) {
   return (function (source) {
@@ -120,3 +120,3 @@ return (function (sink) {
                                       }
-                                    }), Curry._1(debounceF, signal[0])));
+                                    }), f(signal[0])));
                           return /* () */0;
@@ -139,3 +139,3 @@ } else {
 
-function throttle(throttleF) {
+function throttle(f) {
   return (function (source) {
@@ -168,3 +168,3 @@ return (function (sink) {
                                         return /* () */0;
-                                      }), Curry._1(throttleF, signal[0])));
+                                      }), f(signal[0])));
                             return sink(signal);
@@ -171,0 +171,0 @@ }

lib/js/src/wonka.js

@@ -57,3 +57,3 @@ 'use strict';
   return (function (sink) {
-      var teardown = Curry._1(f, /* record */[
+      var teardown = f(/* record */[
             /* next */(function (value) {
@@ -68,3 +68,3 @@ return sink(/* Push */Block.__(1, [value]));
                         if (signal) {
-                          return Curry._1(teardown, /* () */0);
+                          return teardown();
                         } else {
@@ -199,3 +199,3 @@ return /* () */0;
                         tmp = typeof signal === "number" ? /* End */0 : (
-                            signal.tag ? /* Push */Block.__(1, [Curry._1(f, signal[0])]) : /* Start */Block.__(0, [signal[0]])
+                            signal.tag ? /* Push */Block.__(1, [f(signal[0])]) : /* Start */Block.__(0, [signal[0]])
                           );
@@ -212,3 +212,3 @@ return sink(tmp);
           return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
-                        if (typeof signal === "number" || !(signal.tag && !Curry._1(f, signal[0]))) {
+                        if (typeof signal === "number" || !(signal.tag && !f(signal[0]))) {
                           return sink(signal);
@@ -294,3 +294,3 @@ } else {
                     } else {
-                      applyInnerSource(Curry._1(f, signal[0]));
+                      applyInnerSource(f(signal[0]));
                       return state[/* outerTalkback */0](/* Pull */0);
@@ -331,4 +331,4 @@ }
 function merge(sources) {
-  return mergeMap((function (prim) {
-                  return prim;
+  return mergeMap((function (x) {
+                  return x;
                 }))(fromArray(sources));
@@ -338,4 +338,4 @@ }
 function mergeAll(source) {
-  return mergeMap((function (prim) {
-                  return prim;
+  return mergeMap((function (x) {
+                  return x;
                 }))(source);
@@ -362,3 +362,3 @@ }
                             if (match !== undefined) {
-                              return applyInnerSource(Curry._1(f, Caml_option.valFromOption(match)));
+                              return applyInnerSource(f(Caml_option.valFromOption(match)));
                             } else if (state[/* ended */5]) {
@@ -404,3 +404,3 @@ return sink(/* End */0);
                       } else {
-                        applyInnerSource(Curry._1(f, x));
+                        applyInnerSource(f(x));
                       }
@@ -436,4 +436,4 @@ return state[/* outerTalkback */1](/* Pull */0);
 function concatAll(source) {
-  return concatMap((function (prim) {
-                  return prim;
+  return concatMap((function (x) {
+                  return x;
                 }))(source);
@@ -443,4 +443,4 @@ }
 function concat(sources) {
-  return concatMap((function (prim) {
-                  return prim;
+  return concatMap((function (x) {
+                  return x;
                 }))(fromArray(sources));
@@ -504,3 +504,3 @@ }
                       }
-                      applyInnerSource(Curry._1(f, signal[0]));
+                      applyInnerSource(f(signal[0]));
                       return state[/* outerTalkback */0](/* Pull */0);
@@ -754,3 +754,3 @@ }
 
-function takeWhile(predicate) {
+function takeWhile(f) {
   return (function (source) {
@@ -771,3 +771,3 @@ return (function (sink) {
                       return /* () */0;
-                    } else if (Curry._1(predicate, signal[0])) {
+                    } else if (f(signal[0])) {
                       return sink(signal);
@@ -869,3 +869,3 @@ } else {
 
-function skipWhile(predicate) {
+function skipWhile(f) {
   return (function (source) {
@@ -877,3 +877,3 @@ return (function (sink) {
                           return sink(signal);
-                        } else if (Curry._1(predicate, signal[0])) {
+                        } else if (f(signal[0])) {
                           return talkback(/* Pull */0);
@@ -880,0 +880,0 @@ } else {

package.json

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

src/web/wonkaJs.js

@@ -85,3 +85,3 @@
 
-function debounce(debounceF) {
+function debounce(f) {
   return (function (source) {
@@ -120,3 +120,3 @@ return (function (sink) {
                                       }
-                                    }), Curry._1(debounceF, signal[0])));
+                                    }), f(signal[0])));
                           return /* () */0;
@@ -139,3 +139,3 @@ } else {
 
-function throttle(throttleF) {
+function throttle(f) {
   return (function (source) {
@@ -168,3 +168,3 @@ return (function (sink) {
                                         return /* () */0;
-                                      }), Curry._1(throttleF, signal[0])));
+                                      }), f(signal[0])));
                             return sink(signal);
@@ -171,0 +171,0 @@ }

src/wonka.js

@@ -57,3 +57,3 @@
   return (function (sink) {
-      var teardown = Curry._1(f, /* record */[
+      var teardown = f(/* record */[
             /* next */(function (value) {
@@ -68,3 +68,3 @@ return sink(/* Push */Block.__(1, [value]));
                         if (signal) {
-                          return Curry._1(teardown, /* () */0);
+                          return teardown();
                         } else {
@@ -199,3 +199,3 @@ return /* () */0;
                         tmp = typeof signal === "number" ? /* End */0 : (
-                            signal.tag ? /* Push */Block.__(1, [Curry._1(f, signal[0])]) : /* Start */Block.__(0, [signal[0]])
+                            signal.tag ? /* Push */Block.__(1, [f(signal[0])]) : /* Start */Block.__(0, [signal[0]])
                           );
@@ -212,3 +212,3 @@ return sink(tmp);
           return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
-                        if (typeof signal === "number" || !(signal.tag && !Curry._1(f, signal[0]))) {
+                        if (typeof signal === "number" || !(signal.tag && !f(signal[0]))) {
                           return sink(signal);
@@ -294,3 +294,3 @@ } else {
                     } else {
-                      applyInnerSource(Curry._1(f, signal[0]));
+                      applyInnerSource(f(signal[0]));
                       return state[/* outerTalkback */0](/* Pull */0);
@@ -331,4 +331,4 @@ }
 function merge(sources) {
-  return mergeMap((function (prim) {
-                  return prim;
+  return mergeMap((function (x) {
+                  return x;
                 }))(fromArray(sources));
@@ -338,4 +338,4 @@ }
 function mergeAll(source) {
-  return mergeMap((function (prim) {
-                  return prim;
+  return mergeMap((function (x) {
+                  return x;
                 }))(source);
@@ -362,3 +362,3 @@ }
                             if (match !== undefined) {
-                              return applyInnerSource(Curry._1(f, Caml_option.valFromOption(match)));
+                              return applyInnerSource(f(Caml_option.valFromOption(match)));
                             } else if (state[/* ended */5]) {
@@ -404,3 +404,3 @@ return sink(/* End */0);
                       } else {
-                        applyInnerSource(Curry._1(f, x));
+                        applyInnerSource(f(x));
                       }
@@ -436,4 +436,4 @@ return state[/* outerTalkback */1](/* Pull */0);
 function concatAll(source) {
-  return concatMap((function (prim) {
-                  return prim;
+  return concatMap((function (x) {
+                  return x;
                 }))(source);
@@ -443,4 +443,4 @@ }
 function concat(sources) {
-  return concatMap((function (prim) {
-                  return prim;
+  return concatMap((function (x) {
+                  return x;
                 }))(fromArray(sources));
@@ -504,3 +504,3 @@ }
                       }
-                      applyInnerSource(Curry._1(f, signal[0]));
+                      applyInnerSource(f(signal[0]));
                       return state[/* outerTalkback */0](/* Pull */0);
@@ -754,3 +754,3 @@ }
 
-function takeWhile(predicate) {
+function takeWhile(f) {
   return (function (source) {
@@ -771,3 +771,3 @@ return (function (sink) {
                       return /* () */0;
-                    } else if (Curry._1(predicate, signal[0])) {
+                    } else if (f(signal[0])) {
                       return sink(signal);
@@ -869,3 +869,3 @@ } else {
 
-function skipWhile(predicate) {
+function skipWhile(f) {
   return (function (source) {
@@ -877,3 +877,3 @@ return (function (sink) {
                           return sink(signal);
-                        } else if (Curry._1(predicate, signal[0])) {
+                        } else if (f(signal[0])) {
                           return talkback(/* Pull */0);
@@ -880,0 +880,0 @@ } else {

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

Worsened metrics

Total package byte prevSize

343869

decreased by-0.31%

Lines of code

7747

decreased by-0.15%

No dependency changes