wonka - npm Package Compare versions

Comparing version 4.0.6 to 4.0.7

dist/wonka.es.js

@@ -8,3 +8,3 @@ function k(a, b) {
 
-function n(a) {
+function p(a) {
   if (void 0 === a) {
@@ -32,13 +32,13 @@ return (a = [ m, 0 ]).tag = 256, a;
 function t(a, b) {
-  let c = !1, d = !1, e = !1;
+  let c = !1, e = !1, d = !1;
   return a(k(0, [ function(g) {
     if (g) {
       c = !0;
-    } else if (d) {
-      e = !0;
+    } else if (e) {
+      d = !0;
     } else {
-      for (d = e = !0; e && !c; ) {
-        void 0 !== (g = b()) ? (e = !1, a(k(1, [ q(g) ]))) : (c = !0, a(0));
+      for (e = d = !0; d && !c; ) {
+        void 0 !== (g = b()) ? (d = !1, a(k(1, [ q(g) ]))) : (c = !0, a(0));
       }
-      d = !1;
+      e = !1;
     }
@@ -52,8 +52,8 @@ return 0;
     var c = a.length;
-    let d = 0;
+    let e = 0;
     return t(b, (function() {
-      if (d < c) {
-        var e = a[d];
-        d = d + 1 | 0;
-        return n(e);
+      if (e < c) {
+        var d = a[e];
+        e = e + 1 | 0;
+        return p(d);
       }
@@ -68,7 +68,7 @@ }));
 
-function x(a) {
+function y(a) {
   return a(0);
 }
 
-function y(a) {
+function z(a) {
   let b = !1;
@@ -80,22 +80,22 @@ return a(k(0, [ function(c) {
 
-function z(a, b, c) {
-  for (var d = Array(c), e = 0; e < c; ) {
-    d[e] = a[b], e = e + 1 | 0, b = b + 1 | 0;
+function A(a, b, c) {
+  for (var e = Array(c), d = 0; d < c; ) {
+    e[d] = a[b], d = d + 1 | 0, b = b + 1 | 0;
   }
-  return d;
+  return e;
 }
 
-function A(a, b) {
+function B(a, b) {
   for (;;) {
     var c = b;
-    var d = 0 === (b = a.length) ? 1 : b;
-    if (0 === (b = d - c.length | 0)) {
+    var e = 0 === (b = a.length) ? 1 : b;
+    if (0 === (b = e - c.length | 0)) {
       return a.apply(null, c);
     }
     if (0 > b) {
-      b = z(c, d, 0 | -b), a = a.apply(null, z(c, 0, d));
+      b = A(c, e, 0 | -b), a = a.apply(null, A(c, 0, e));
     } else {
       return function(a, c) {
-        return function(e) {
-          return A(a, c.concat([ e ]));
+        return function(d) {
+          return B(a, c.concat([ d ]));
         };
@@ -107,5 +107,5 @@ }(a, c);
 
-function C(a, b) {
+function D(a, b) {
   var c = a.length;
-  return 1 === c ? a(b) : function B(a, b, c) {
+  return 1 === c ? a(b) : function C(a, b, c) {
     switch (c) {
@@ -121,28 +121,28 @@ case 1:
      case 3:
-      return function(c, e) {
-        return a(b, c, e);
+      return function(c, d) {
+        return a(b, c, d);
       };
 
      case 4:
-      return function(c, e, g) {
-        return a(b, c, e, g);
+      return function(c, d, g) {
+        return a(b, c, d, g);
       };
 
      case 5:
-      return function(c, e, g, f) {
-        return a(b, c, e, g, f);
+      return function(c, d, g, f) {
+        return a(b, c, d, g, f);
       };
 
      case 6:
-      return function(c, e, g, f, h) {
-        return a(b, c, e, g, f, h);
+      return function(c, d, g, f, h) {
+        return a(b, c, d, g, f, h);
       };
 
      case 7:
-      return function(c, e, g, f, h, l) {
-        return a(b, c, e, g, f, h, l);
+      return function(c, d, g, f, h, l) {
+        return a(b, c, d, g, f, h, l);
       };
 
      default:
-      return A(a, [ b ]);
+      return B(a, [ b ]);
     }
@@ -152,8 +152,8 @@ }(a, b, c);
 
-function E(a, b, c) {
-  var d = a.length;
-  return 2 === d ? a(b, c) : function D(a, b, c, d) {
-    switch (d) {
+function F(a, b, c) {
+  var e = a.length;
+  return 2 === e ? a(b, c) : function E(a, b, c, e) {
+    switch (e) {
      case 1:
-      return A(a(b), [ c ]);
+      return B(a(b), [ c ]);
 
@@ -164,75 +164,75 @@ case 2:
      case 3:
-      return function(e) {
-        return a(b, c, e);
+      return function(d) {
+        return a(b, c, d);
       };
 
      case 4:
-      return function(e, d) {
-        return a(b, c, e, d);
+      return function(d, e) {
+        return a(b, c, d, e);
       };
 
      case 5:
-      return function(e, d, f) {
-        return a(b, c, e, d, f);
+      return function(d, e, f) {
+        return a(b, c, d, e, f);
       };
 
      case 6:
-      return function(e, d, f, h) {
-        return a(b, c, e, d, f, h);
+      return function(d, e, f, h) {
+        return a(b, c, d, e, f, h);
       };
 
      case 7:
-      return function(e, d, f, h, l) {
-        return a(b, c, e, d, f, h, l);
+      return function(d, e, f, h, l) {
+        return a(b, c, d, e, f, h, l);
       };
 
      default:
-      return A(a, [ b, c ]);
+      return B(a, [ b, c ]);
     }
-  }(a, b, c, d);
+  }(a, b, c, e);
 }
 
-function G(a, b, c, d) {
-  var e = a.length;
-  return 3 === e ? a(b, c, d) : function F(a, b, c, d, e) {
-    switch (e) {
+function H(a, b, c, e) {
+  var d = a.length;
+  return 3 === d ? a(b, c, e) : function G(a, b, c, e, d) {
+    switch (d) {
      case 1:
-      return A(a(b), [ c, d ]);
+      return B(a(b), [ c, e ]);
 
      case 2:
-      return A(a(b, c), [ d ]);
+      return B(a(b, c), [ e ]);
 
      case 3:
-      return a(b, c, d);
+      return a(b, c, e);
 
      case 4:
-      return function(e) {
-        return a(b, c, d, e);
+      return function(d) {
+        return a(b, c, e, d);
       };
 
      case 5:
-      return function(e, f) {
-        return a(b, c, d, e, f);
+      return function(d, f) {
+        return a(b, c, e, d, f);
       };
 
      case 6:
-      return function(e, f, h) {
-        return a(b, c, d, e, f, h);
+      return function(d, f, h) {
+        return a(b, c, e, d, f, h);
       };
 
      case 7:
-      return function(e, f, h, l) {
-        return a(b, c, d, e, f, h, l);
+      return function(d, f, h, l) {
+        return a(b, c, e, d, f, h, l);
       };
 
      default:
-      return A(a, [ b, c, d ]);
+      return B(a, [ b, c, e ]);
     }
-  }(a, b, c, d, e);
+  }(a, b, c, e, d);
 }
 
-function H(a, b) {
+function I(a, b) {
   return function(c) {
-    let d = r, e = r, g = void 0, f = void 0, h = !1, l = 0, p = !1;
-    C(a, (function(a) {
+    let e = r, d = r, g = void 0, f = void 0, h = !1, l = 0, n = !1;
+    D(a, (function(a) {
       var b = f;
@@ -243,6 +243,6 @@ if ("number" == typeof a) {
         }
-        if (p) {
+        if (n) {
           return 0;
         }
-        p = !0;
+        n = !0;
         return c(0);
@@ -253,16 +253,16 @@ }
         if (void 0 !== b) {
-          if (p) {
+          if (n) {
             return 0;
           }
-          g = n(a);
+          g = p(a);
           h = !1;
           return c(k(1, [ [ a, q(b) ] ]));
         }
-        g = n(a);
-        return h ? (h = !1, 0) : e(0);
+        g = p(a);
+        return h ? (h = !1, 0) : d(0);
       }
-      d = a[0];
+      e = a[0];
       return 0;
     }));
-    C(b, (function(a) {
+    D(b, (function(a) {
       var b = g;
@@ -273,6 +273,6 @@ if ("number" == typeof a) {
         }
-        if (p) {
+        if (n) {
           return 0;
         }
-        p = !0;
+        n = !0;
         return c(0);
@@ -283,21 +283,21 @@ }
         if (void 0 !== b) {
-          if (p) {
+          if (n) {
             return 0;
           }
-          f = n(a);
+          f = p(a);
           h = !1;
           return c(k(1, [ [ q(b), a ] ]));
         }
-        f = n(a);
-        return h ? (h = !1, 0) : d(0);
+        f = p(a);
+        return h ? (h = !1, 0) : e(0);
       }
-      e = a[0];
+      d = a[0];
       return 0;
     }));
     return c(k(0, [ function(a) {
-      if (p) {
+      if (n) {
         return 0;
       }
       if (a) {
-        return p = !0, d(1), e(1);
+        return n = !0, e(1), d(1);
       }
@@ -308,4 +308,4 @@ if (h) {
       h = !0;
-      d(a);
-      return e(a);
+      e(a);
+      return d(a);
     } ]));
@@ -315,11 +315,15 @@ };
 
-function I(a) {
+function J(a) {
   return function(b) {
     return function(c) {
-      function d(b) {
-        if ("number" == typeof b) {
-          if (l) {
-            l = !1;
-            if (void 0 !== (b = e.shift())) {
-              return C(a(q(b)), d);
+      function e(a) {
+        n = !0;
+        return D(a, d);
+      }
+      function d(d) {
+        if ("number" == typeof d) {
+          if (n) {
+            n = !1;
+            if (void 0 !== (d = g.shift())) {
+              return e(a(q(d)));
             }
@@ -329,21 +333,20 @@ if (v) {
             }
-            if (f) {
+            if (h) {
               return 0;
             }
-            f = !0;
-            return g(0);
+            h = !0;
+            return f(0);
           }
           return 0;
         }
-        if (b.tag) {
-          return l ? (c(b), p ? (p = !1, 0) : h(0)) : 0;
+        if (d.tag) {
+          return n ? (c(d), x ? (x = !1, 0) : l(0)) : 0;
         }
-        l = !0;
-        h = b = b[0];
-        p = !1;
-        return b(0);
+        l = d = d[0];
+        x = !1;
+        return d(0);
       }
-      let e = [], g = r, f = !1, h = r, l = !1, p = !1, v = !1;
-      C(b, (function(b) {
-        if ("number" == typeof b) {
+      let g = [], f = r, h = !1, l = r, n = !1, x = !1, v = !1;
+      D(b, (function(d) {
+        if ("number" == typeof d) {
           if (v) {
@@ -353,13 +356,13 @@ return 0;
           v = !0;
-          return l || 0 !== e.length ? 0 : c(0);
+          return n || 0 !== g.length ? 0 : c(0);
         }
-        if (b.tag) {
+        if (d.tag) {
           if (v) {
             return 0;
           }
-          b = b[0];
-          f = !1;
-          return l ? (e.push(b), 0) : C(a(b), d);
+          d = d[0];
+          h = !1;
+          return n ? (g.push(d), 0) : e(a(d));
         }
-        g = b[0];
+        f = d[0];
         return 0;
@@ -369,7 +372,7 @@ }));
         if (a) {
-          if (v || (v = !0, g(1)), l) {
-            return l = !1, h(1);
+          if (v || (v = !0, f(1)), n) {
+            return n = !1, l(1);
           }
-        } else if (v || f || (f = !0, g(0)), l && !p) {
-          return p = !0, h(0);
+        } else if (v || h || (h = !0, f(0)), n && !x) {
+          return x = !0, l(0);
         }
@@ -382,19 +385,19 @@ return 0;
 
-function J(a) {
+function K(a) {
   return a;
 }
 
-function K(a) {
+function L(a) {
   return a;
 }
 
-function L(a) {
+function M(a) {
   return a(0);
 }
 
-function M(a) {
+function N(a) {
   return function(b) {
     return function(c) {
-      let e = r, g = !1, f = [], h = !1;
-      C(b, (function(b) {
+      let d = r, g = !1, f = [], h = !1;
+      D(b, (function(b) {
         if ("number" == typeof b) {
@@ -412,11 +415,11 @@ if (h) {
           g = !1;
-          !function d(a) {
-            function b(a) {
-              return a !== d;
+          !function e(a) {
+            function e(a) {
+              return a !== b;
             }
-            let d = r;
-            return C(a, (function(a) {
+            let b = r;
+            return D(a, (function(a) {
               if ("number" == typeof a) {
                 if (0 !== f.length) {
-                  f = f.filter(b);
+                  f = f.filter(e);
                   a = 0 === f.length;
@@ -427,3 +430,3 @@ if (h && a) {
                   if (!g && a) {
-                    return g = !0, e(0);
+                    return g = !0, d(0);
                   }
@@ -434,5 +437,5 @@ }
               if (a.tag) {
-                return 0 !== f.length ? (c(k(1, [ a[0] ])), d(0)) : 0;
+                return 0 !== f.length ? (c(k(1, [ a[0] ])), b(0)) : 0;
               }
-              d = a = a[0];
+              b = a = a[0];
               f = f.concat(a);
@@ -446,11 +449,11 @@ return a(0);
           g = !0;
-          return e(0);
+          return d(0);
         }
-        e = b[0];
+        d = b[0];
         return 0;
       }));
       return c(k(0, [ function(a) {
-        a ? (h || (h = !0, e(a)), f.forEach((function c(c) {
+        a ? (h || (h = !0, d(a)), f.forEach((function c(c) {
           return c(a);
-        })), f = []) : (g || h ? g = !1 : (g = !0, e(0)), f.forEach(L));
+        })), f = []) : (g || h ? g = !1 : (g = !0, d(0)), f.forEach(M));
         return 0;
@@ -462,39 +465,39 @@ } ]));
 
-function N(a) {
+function O(a) {
   return a;
 }
 
-function O(a) {
+function P(a) {
   return a;
 }
 
-function P(a) {
-  return M(O)(a);
+function Q(a) {
+  return N(P)(a);
 }
 
-function Q(a) {
+function R(a) {
   return function(b) {
     return function(c) {
-      let d = !1;
-      return C(b, (function(e) {
-        if ("number" == typeof e) {
-          if (d) {
+      let e = !1;
+      return D(b, (function(d) {
+        if ("number" == typeof d) {
+          if (e) {
             return 0;
           }
-          d = !0;
-          return c(e);
+          e = !0;
+          return c(d);
         }
-        if (e.tag) {
-          if (d) {
+        if (d.tag) {
+          if (e) {
             return 0;
           }
-          a(e[0]);
-          return c(e);
+          a(d[0]);
+          return c(d);
         }
-        var b = e[0];
+        var b = d[0];
         return c(k(0, [ function(a) {
-          if (d) {
+          if (e) {
             return 0;
           }
-          a && (d = !0);
+          a && (e = !0);
           return b(a);
@@ -507,9 +510,9 @@ } ]));
 
-function R(a, b) {
+function S(a, b) {
   return function(c) {
-    return function(d) {
-      let e = b;
-      return C(c, (function(c) {
-        "number" == typeof c ? c = 0 : c.tag ? (e = a(e, c[0]), c = k(1, [ e ])) : c = k(0, [ c[0] ]);
-        return d(c);
+    return function(e) {
+      let d = b;
+      return D(c, (function(c) {
+        "number" == typeof c ? c = 0 : c.tag ? (d = a(d, c[0]), c = k(1, [ d ])) : c = k(0, [ c[0] ]);
+        return e(c);
       }));
@@ -520,14 +523,14 @@ };
 
-function S(a) {
+function T(a) {
   return a(0);
 }
 
-function T(a) {
+function U(a) {
   return function(b) {
     return function(c) {
-      function d(a) {
-        if ("number" == typeof a) {
-          if (h) {
+      function e(a) {
+        if (h) {
+          if ("number" == typeof a) {
             h = !1;
-            if (p) {
+            if (n) {
               return c(a);
@@ -539,32 +542,33 @@ }
             g = !0;
-            return e(0);
+            return d(0);
           }
-          return 0;
+          if (a.tag) {
+            return c(a), l ? (l = !1, 0) : f(0);
+          }
+          f = a = a[0];
+          l = !1;
+          return a(0);
         }
-        if (a.tag) {
-          return h ? (c(a), l ? (l = !1, 0) : f(0)) : 0;
-        }
-        h = !0;
-        f = a = a[0];
-        l = !1;
-        return a(0);
+        return 0;
       }
-      let e = r, g = !1, f = r, h = !1, l = !1, p = !1;
-      C(b, (function(b) {
+      let d = r, g = !1, f = r, h = !1, l = !1, n = !1;
+      D(b, (function(b) {
         if ("number" == typeof b) {
-          if (p) {
+          if (n) {
             return 0;
           }
-          p = !0;
+          n = !0;
           return h ? 0 : c(0);
         }
         if (b.tag) {
-          if (p) {
+          if (n) {
             return 0;
           }
           h && (f(1), f = r);
-          g ? g = !1 : (g = !0, e(0));
-          return C(b = a(b[0]), d);
+          g ? g = !1 : (g = !0, d(0));
+          b = a(b[0]);
+          h = !0;
+          return D(b, e);
         }
-        e = b[0];
+        d = b[0];
         return 0;
@@ -574,6 +578,6 @@ }));
         if (a) {
-          if (p || (p = !0, e(1)), h) {
+          if (n || (n = !0, d(1)), h) {
             return h = !1, f(1);
           }
-        } else if (p || g || (g = !0, e(0)), h && !l) {
+        } else if (n || g || (g = !0, d(0)), h && !l) {
           return l = !0, f(0);
@@ -587,26 +591,26 @@ }
 
-function U(a) {
+function V(a) {
   return a;
 }
 
-function V(a) {
+function W(a) {
   return function(b) {
     return function(c) {
-      function d() {
+      function e() {
         return g.shift();
       }
-      let e = r;
+      let d = r;
       var g = [];
-      return C(b, (function(b) {
+      return D(b, (function(b) {
         if ("number" == typeof b) {
-          return t(c, d);
+          return t(c, e);
         }
         if (b.tag) {
-          return g.length >= a && 0 < a && g.shift(), g.push(b[0]), e(0);
+          return g.length >= a && 0 < a && g.shift(), g.push(b[0]), d(0);
         }
         b = b[0];
         if (0 >= a) {
-          return b(1), y(c);
+          return b(1), z(c);
         }
-        e = b;
+        d = b;
         return b(0);
@@ -618,25 +622,25 @@ }));
 
-function W(a) {
+function X(a) {
   return function(b) {
-    let c = r, d = !1;
-    C(b, (function(b) {
-      if ("number" == typeof b) {
-        return d = !0, 0;
+    let c = r, e = !1;
+    D(b, (function(d) {
+      if ("number" == typeof d) {
+        return e = !0, 0;
       }
-      if (b.tag) {
-        if (d) {
+      if (d.tag) {
+        if (e) {
           return 0;
         }
-        a(b[0]);
+        a(d[0]);
         return c(0);
       }
-      c = b = b[0];
-      return b(0);
+      c = d = d[0];
+      return d(0);
     }));
     return {
       unsubscribe: function() {
-        if (d) {
+        if (e) {
           return 0;
         }
-        d = !0;
+        e = !0;
         return c(1);
@@ -648,29 +652,29 @@ }
 
-function X() {
+function Y() {
   return 0;
 }
 
-var Y = "function" == typeof Symbol ? Symbol.observable || (Symbol.observable = Symbol("observable")) : "@@observable";
+var Z = "function" == typeof Symbol ? Symbol.observable || (Symbol.observable = Symbol("observable")) : "@@observable";
 
-function Z() {
+function aa() {
   return 0;
 }
 
-function aa(a, b, c) {
+function ba(a, b, c) {
   a.addEventListener(b, c);
 }
 
-function ba(a, b, c) {
+function ca(a, b, c) {
   a.removeEventListener(b, c);
 }
 
-function ca(a, b) {
+function da(a, b) {
   return function(c) {
-    function d(a) {
+    function e(a) {
       return c(k(1, [ a ]));
     }
     c(k(0, [ function(c) {
-      return c ? G(ba, a, b, d) : 0;
+      return c ? H(ca, a, b, e) : 0;
     } ]));
-    return G(aa, a, b, d);
+    return H(ba, a, b, e);
   };
@@ -682,3 +686,3 @@ }
     return function(c) {
-      function d(a) {
+      function e(a) {
         if ("number" == typeof a) {
@@ -690,11 +694,11 @@ if (l) {
           g(1);
-          0 < e.length && c(k(1, [ e ]));
+          0 < d.length && c(k(1, [ d ]));
           return c(0);
         }
         if (a.tag) {
-          if (l || 0 >= e.length) {
+          if (l || 0 >= d.length) {
             return 0;
           }
-          a = e;
-          e = [];
+          a = d;
+          d = [];
           return c(k(1, [ a ]));
@@ -705,4 +709,4 @@ }
       }
-      let e = [], g = r, f = r, h = !1, l = !1;
-      C(b, (function(b) {
+      let d = [], g = r, f = r, h = !1, l = !1;
+      D(b, (function(b) {
         if ("number" == typeof b) {
@@ -714,3 +718,3 @@ if (l) {
           f(1);
-          0 < e.length && c(k(1, [ e ]));
+          0 < d.length && c(k(1, [ d ]));
           return c(0);
@@ -722,3 +726,3 @@ }
           }
-          e.push(b[0]);
+          d.push(b[0]);
           if (h) {
@@ -732,3 +736,3 @@ return h = !1, 0;
         g = b[0];
-        return C(a, d);
+        return D(a, e);
       }));
@@ -754,11 +758,11 @@ return c(k(0, [ function(a) {
 function combine(a, b) {
-  return E(H, a, b);
+  return F(I, a, b);
 }
 
 function concat(a) {
-  return I(K)(u(a));
+  return J(L)(u(a));
 }
 
 function concatAll(a) {
-  return I(J)(a);
+  return J(K)(a);
 }
@@ -769,9 +773,9 @@
     return function(c) {
-      function d() {
-        var a = e;
-        void 0 !== a && (e = void 0, clearTimeout(q(a)));
+      function e() {
+        var a = d;
+        void 0 !== a && (d = void 0, clearTimeout(q(a)));
         return 0;
       }
-      let e = void 0, g = !1, f = !1;
-      return C(b, (function(b) {
+      let d = void 0, g = !1, f = !1;
+      return D(b, (function(b) {
         if ("number" == typeof b) {
@@ -782,7 +786,7 @@ if (f) {
           f = !0;
-          return void 0 !== e ? (g = !0, 0) : c(0);
+          return void 0 !== d ? (g = !0, 0) : c(0);
         }
         if (b.tag) {
-          return f || (d(), e = n(setTimeout((function h() {
-            e = void 0;
+          return f || (e(), d = p(setTimeout((function h() {
+            d = void 0;
             c(b);
@@ -792,5 +796,5 @@ return g ? c(0) : 0;
         }
-        var p = b[0];
+        var n = b[0];
         return c(k(0, [ function(a) {
-          return f ? 0 : a ? (f = !0, g = !1, d(), p(1)) : p(0);
+          return f ? 0 : a ? (f = !0, g = !1, e(), n(1)) : n(0);
         } ]));
@@ -805,10 +809,10 @@ }));
     return function(c) {
-      let d = 0;
-      return C(b, (function(b) {
-        if ("number" != typeof b && !b.tag) {
-          return c(b);
+      let e = 0;
+      return D(b, (function(d) {
+        if ("number" != typeof d && !d.tag) {
+          return c(d);
         }
-        d = d + 1 | 0;
+        e = e + 1 | 0;
         setTimeout((function() {
-          return 0 !== d ? (d = d - 1 | 0, c(b)) : 0;
+          return 0 !== e ? (e = e - 1 | 0, c(d)) : 0;
         }), a);
@@ -824,12 +828,12 @@ return 0;
     return function(c) {
-      let d = r;
-      return C(b, (function(b) {
-        if ("number" == typeof b) {
-          return c(b);
+      let e = r;
+      return D(b, (function(d) {
+        if ("number" == typeof d) {
+          return c(d);
         }
-        if (b.tag) {
-          return a(b[0]) ? c(b) : d(0);
+        if (d.tag) {
+          return a(d[0]) ? c(d) : e(0);
         }
-        d = b[0];
-        return c(b);
+        e = d[0];
+        return c(d);
       }));
@@ -842,3 +846,3 @@ };
   return function(b) {
-    W(a)(b);
+    X(a)(b);
     return 0;
@@ -850,11 +854,11 @@ };
   return function(b) {
-    return E(a, 0, (function(a, d) {
+    return F(a, 0, (function(a, e) {
       switch (a) {
        case 0:
         return b(k(0, [ function c(a) {
-          return a ? d(2) : d(1);
+          return a ? e(2) : e(1);
         } ]));
 
        case 1:
-        return b(k(1, [ d ]));
+        return b(k(1, [ e ]));
 
@@ -869,3 +873,3 @@ case 2:
 function fromDomEvent(a, b) {
-  return E(ca, a, b);
+  return F(da, a, b);
 }
@@ -879,3 +883,3 @@
       if (a) {
-        return c = a[1], n(a[0]);
+        return c = a[1], p(a[0]);
       }
@@ -887,7 +891,7 @@ }));
 function fromObservable(a) {
-  var b = void 0 !== a[Y] ? a[Y]() : a;
+  var b = void 0 !== a[Z] ? a[Z]() : a;
   return function(a) {
     var c = b.subscribe({
-      next: function(b) {
-        return a(k(1, [ b ]));
+      next: function(c) {
+        return a(k(1, [ c ]));
       },
@@ -897,3 +901,3 @@ complete: function() {
       },
-      error: Z
+      error: aa
     });
@@ -923,4 +927,4 @@ return a(k(0, [ function(a) {
     let c = !1;
-    return b(k(0, [ function(d) {
-      if (d) {
+    return b(k(0, [ function(e) {
+      if (e) {
         return c = !0, 0;
@@ -941,3 +945,3 @@ }
     let c = 0;
-    var d = setInterval((function() {
+    var e = setInterval((function() {
       var a = c;
@@ -948,3 +952,3 @@ c = c + 1 | 0;
     return b(k(0, [ function(a) {
-      a && clearInterval(d);
+      a && clearInterval(e);
       return 0;
@@ -957,12 +961,12 @@ } ]));
   return function(b) {
-    let c = w, d = !1;
+    let c = w, e = !1;
     c = a({
       next: function(a) {
-        return d ? 0 : b(k(1, [ a ]));
+        return e ? 0 : b(k(1, [ a ]));
       },
       complete: function() {
-        if (d) {
+        if (e) {
           return 0;
         }
-        d = !0;
+        e = !0;
         return b(0);
@@ -972,3 +976,3 @@ }
     return b(k(0, [ function(a) {
-      return a && !d ? (d = !0, c()) : 0;
+      return a && !e ? (e = !0, c()) : 0;
     } ]));
@@ -981,9 +985,9 @@ };
   return {
-    source: function(b) {
-      function c(a) {
-        return a !== b;
+    source: function(c) {
+      function b(a) {
+        return a !== c;
       }
-      a = a.concat(b);
-      return b(k(0, [ function(b) {
-        b && (a = a.filter(c));
+      a = a.concat(c);
+      return c(k(0, [ function(c) {
+        c && (a = a.filter(b));
         return 0;
@@ -993,3 +997,3 @@ } ]));
     next: function(c) {
-      b || a.forEach((function d(a) {
+      b || a.forEach((function e(a) {
         return a(k(1, [ c ]));
@@ -1000,3 +1004,3 @@ }));
     complete: function() {
-      b || (b = !0, a.forEach(x));
+      b || (b = !0, a.forEach(y));
       return 0;
@@ -1010,3 +1014,3 @@ }
     return function(c) {
-      return C(b, (function(b) {
+      return D(b, (function(b) {
         b = "number" == typeof b ? 0 : b.tag ? k(1, [ a(b[0]) ]) : k(0, [ b[0] ]);
@@ -1020,3 +1024,3 @@ return c(b);
 function merge(a) {
-  return M(N)(u(a));
+  return N(O)(u(a));
 }
@@ -1031,9 +1035,9 @@
     return function(c) {
-      let d = !1;
-      return C(b, (function(b) {
+      let e = !1;
+      return D(b, (function(b) {
         if ("number" == typeof b) {
-          if (d) {
+          if (e) {
             return 0;
           }
-          d = !0;
+          e = !0;
           c(b);
@@ -1043,7 +1047,7 @@ return a();
         if (b.tag) {
-          return d ? 0 : c(b);
+          return e ? 0 : c(b);
         }
-        var e = b[0];
-        return c(k(0, [ function(b) {
-          return d ? 0 : b ? (d = !0, e(b), a()) : e(b);
+        var d = b[0];
+        return c(k(0, [ function(c) {
+          return e ? 0 : c ? (e = !0, d(c), a()) : d(c);
         } ]));
@@ -1058,3 +1062,3 @@ }));
     return function(c) {
-      return C(b, (function(b) {
+      return D(b, (function(b) {
         if ("number" == typeof b || b.tag) {
@@ -1071,3 +1075,3 @@ return c(b);
 function pipe() {
-  for (var a = arguments, b = arguments[0], c = 1, d = arguments.length; c < d; c++) {
+  for (var a = arguments, b = arguments[0], c = 1, e = arguments.length; c < e; c++) {
     b = a[c](b);
@@ -1079,3 +1083,3 @@ }
 function publish(a) {
-  return W(X)(a);
+  return X(Y)(a);
 }
@@ -1086,4 +1090,4 @@
     return function(c) {
-      let d = r, e = r, g = void 0, f = !1, h = !1;
-      C(b, (function(a) {
+      let e = r, d = r, g = void 0, f = !1, h = !1;
+      D(b, (function(a) {
         if ("number" == typeof a) {
@@ -1094,7 +1098,7 @@ if (h) {
           h = !0;
-          e(1);
+          d(1);
           return c(0);
         }
         if (a.tag) {
-          g = n(a[0]);
+          g = p(a[0]);
           if (f) {
@@ -1104,9 +1108,9 @@ return f = !1, 0;
           f = !0;
-          e(0);
-          return d(0);
+          d(0);
+          return e(0);
         }
-        d = a[0];
+        e = a[0];
         return 0;
       }));
-      C(a, (function(a) {
+      D(a, (function(a) {
         var b = g;
@@ -1118,3 +1122,3 @@ if ("number" == typeof a) {
           h = !0;
-          d(1);
+          e(1);
           return c(0);
@@ -1129,3 +1133,3 @@ }
         }
-        e = a[0];
+        d = a[0];
         return 0;
@@ -1138,3 +1142,3 @@ }));
         if (a) {
-          return h = !0, d(1), e(1);
+          return h = !0, e(1), d(1);
         }
@@ -1145,4 +1149,4 @@ if (f) {
         f = !0;
-        d(0);
-        return e(0);
+        e(0);
+        return d(0);
       } ]));
@@ -1154,3 +1158,3 @@ };
 function scan(a, b) {
-  return E(R, a, b);
+  return F(S, a, b);
 }
@@ -1160,8 +1164,8 @@
   function b(a) {
-    "number" == typeof a ? (c.forEach(S), c = []) : a.tag ? (e = !1, c.forEach((function b(b) {
-      return b(a);
-    }))) : d = a[0];
+    "number" == typeof a ? (c.forEach(T), c = []) : a.tag ? (d = !1, c.forEach((function b(c) {
+      return c(a);
+    }))) : e = a[0];
     return 0;
   }
-  let c = [], d = r, e = !1;
+  let c = [], e = r, d = !1;
   return function(g) {
@@ -1172,12 +1176,12 @@ function f(a) {
     c = c.concat(g);
-    1 === c.length && C(a, b);
+    1 === c.length && D(a, b);
     return g(k(0, [ function(a) {
       if (a) {
-        return c = c.filter(f), 0 === c.length ? d(1) : 0;
+        return c = c.filter(f), 0 === c.length ? e(1) : 0;
       }
-      if (e) {
+      if (d) {
         return 0;
       }
-      e = !0;
-      return d(a);
+      d = !0;
+      return e(a);
     } ]));
@@ -1190,4 +1194,4 @@ };
     return function(c) {
-      let d = r, e = a;
-      return C(b, (function(a) {
+      let e = r, d = a;
+      return D(b, (function(a) {
         if ("number" == typeof a) {
@@ -1197,5 +1201,5 @@ return c(a);
         if (a.tag) {
-          return 0 < e ? (e = e - 1 | 0, d(0)) : c(a);
+          return 0 < d ? (d = d - 1 | 0, e(0)) : c(a);
         }
-        d = a[0];
+        e = a[0];
         return c(a);
@@ -1210,5 +1214,5 @@ }));
     return function(c) {
-      function d(a) {
+      function e(a) {
         if ("number" == typeof a) {
-          return f ? (l = !0, e(1)) : 0;
+          return f ? (l = !0, d(1)) : 0;
         }
@@ -1221,4 +1225,4 @@ if (a.tag) {
       }
-      let e = r, g = r, f = !0, h = !1, l = !1;
-      C(b, (function(b) {
+      let d = r, g = r, f = !0, h = !1, l = !1;
+      D(b, (function(b) {
         if ("number" == typeof b) {
@@ -1233,3 +1237,3 @@ return f && g(1), l = !0, c(0);
             h = !0;
-            e(0);
+            d(0);
             return g(0);
@@ -1240,4 +1244,4 @@ }
         }
-        e = b[0];
-        return C(a, d);
+        d = b[0];
+        return D(a, e);
       }));
@@ -1249,3 +1253,3 @@ return c(k(0, [ function(a) {
         if (a) {
-          return l = !0, e(1), f ? g(1) : 0;
+          return l = !0, d(1), f ? g(1) : 0;
         }
@@ -1257,3 +1261,3 @@ if (h) {
         f && g(0);
-        return e(0);
+        return d(0);
       } ]));
@@ -1267,4 +1271,4 @@ };
     return function(c) {
-      let d = r, e = !0;
-      return C(b, (function(b) {
+      let e = r, d = !0;
+      return D(b, (function(b) {
         if ("number" == typeof b) {
@@ -1274,11 +1278,11 @@ return c(b);
         if (b.tag) {
-          if (e) {
+          if (d) {
             if (a(b[0])) {
-              return d(0);
+              return e(0);
             }
-            e = !1;
+            d = !1;
           }
           return c(b);
         }
-        d = b[0];
+        e = b[0];
         return c(b);
@@ -1291,3 +1295,3 @@ }));
 function switchAll(a) {
-  return T(U)(a);
+  return U(V)(a);
 }
@@ -1298,17 +1302,17 @@
     return function(c) {
-      let d = !1, e = 0, g = r;
-      C(b, (function(b) {
+      let e = !1, d = 0, g = r;
+      D(b, (function(b) {
         if ("number" == typeof b) {
-          if (d) {
+          if (e) {
             return 0;
           }
-          d = !0;
+          e = !0;
           return c(0);
         }
         if (b.tag) {
-          return e < a && !d && (e = e + 1 | 0, c(b), !d && e >= a) ? (d = !0, c(0), g(1)) : 0;
+          return d < a && !e && (d = d + 1 | 0, c(b), !e && d >= a) ? (e = !0, c(0), g(1)) : 0;
         }
         b = b[0];
         if (0 >= a) {
-          return d = !0, c(0), b(1);
+          return e = !0, c(0), b(1);
         }
@@ -1319,3 +1323,3 @@ g = b;
       return c(k(0, [ function(b) {
-        return d ? 0 : b ? (d = !0, g(1)) : e < a ? g(0) : 0;
+        return e ? 0 : b ? (e = !0, g(1)) : d < a ? g(0) : 0;
       } ]));
@@ -1329,3 +1333,3 @@ };
     return function(c) {
-      function d(a) {
+      function e(a) {
         if ("number" == typeof a) {
@@ -1335,3 +1339,3 @@ return 0;
         if (a.tag) {
-          return e = !0, g(1), c(0);
+          return d = !0, g(1), c(0);
         }
@@ -1341,9 +1345,9 @@ f = a = a[0];
       }
-      let e = !1, g = r, f = r;
-      C(b, (function(b) {
+      let d = !1, g = r, f = r;
+      D(b, (function(b) {
         if ("number" == typeof b) {
-          if (e) {
+          if (d) {
             return 0;
           }
-          e = !0;
+          d = !0;
           f(1);
@@ -1353,9 +1357,9 @@ return c(0);
         if (b.tag) {
-          return e ? 0 : c(b);
+          return d ? 0 : c(b);
         }
         g = b[0];
-        return C(a, d);
+        return D(a, e);
       }));
       return c(k(0, [ function(a) {
-        return e ? 0 : a ? (e = !0, g(1), f(1)) : g(0);
+        return d ? 0 : a ? (d = !0, g(1), f(1)) : g(0);
       } ]));
@@ -1369,13 +1373,13 @@ };
     return function(c) {
-      let d = r, e = !1;
-      return C(b, (function(b) {
+      let e = r, d = !1;
+      return D(b, (function(b) {
         if ("number" == typeof b) {
-          if (e) {
+          if (d) {
             return 0;
           }
-          e = !0;
+          d = !0;
           return c(0);
         }
         if (b.tag) {
-          if (e) {
+          if (d) {
             return 0;
@@ -1386,7 +1390,7 @@ }
           }
-          e = !0;
+          d = !0;
           c(0);
-          return d(1);
+          return e(1);
         }
-        d = b[0];
+        e = b[0];
         return c(b);
@@ -1401,7 +1405,7 @@ }));
     return function(c) {
-      function d() {
+      function e() {
         void 0 !== f && clearTimeout(q(f));
         return 0;
       }
-      function e() {
+      function d() {
         f = void 0;
@@ -1412,5 +1416,5 @@ g = !1;
       let g = !1, f = void 0;
-      return C(b, (function(b) {
+      return D(b, (function(b) {
         if ("number" == typeof b) {
-          return d(), c(0);
+          return e(), c(0);
         }
@@ -1422,4 +1426,4 @@ if (b.tag) {
           g = !0;
-          d();
-          f = n(setTimeout(e, a(b[0])));
+          e();
+          f = p(setTimeout(d, a(b[0])));
           return c(b);
@@ -1429,3 +1433,3 @@ }
         return c(k(0, [ function(a) {
-          return a ? (d(), h(1)) : h(a);
+          return a ? (e(), h(1)) : h(a);
         } ]));
@@ -1438,6 +1442,6 @@ }));
 function toArray(a) {
-  let b = [], c = r, d = !1;
-  C(a, (function(a) {
+  let b = [], c = r, e = !1;
+  D(a, (function(a) {
     if ("number" == typeof a) {
-      return d = !0, 0;
+      return e = !0, 0;
     }
@@ -1450,3 +1454,3 @@ if (a.tag) {
   }));
-  d || c(1);
+  e || c(1);
   return b;
@@ -1457,11 +1461,11 @@ }
   return function(b, c) {
-    return 0 === b ? C(a, (function d(a) {
+    return 0 === b ? D(a, (function e(a) {
       if ("number" == typeof a) {
-        return E(c, 2, 0);
+        return F(c, 2, 0);
       }
       if (a.tag) {
-        return E(c, 1, a[0]);
+        return F(c, 1, a[0]);
       }
       var b = a[0];
-      return E(c, 0, (function(a) {
+      return F(c, 0, (function(a) {
         switch (a) {
@@ -1485,9 +1489,9 @@ case 0:
     subscribe: function(b) {
-      let c = r, e = !1;
-      C(a, (function(a) {
+      let c = r, d = !1;
+      D(a, (function(a) {
         if ("number" == typeof a) {
-          return e = !0, b.complete();
+          return d = !0, b.complete();
         }
         if (a.tag) {
-          if (e) {
+          if (d) {
             return 0;
@@ -1503,6 +1507,6 @@ }
         unsubscribe: function() {
-          if (e) {
+          if (d) {
             return 0;
           }
-          e = !0;
+          d = !0;
           return c(1);
@@ -1513,3 +1517,3 @@ }
   };
-  b[Y] = function() {
+  b[Z] = function() {
     return b;
@@ -1522,3 +1526,3 @@ };
   return new Promise((function(b) {
-    return C(V(1)(a), (function(a) {
+    return D(W(1)(a), (function(a) {
       return "number" == typeof a ? 0 : a.tag ? b(a[0]) : a[0](0);
@@ -1529,2 +1533,2 @@ }));
 
-export { buffer, combine, concat, concatAll, I as concatMap, debounce, delay, y as empty, filter, P as flatten, forEach, u as fromArray, fromCallbag, fromDomEvent, fromList, fromObservable, fromPromise, fromValue, interval, make, makeSubject, map, merge, P as mergeAll, M as mergeMap, never, onEnd, Q as onPush, onStart, pipe, publish, sample, scan, share, skip, skipUntil, skipWhile, W as subscribe, switchAll, T as switchMap, take, V as takeLast, takeUntil, takeWhile, Q as tap, throttle, toArray, toCallbag, toObservable, toPromise };
+export { buffer, combine, concat, concatAll, J as concatMap, debounce, delay, z as empty, filter, Q as flatten, forEach, u as fromArray, fromCallbag, fromDomEvent, fromList, fromObservable, fromPromise, fromValue, interval, make, makeSubject, map, merge, Q as mergeAll, N as mergeMap, never, onEnd, R as onPush, onStart, pipe, publish, sample, scan, share, skip, skipUntil, skipWhile, X as subscribe, switchAll, U as switchMap, take, W as takeLast, takeUntil, takeWhile, R as tap, throttle, toArray, toCallbag, toObservable, toPromise };

dist/wonka.js

@@ -383,3 +383,3 @@ "use strict";
             if (void 0 !== (b = d.shift())) {
-              return _1(a(valFromOption(b)), e);
+              return n(a(valFromOption(b)));
             }
@@ -400,3 +400,2 @@ if (m) {
         }
-        k = !0;
         h = b = b[0];
@@ -407,2 +406,6 @@ l = !1;
       let d = [], f = talkbackPlaceholder, g = !1, h = talkbackPlaceholder, k = !1, l = !1, m = !1;
+      var n = function(a) {
+        k = !0;
+        return _1(a, e);
+      };
       _1(b, (function(b) {
@@ -424,3 +427,3 @@ if ("number" == typeof b) {
           g = !1;
-          return k ? (d.push(b), 0) : _1(a(b), e);
+          return k ? (d.push(b), 0) : n(a(b));
         }
@@ -583,4 +586,4 @@ f = b[0];
       function e(a) {
-        if ("number" == typeof a) {
-          if (h) {
+        if (h) {
+          if ("number" == typeof a) {
             h = !1;
@@ -596,11 +599,10 @@ if (l) {
           }
-          return 0;
+          if (a.tag) {
+            return c(a), k ? (k = !1, 0) : g(0);
+          }
+          g = a = a[0];
+          k = !1;
+          return a(0);
         }
-        if (a.tag) {
-          return h ? (c(a), k ? (k = !1, 0) : g(0)) : 0;
-        }
-        h = !0;
-        g = a = a[0];
-        k = !1;
-        return a(0);
+        return 0;
       }
@@ -622,3 +624,5 @@ let d = talkbackPlaceholder, f = !1, g = talkbackPlaceholder, h = !1, k = !1, l = !1;
           f ? f = !1 : (f = !0, d(0));
-          return _1(b = a(b[0]), e);
+          b = a(b[0]);
+          h = !0;
+          return _1(b, e);
         }
@@ -625,0 +629,0 @@ d = b[0];

dist/wonka.min.js

@@ -1,1 +0,1 @@
-"use strict";function n(n,t){return t.tag=n,t}var t=[];function r(n){return void 0===n?((n=[t,0]).tag=256,n):(null!==n&&n[0]===t&&((n=[t,n[1]+1|0]).tag=256),n)}function u(n){return null===n||n[0]!==t?n:0!==(n=n[1])?[t,n-1|0]:void 0}function e(n){return 0}function o(t,r){let e=!1,o=!1,f=!1;return t(n(0,[function(i){if(i)e=!0;else if(o)f=!0;else{for(o=f=!0;f&&!e;)void 0!==(i=r())?(f=!1,t(n(1,[u(i)]))):(e=!0,t(0));o=!1}return 0}]))}function f(n){return function(t){var u=n.length;let e=0;return o(t,(function(){if(e<u){var t=n[e];return e=e+1|0,r(t)}}))}}function i(){return 0}function c(n){return n(0)}function a(t){let r=!1;return t(n(0,[function(n){return n?(r=!0,0):r?0:t(0)}]))}var s=f,l=a;function p(n,t,r){for(var u=Array(r),e=0;e<r;)u[e]=n[t],e=e+1|0,t=t+1|0;return u}function b(n,t){for(;;){var r=t,u=0===(t=n.length)?1:t;if(0==(t=u-r.length|0))return n.apply(null,r);if(!(0>t))return function(n,t){return function(r){return b(n,t.concat([r]))}}(n,r);t=p(r,u,0|-t),n=n.apply(null,p(r,0,u))}}function m(n,t){var r=n.length;return 1===r?n(t):function(n,t,r){switch(r){case 1:return n(t);case 2:return function(r){return n(t,r)};case 3:return function(r,u){return n(t,r,u)};case 4:return function(r,u,e){return n(t,r,u,e)};case 5:return function(r,u,e,o){return n(t,r,u,e,o)};case 6:return function(r,u,e,o,f){return n(t,r,u,e,o,f)};case 7:return function(r,u,e,o,f,i){return n(t,r,u,e,o,f,i)};default:return b(n,[t])}}(n,t,r)}function v(n,t,r){var u=n.length;return 2===u?n(t,r):function(n,t,r,u){switch(u){case 1:return b(n(t),[r]);case 2:return n(t,r);case 3:return function(u){return n(t,r,u)};case 4:return function(u,e){return n(t,r,u,e)};case 5:return function(u,e,o){return n(t,r,u,e,o)};case 6:return function(u,e,o,f){return n(t,r,u,e,o,f)};case 7:return function(u,e,o,f,i){return n(t,r,u,e,o,f,i)};default:return b(n,[t,r])}}(n,t,r,u)}function g(n,t,r,u){var e=n.length;return 3===e?n(t,r,u):function(n,t,r,u,e){switch(e){case 1:return b(n(t),[r,u]);case 2:return b(n(t,r),[u]);case 3:return n(t,r,u);case 4:return function(e){return n(t,r,u,e)};case 5:return function(e,o){return n(t,r,u,e,o)};case 6:return function(e,o,f){return n(t,r,u,e,o,f)};case 7:return function(e,o,f,i){return n(t,r,u,e,o,f,i)};default:return b(n,[t,r,u])}}(n,t,r,u,e)}function x(t,o){return function(f){let i=e,c=e,a=void 0,s=void 0,l=!1,p=0,b=!1;return m(t,(function(t){var e=s;return"number"==typeof t?1>p?(p=p+1|0,0):b?0:(b=!0,f(0)):t.tag?(t=t[0],void 0!==e?b?0:(a=r(t),l=!1,f(n(1,[[t,u(e)]]))):(a=r(t),l?(l=!1,0):c(0))):(i=t[0],0)})),m(o,(function(t){var e=a;return"number"==typeof t?1>p?(p=p+1|0,0):b?0:(b=!0,f(0)):t.tag?(t=t[0],void 0!==e?b?0:(s=r(t),l=!1,f(n(1,[[u(e),t]]))):(s=r(t),l?(l=!1,0):i(0))):(c=t[0],0)})),f(n(0,[function(n){return b?0:n?(b=!0,i(1),c(1)):l?0:(l=!0,i(n),c(n))}]))}}function y(t){return function(r){return function(o){function f(n){return"number"==typeof n?l?(l=!1,void 0!==(n=i.shift())?m(t(u(n)),f):b?o(0):a?0:(a=!0,c(0))):0:n.tag?l?(o(n),p?(p=!1,0):s(0)):0:(l=!0,s=n=n[0],p=!1,n(0))}let i=[],c=e,a=!1,s=e,l=!1,p=!1,b=!1;return m(r,(function(n){return"number"==typeof n?b?0:(b=!0,!l&&function(n){return 0===n.length}(i)?o(0):0):n.tag?b?0:(n=n[0],a=!1,l?(i.push(n),0):m(t(n),f)):(c=n[0],0)})),o(n(0,[function(n){if(n){if(b||(b=!0,c(1)),l)return l=!1,s(1)}else if(b||a||(a=!0,c(0)),l&&!p)return p=!0,s(0);return 0}]))}}}function h(n){return n}function d(n){return n}function E(n){return n(0)}function k(t){return function(r){return function(u){let o=e,f=!1,i=[],c=!1;return m(r,(function(r){return"number"==typeof r?c?0:(c=!0,0===i.length?u(0):0):r.tag?c?0:(f=!1,function(t){function r(n){return n!==a}let a=e;m(t,(function(t){if("number"==typeof t){if(0!==i.length){if(i=i.filter(r),t=0===i.length,c&&t)return u(0);if(!f&&t)return f=!0,o(0)}return 0}return t.tag?0!==i.length?(u(n(1,[t[0]])),a(0)):0:(a=t=t[0],i=i.concat(t),t(0))}))}(t(r[0])),f?0:(f=!0,o(0))):(o=r[0],0)})),u(n(0,[function(n){return n?(c||(c=!0,o(n)),i.forEach((function(t){return t(n)})),i=[]):(f||c?f=!1:(f=!0,o(0)),i.forEach(E)),0}]))}}}function w(n){return n}function A(n){return n}function S(n){return k(A)(n)}function P(t){return function(r){return function(u){let e=!1;return m(r,(function(r){if("number"==typeof r)return e?0:(e=!0,u(r));if(r.tag)return e?0:(t(r[0]),u(r));var o=r[0];return u(n(0,[function(n){return e?0:(n&&(e=!0),o(n))}]))}))}}}function T(t,r){return function(u){return function(e){let o=r;return m(u,(function(r){return"number"==typeof r?r=0:r.tag?(o=t(o,r[0]),r=n(1,[o])):r=n(0,[r[0]]),e(r)}))}}}function L(n){return n(0)}function M(t){return function(r){return function(u){function o(n){return"number"==typeof n?a?(a=!1,l?u(n):i?0:(i=!0,f(0))):0:n.tag?a?(u(n),s?(s=!1,0):c(0)):0:(a=!0,c=n=n[0],s=!1,n(0))}let f=e,i=!1,c=e,a=!1,s=!1,l=!1;return m(r,(function(n){return"number"==typeof n?l?0:(l=!0,a?0:u(0)):n.tag?l?0:(a&&(c(1),c=e),i?i=!1:(i=!0,f(0)),m(n=t(n[0]),o)):(f=n[0],0)})),u(n(0,[function(n){if(n){if(l||(l=!0,f(1)),a)return a=!1,c(1)}else if(l||i||(i=!0,f(0)),a&&!s)return s=!0,c(0);return 0}]))}}}function C(n){return n}function I(n){return function(t){return function(r){function u(){return i.shift()}let f=e;var i=[];return m(t,(function(t){return"number"==typeof t?o(r,u):t.tag?(i.length>=n&&0<n&&i.shift(),i.push(t[0]),f(0)):(t=t[0],0>=n?(t(1),a(r)):(f=t,t(0)))}))}}}var O=y,U=k,W=S,j=S,D=P,V=P,q=M,z=I;function B(n){return function(t){let r=e,u=!1;return m(t,(function(t){return"number"==typeof t?(u=!0,0):t.tag?u?0:(n(t[0]),r(0)):(r=t=t[0],t(0))})),{unsubscribe:function(n){return u?0:(u=!0,r(1))}}}}function F(n){return 0}var G=B,H="function"==typeof Symbol?Symbol.observable||(Symbol.observable=Symbol("observable")):"@@observable";function J(n){return 0}function K(n,t,r){n.addEventListener(t,r)}function N(n,t,r){n.removeEventListener(t,r)}function Q(t,r){return function(u){var e=K,o=N,f=function(t){return u(n(1,[t]))};return u(n(0,[function(n){return n?g(o,t,r,f):0}])),g(e,t,r,f)}}exports.buffer=function(t){return function(r){return function(u){function o(t){return"number"==typeof t?s?0:(s=!0,i(1),0<f.length&&u(n(1,[f])),u(0)):t.tag?s||0>=f.length?0:(t=f,f=[],u(n(1,[t]))):(c=t[0],0)}let f=[],i=e,c=e,a=!1,s=!1;return m(r,(function(r){return"number"==typeof r?s?0:(s=!0,c(1),0<f.length&&u(n(1,[f])),u(0)):r.tag?s?0:(f.push(r[0]),a?(a=!1,0):(a=!0,i(0),c(0))):(i=r[0],m(t,o))})),u(n(0,[function(n){return s?0:n?(s=!0,i(1),c(1)):a?0:(a=!0,i(0),c(0))}]))}}},exports.combine=function(n,t){return v(x,n,t)},exports.concat=function(n){return y(d)(f(n))},exports.concatAll=function(n){return y(h)(n)},exports.concatMap=O,exports.debounce=function(t){return function(e){return function(o){let f=void 0,i=!1,c=!1;var a=function(n){return void 0!==(n=f)&&(f=void 0,clearTimeout(u(n))),0};return m(e,(function(u){if("number"==typeof u)return c?0:(c=!0,void 0!==f?(i=!0,0):o(0));if(u.tag)return c||(a(),f=r(setTimeout((function(n){return f=void 0,o(u),i?o(0):0}),t(u[0])))),0;var e=u[0];return o(n(0,[function(n){return c?0:n?(c=!0,i=!1,a(),e(1)):e(0)}]))}))}}},exports.delay=function(n){return function(t){return function(r){let u=0;return m(t,(function(t){return"number"==typeof t||t.tag?(u=u+1|0,setTimeout((function(n){return 0!==u?(u=u-1|0,r(t)):0}),n),0):r(t)}))}}},exports.empty=l,exports.filter=function(n){return function(t){return function(r){let u=e;return m(t,(function(t){return"number"==typeof t?r(t):t.tag?n(t[0])?r(t):u(0):(u=t[0],r(t))}))}}},exports.flatten=j,exports.forEach=function(n){return function(t){return B(n)(t),0}},exports.fromArray=s,exports.fromCallbag=function(t){return function(r){return v(t,0,(function(t,u){switch(t){case 0:return r(n(0,[function(n){return u(n?2:1)}]));case 1:return r(n(1,[u]));case 2:return r(0)}}))}},exports.fromDomEvent=function(n,t){return v(Q,n,t)},exports.fromList=function(n){return function(t){let u=n;return o(t,(function(){var n=u;if(n)return u=n[1],r(n[0])}))}},exports.fromObservable=function(t){var r=void 0!==t[H]?t[H]():t;return function(t){var u=r.subscribe({next:function(r){return t(n(1,[r]))},complete:function(){return t(0)},error:J});return t(n(0,[function(n){return n?u.unsubscribe():0}]))}},exports.fromPromise=function(t){return function(r){let u=!1;return t.then((function(t){return u||(r(n(1,[t])),r(0)),Promise.resolve(0)})),r(n(0,[function(n){return n&&(u=!0),0}]))}},exports.fromValue=function(t){return function(r){let u=!1;return r(n(0,[function(e){return e?(u=!0,0):u?0:(u=!0,r(n(1,[t])),r(0))}]))}},exports.interval=function(t){return function(r){let u=0;var e=setInterval((function(t){return t=u,u=u+1|0,r(n(1,[t]))}),t);return r(n(0,[function(n){return n&&clearInterval(e),0}]))}},exports.make=function(t){return function(r){let u=i,e=!1;return u=t({next:function(t){return e?0:r(n(1,[t]))},complete:function(n){return e?0:(e=!0,r(0))}}),r(n(0,[function(n){return n&&!e?(e=!0,u()):0}]))}},exports.makeSubject=function(t){let r=[],u=!1;return{source:function(t){function u(n){return n!==t}return r=r.concat(t),t(n(0,[function(n){return n&&(r=r.filter(u)),0}]))},next:function(t){return u||r.forEach((function(r){return r(n(1,[t]))})),0},complete:function(n){return u||(u=!0,r.forEach(c)),0}}},exports.map=function(t){return function(r){return function(u){return m(r,(function(r){return r="number"==typeof r?0:r.tag?n(1,[t(r[0])]):n(0,[r[0]]),u(r)}))}}},exports.merge=function(n){return k(w)(f(n))},exports.mergeAll=W,exports.mergeMap=U,exports.never=function(t){return t(n(0,[e]))},exports.onEnd=function(t){return function(r){return function(u){let e=!1;return m(r,(function(r){if("number"==typeof r)return e?0:(e=!0,u(r),t());if(r.tag)return e?0:u(r);var o=r[0];return u(n(0,[function(n){return e?0:n?(e=!0,o(n),t()):o(n)}]))}))}}},exports.onPush=D,exports.onStart=function(n){return function(t){return function(r){return m(t,(function(t){return"number"==typeof t||t.tag?r(t):(r(t),n())}))}}},exports.pipe=function(){for(var n=arguments,t=arguments[0],r=1,u=arguments.length;r<u;r++)t=n[r](t);return t},exports.publish=function(n){return B(F)(n)},exports.sample=function(t){return function(o){return function(f){let i=e,c=e,a=void 0,s=!1,l=!1;return m(o,(function(n){return"number"==typeof n?l?0:(l=!0,c(1),f(0)):n.tag?(a=r(n[0]),s?(s=!1,0):(s=!0,c(0),i(0))):(i=n[0],0)})),m(t,(function(t){var r=a;return"number"==typeof t?l?0:(l=!0,i(1),f(0)):t.tag?void 0===r||l?0:(a=void 0,f(n(1,[u(r)]))):(c=t[0],0)})),f(n(0,[function(n){return l?0:n?(l=!0,i(1),c(1)):s?0:(s=!0,i(0),c(0))}]))}}},exports.scan=function(n,t){return v(T,n,t)},exports.share=function(t){function r(n){return"number"==typeof n?(u.forEach(L),u=[]):n.tag?(f=!1,u.forEach((function(t){return t(n)}))):o=n[0],0}let u=[],o=e,f=!1;return function(e){function i(n){return n!==e}return u=u.concat(e),1===u.length&&m(t,r),e(n(0,[function(n){return n?(u=u.filter(i),0===u.length?o(1):0):f?0:(f=!0,o(n))}]))}},exports.skip=function(n){return function(t){return function(r){let u=e,o=n;return m(t,(function(n){return"number"==typeof n?r(n):n.tag?0<o?(o=o-1|0,u(0)):r(n):(u=n[0],r(n))}))}}},exports.skipUntil=function(t){return function(r){return function(u){function o(n){return"number"==typeof n?c?(s=!0,f(1)):0:n.tag?(c=!1,i(1)):(i=n=n[0],n(0))}let f=e,i=e,c=!0,a=!1,s=!1;return m(r,(function(n){return"number"==typeof n?(c&&i(1),s=!0,u(0)):n.tag?c||s?a?(a=!1,0):(a=!0,f(0),i(0)):(a=!1,u(n)):(f=n[0],m(t,o))})),u(n(0,[function(n){return s?0:n?(s=!0,f(1),c?i(1):0):a?0:(a=!0,c&&i(0),f(0))}]))}}},exports.skipWhile=function(n){return function(t){return function(r){let u=e,o=!0;return m(t,(function(t){if("number"==typeof t)return r(t);if(t.tag){if(o){if(n(t[0]))return u(0);o=!1}return r(t)}return u=t[0],r(t)}))}}},exports.subscribe=G,exports.switchAll=function(n){return M(C)(n)},exports.switchMap=q,exports.take=function(t){return function(r){return function(u){let o=!1,f=0,i=e;return m(r,(function(n){return"number"==typeof n?o?0:(o=!0,u(0)):n.tag?f<t&&!o&&(f=f+1|0,u(n),!o&&f>=t)?(o=!0,u(0),i(1)):0:(n=n[0],0>=t?(o=!0,u(0),n(1)):(i=n,0))})),u(n(0,[function(n){return o?0:n?(o=!0,i(1)):f<t?i(0):0}]))}}},exports.takeLast=z,exports.takeUntil=function(t){return function(r){return function(u){function o(n){return"number"==typeof n?0:n.tag?(f=!0,i(1),u(0)):(c=n=n[0],n(0))}let f=!1,i=e,c=e;return m(r,(function(n){return"number"==typeof n?f?0:(f=!0,c(1),u(0)):n.tag?f?0:u(n):(i=n[0],m(t,o))})),u(n(0,[function(n){return f?0:n?(f=!0,i(1),c(1)):i(0)}]))}}},exports.takeWhile=function(n){return function(t){return function(r){let u=e,o=!1;return m(t,(function(t){return"number"==typeof t?o?0:(o=!0,r(0)):t.tag?o?0:n(t[0])?r(t):(o=!0,r(0),u(1)):(u=t[0],r(t))}))}}},exports.tap=V,exports.throttle=function(t){return function(e){return function(o){function f(n){return c=void 0,i=!1,0}let i=!1,c=void 0;var a=function(n){return void 0!==(n=c)&&clearTimeout(u(n)),0};return m(e,(function(u){if("number"==typeof u)return a(),o(0);if(u.tag)return i?0:(i=!0,a(),c=r(setTimeout(f,t(u[0]))),o(u));var e=u[0];return o(n(0,[function(n){return n?(a(),e(1)):e(n)}]))}))}}},exports.toArray=function(n){let t=[],r=e,u=!1;return m(n,(function(n){return"number"==typeof n?(u=!0,0):n.tag?(t.push(n[0]),r(0)):(r=n=n[0],n(0))})),u||r(1),t},exports.toCallbag=function(n){return function(t,r){return 0===t?m(n,(function(n){if("number"==typeof n)return v(r,2,0);if(n.tag)return v(r,1,n[0]);var t=n[0];return v(r,0,(function(n){switch(n){case 0:return 0;case 1:return t(0);case 2:return t(1)}}))})):0}},exports.toObservable=function(n){var t={subscribe:function(t){let r=e,u=!1;return m(n,(function(n){return"number"==typeof n?(u=!0,t.complete()):n.tag?u?0:(t.next(n[0]),r(0)):(r=n=n[0],n(0))})),{unsubscribe:function(){return u?0:(u=!0,r(1))}}}};return t[H]=function(n){return t},t},exports.toPromise=function(n){return new Promise((function(t,r){return m(I(1)(n),(function(n){return"number"==typeof n?0:n.tag?t(n[0]):n[0](0)}))}))};
+"use strict";function n(n,t){return t.tag=n,t}var t=[];function r(n){return void 0===n?((n=[t,0]).tag=256,n):(null!==n&&n[0]===t&&((n=[t,n[1]+1|0]).tag=256),n)}function u(n){return null===n||n[0]!==t?n:0!==(n=n[1])?[t,n-1|0]:void 0}function e(n){return 0}function o(t,r){let e=!1,o=!1,f=!1;return t(n(0,[function(i){if(i)e=!0;else if(o)f=!0;else{for(o=f=!0;f&&!e;)void 0!==(i=r())?(f=!1,t(n(1,[u(i)]))):(e=!0,t(0));o=!1}return 0}]))}function f(n){return function(t){var u=n.length;let e=0;return o(t,(function(){if(e<u){var t=n[e];return e=e+1|0,r(t)}}))}}function i(){return 0}function c(n){return n(0)}function a(t){let r=!1;return t(n(0,[function(n){return n?(r=!0,0):r?0:t(0)}]))}var s=f,l=a;function p(n,t,r){for(var u=Array(r),e=0;e<r;)u[e]=n[t],e=e+1|0,t=t+1|0;return u}function b(n,t){for(;;){var r=t,u=0===(t=n.length)?1:t;if(0==(t=u-r.length|0))return n.apply(null,r);if(!(0>t))return function(n,t){return function(r){return b(n,t.concat([r]))}}(n,r);t=p(r,u,0|-t),n=n.apply(null,p(r,0,u))}}function m(n,t){var r=n.length;return 1===r?n(t):function(n,t,r){switch(r){case 1:return n(t);case 2:return function(r){return n(t,r)};case 3:return function(r,u){return n(t,r,u)};case 4:return function(r,u,e){return n(t,r,u,e)};case 5:return function(r,u,e,o){return n(t,r,u,e,o)};case 6:return function(r,u,e,o,f){return n(t,r,u,e,o,f)};case 7:return function(r,u,e,o,f,i){return n(t,r,u,e,o,f,i)};default:return b(n,[t])}}(n,t,r)}function v(n,t,r){var u=n.length;return 2===u?n(t,r):function(n,t,r,u){switch(u){case 1:return b(n(t),[r]);case 2:return n(t,r);case 3:return function(u){return n(t,r,u)};case 4:return function(u,e){return n(t,r,u,e)};case 5:return function(u,e,o){return n(t,r,u,e,o)};case 6:return function(u,e,o,f){return n(t,r,u,e,o,f)};case 7:return function(u,e,o,f,i){return n(t,r,u,e,o,f,i)};default:return b(n,[t,r])}}(n,t,r,u)}function g(n,t,r,u){var e=n.length;return 3===e?n(t,r,u):function(n,t,r,u,e){switch(e){case 1:return b(n(t),[r,u]);case 2:return b(n(t,r),[u]);case 3:return n(t,r,u);case 4:return function(e){return n(t,r,u,e)};case 5:return function(e,o){return n(t,r,u,e,o)};case 6:return function(e,o,f){return n(t,r,u,e,o,f)};case 7:return function(e,o,f,i){return n(t,r,u,e,o,f,i)};default:return b(n,[t,r,u])}}(n,t,r,u,e)}function x(t,o){return function(f){let i=e,c=e,a=void 0,s=void 0,l=!1,p=0,b=!1;return m(t,(function(t){var e=s;return"number"==typeof t?1>p?(p=p+1|0,0):b?0:(b=!0,f(0)):t.tag?(t=t[0],void 0!==e?b?0:(a=r(t),l=!1,f(n(1,[[t,u(e)]]))):(a=r(t),l?(l=!1,0):c(0))):(i=t[0],0)})),m(o,(function(t){var e=a;return"number"==typeof t?1>p?(p=p+1|0,0):b?0:(b=!0,f(0)):t.tag?(t=t[0],void 0!==e?b?0:(s=r(t),l=!1,f(n(1,[[u(e),t]]))):(s=r(t),l?(l=!1,0):i(0))):(c=t[0],0)})),f(n(0,[function(n){return b?0:n?(b=!0,i(1),c(1)):l?0:(l=!0,i(n),c(n))}]))}}function y(t){return function(r){return function(o){function f(n){return"number"==typeof n?l?(l=!1,void 0!==(n=i.shift())?v(t(u(n))):b?o(0):a?0:(a=!0,c(0))):0:n.tag?l?(o(n),p?(p=!1,0):s(0)):0:(s=n=n[0],p=!1,n(0))}let i=[],c=e,a=!1,s=e,l=!1,p=!1,b=!1;var v=function(n){return l=!0,m(n,f)};return m(r,(function(n){return"number"==typeof n?b?0:(b=!0,!l&&function(n){return 0===n.length}(i)?o(0):0):n.tag?b?0:(n=n[0],a=!1,l?(i.push(n),0):v(t(n))):(c=n[0],0)})),o(n(0,[function(n){if(n){if(b||(b=!0,c(1)),l)return l=!1,s(1)}else if(b||a||(a=!0,c(0)),l&&!p)return p=!0,s(0);return 0}]))}}}function h(n){return n}function d(n){return n}function E(n){return n(0)}function k(t){return function(r){return function(u){let o=e,f=!1,i=[],c=!1;return m(r,(function(r){return"number"==typeof r?c?0:(c=!0,0===i.length?u(0):0):r.tag?c?0:(f=!1,function(t){function r(n){return n!==a}let a=e;m(t,(function(t){if("number"==typeof t){if(0!==i.length){if(i=i.filter(r),t=0===i.length,c&&t)return u(0);if(!f&&t)return f=!0,o(0)}return 0}return t.tag?0!==i.length?(u(n(1,[t[0]])),a(0)):0:(a=t=t[0],i=i.concat(t),t(0))}))}(t(r[0])),f?0:(f=!0,o(0))):(o=r[0],0)})),u(n(0,[function(n){return n?(c||(c=!0,o(n)),i.forEach((function(t){return t(n)})),i=[]):(f||c?f=!1:(f=!0,o(0)),i.forEach(E)),0}]))}}}function w(n){return n}function A(n){return n}function S(n){return k(A)(n)}function P(t){return function(r){return function(u){let e=!1;return m(r,(function(r){if("number"==typeof r)return e?0:(e=!0,u(r));if(r.tag)return e?0:(t(r[0]),u(r));var o=r[0];return u(n(0,[function(n){return e?0:(n&&(e=!0),o(n))}]))}))}}}function T(t,r){return function(u){return function(e){let o=r;return m(u,(function(r){return"number"==typeof r?r=0:r.tag?(o=t(o,r[0]),r=n(1,[o])):r=n(0,[r[0]]),e(r)}))}}}function L(n){return n(0)}function M(t){return function(r){return function(u){function o(n){return a?"number"==typeof n?(a=!1,l?u(n):i?0:(i=!0,f(0))):n.tag?(u(n),s?(s=!1,0):c(0)):(c=n=n[0],s=!1,n(0)):0}let f=e,i=!1,c=e,a=!1,s=!1,l=!1;return m(r,(function(n){return"number"==typeof n?l?0:(l=!0,a?0:u(0)):n.tag?l?0:(a&&(c(1),c=e),i?i=!1:(i=!0,f(0)),n=t(n[0]),a=!0,m(n,o)):(f=n[0],0)})),u(n(0,[function(n){if(n){if(l||(l=!0,f(1)),a)return a=!1,c(1)}else if(l||i||(i=!0,f(0)),a&&!s)return s=!0,c(0);return 0}]))}}}function C(n){return n}function I(n){return function(t){return function(r){function u(){return i.shift()}let f=e;var i=[];return m(t,(function(t){return"number"==typeof t?o(r,u):t.tag?(i.length>=n&&0<n&&i.shift(),i.push(t[0]),f(0)):(t=t[0],0>=n?(t(1),a(r)):(f=t,t(0)))}))}}}var O=y,U=k,W=S,j=S,D=P,V=P,q=M,z=I;function B(n){return function(t){let r=e,u=!1;return m(t,(function(t){return"number"==typeof t?(u=!0,0):t.tag?u?0:(n(t[0]),r(0)):(r=t=t[0],t(0))})),{unsubscribe:function(n){return u?0:(u=!0,r(1))}}}}function F(n){return 0}var G=B,H="function"==typeof Symbol?Symbol.observable||(Symbol.observable=Symbol("observable")):"@@observable";function J(n){return 0}function K(n,t,r){n.addEventListener(t,r)}function N(n,t,r){n.removeEventListener(t,r)}function Q(t,r){return function(u){var e=K,o=N,f=function(t){return u(n(1,[t]))};return u(n(0,[function(n){return n?g(o,t,r,f):0}])),g(e,t,r,f)}}exports.buffer=function(t){return function(r){return function(u){function o(t){return"number"==typeof t?s?0:(s=!0,i(1),0<f.length&&u(n(1,[f])),u(0)):t.tag?s||0>=f.length?0:(t=f,f=[],u(n(1,[t]))):(c=t[0],0)}let f=[],i=e,c=e,a=!1,s=!1;return m(r,(function(r){return"number"==typeof r?s?0:(s=!0,c(1),0<f.length&&u(n(1,[f])),u(0)):r.tag?s?0:(f.push(r[0]),a?(a=!1,0):(a=!0,i(0),c(0))):(i=r[0],m(t,o))})),u(n(0,[function(n){return s?0:n?(s=!0,i(1),c(1)):a?0:(a=!0,i(0),c(0))}]))}}},exports.combine=function(n,t){return v(x,n,t)},exports.concat=function(n){return y(d)(f(n))},exports.concatAll=function(n){return y(h)(n)},exports.concatMap=O,exports.debounce=function(t){return function(e){return function(o){let f=void 0,i=!1,c=!1;var a=function(n){return void 0!==(n=f)&&(f=void 0,clearTimeout(u(n))),0};return m(e,(function(u){if("number"==typeof u)return c?0:(c=!0,void 0!==f?(i=!0,0):o(0));if(u.tag)return c||(a(),f=r(setTimeout((function(n){return f=void 0,o(u),i?o(0):0}),t(u[0])))),0;var e=u[0];return o(n(0,[function(n){return c?0:n?(c=!0,i=!1,a(),e(1)):e(0)}]))}))}}},exports.delay=function(n){return function(t){return function(r){let u=0;return m(t,(function(t){return"number"==typeof t||t.tag?(u=u+1|0,setTimeout((function(n){return 0!==u?(u=u-1|0,r(t)):0}),n),0):r(t)}))}}},exports.empty=l,exports.filter=function(n){return function(t){return function(r){let u=e;return m(t,(function(t){return"number"==typeof t?r(t):t.tag?n(t[0])?r(t):u(0):(u=t[0],r(t))}))}}},exports.flatten=j,exports.forEach=function(n){return function(t){return B(n)(t),0}},exports.fromArray=s,exports.fromCallbag=function(t){return function(r){return v(t,0,(function(t,u){switch(t){case 0:return r(n(0,[function(n){return u(n?2:1)}]));case 1:return r(n(1,[u]));case 2:return r(0)}}))}},exports.fromDomEvent=function(n,t){return v(Q,n,t)},exports.fromList=function(n){return function(t){let u=n;return o(t,(function(){var n=u;if(n)return u=n[1],r(n[0])}))}},exports.fromObservable=function(t){var r=void 0!==t[H]?t[H]():t;return function(t){var u=r.subscribe({next:function(r){return t(n(1,[r]))},complete:function(){return t(0)},error:J});return t(n(0,[function(n){return n?u.unsubscribe():0}]))}},exports.fromPromise=function(t){return function(r){let u=!1;return t.then((function(t){return u||(r(n(1,[t])),r(0)),Promise.resolve(0)})),r(n(0,[function(n){return n&&(u=!0),0}]))}},exports.fromValue=function(t){return function(r){let u=!1;return r(n(0,[function(e){return e?(u=!0,0):u?0:(u=!0,r(n(1,[t])),r(0))}]))}},exports.interval=function(t){return function(r){let u=0;var e=setInterval((function(t){return t=u,u=u+1|0,r(n(1,[t]))}),t);return r(n(0,[function(n){return n&&clearInterval(e),0}]))}},exports.make=function(t){return function(r){let u=i,e=!1;return u=t({next:function(t){return e?0:r(n(1,[t]))},complete:function(n){return e?0:(e=!0,r(0))}}),r(n(0,[function(n){return n&&!e?(e=!0,u()):0}]))}},exports.makeSubject=function(t){let r=[],u=!1;return{source:function(t){function u(n){return n!==t}return r=r.concat(t),t(n(0,[function(n){return n&&(r=r.filter(u)),0}]))},next:function(t){return u||r.forEach((function(r){return r(n(1,[t]))})),0},complete:function(n){return u||(u=!0,r.forEach(c)),0}}},exports.map=function(t){return function(r){return function(u){return m(r,(function(r){return r="number"==typeof r?0:r.tag?n(1,[t(r[0])]):n(0,[r[0]]),u(r)}))}}},exports.merge=function(n){return k(w)(f(n))},exports.mergeAll=W,exports.mergeMap=U,exports.never=function(t){return t(n(0,[e]))},exports.onEnd=function(t){return function(r){return function(u){let e=!1;return m(r,(function(r){if("number"==typeof r)return e?0:(e=!0,u(r),t());if(r.tag)return e?0:u(r);var o=r[0];return u(n(0,[function(n){return e?0:n?(e=!0,o(n),t()):o(n)}]))}))}}},exports.onPush=D,exports.onStart=function(n){return function(t){return function(r){return m(t,(function(t){return"number"==typeof t||t.tag?r(t):(r(t),n())}))}}},exports.pipe=function(){for(var n=arguments,t=arguments[0],r=1,u=arguments.length;r<u;r++)t=n[r](t);return t},exports.publish=function(n){return B(F)(n)},exports.sample=function(t){return function(o){return function(f){let i=e,c=e,a=void 0,s=!1,l=!1;return m(o,(function(n){return"number"==typeof n?l?0:(l=!0,c(1),f(0)):n.tag?(a=r(n[0]),s?(s=!1,0):(s=!0,c(0),i(0))):(i=n[0],0)})),m(t,(function(t){var r=a;return"number"==typeof t?l?0:(l=!0,i(1),f(0)):t.tag?void 0===r||l?0:(a=void 0,f(n(1,[u(r)]))):(c=t[0],0)})),f(n(0,[function(n){return l?0:n?(l=!0,i(1),c(1)):s?0:(s=!0,i(0),c(0))}]))}}},exports.scan=function(n,t){return v(T,n,t)},exports.share=function(t){function r(n){return"number"==typeof n?(u.forEach(L),u=[]):n.tag?(f=!1,u.forEach((function(t){return t(n)}))):o=n[0],0}let u=[],o=e,f=!1;return function(e){function i(n){return n!==e}return u=u.concat(e),1===u.length&&m(t,r),e(n(0,[function(n){return n?(u=u.filter(i),0===u.length?o(1):0):f?0:(f=!0,o(n))}]))}},exports.skip=function(n){return function(t){return function(r){let u=e,o=n;return m(t,(function(n){return"number"==typeof n?r(n):n.tag?0<o?(o=o-1|0,u(0)):r(n):(u=n[0],r(n))}))}}},exports.skipUntil=function(t){return function(r){return function(u){function o(n){return"number"==typeof n?c?(s=!0,f(1)):0:n.tag?(c=!1,i(1)):(i=n=n[0],n(0))}let f=e,i=e,c=!0,a=!1,s=!1;return m(r,(function(n){return"number"==typeof n?(c&&i(1),s=!0,u(0)):n.tag?c||s?a?(a=!1,0):(a=!0,f(0),i(0)):(a=!1,u(n)):(f=n[0],m(t,o))})),u(n(0,[function(n){return s?0:n?(s=!0,f(1),c?i(1):0):a?0:(a=!0,c&&i(0),f(0))}]))}}},exports.skipWhile=function(n){return function(t){return function(r){let u=e,o=!0;return m(t,(function(t){if("number"==typeof t)return r(t);if(t.tag){if(o){if(n(t[0]))return u(0);o=!1}return r(t)}return u=t[0],r(t)}))}}},exports.subscribe=G,exports.switchAll=function(n){return M(C)(n)},exports.switchMap=q,exports.take=function(t){return function(r){return function(u){let o=!1,f=0,i=e;return m(r,(function(n){return"number"==typeof n?o?0:(o=!0,u(0)):n.tag?f<t&&!o&&(f=f+1|0,u(n),!o&&f>=t)?(o=!0,u(0),i(1)):0:(n=n[0],0>=t?(o=!0,u(0),n(1)):(i=n,0))})),u(n(0,[function(n){return o?0:n?(o=!0,i(1)):f<t?i(0):0}]))}}},exports.takeLast=z,exports.takeUntil=function(t){return function(r){return function(u){function o(n){return"number"==typeof n?0:n.tag?(f=!0,i(1),u(0)):(c=n=n[0],n(0))}let f=!1,i=e,c=e;return m(r,(function(n){return"number"==typeof n?f?0:(f=!0,c(1),u(0)):n.tag?f?0:u(n):(i=n[0],m(t,o))})),u(n(0,[function(n){return f?0:n?(f=!0,i(1),c(1)):i(0)}]))}}},exports.takeWhile=function(n){return function(t){return function(r){let u=e,o=!1;return m(t,(function(t){return"number"==typeof t?o?0:(o=!0,r(0)):t.tag?o?0:n(t[0])?r(t):(o=!0,r(0),u(1)):(u=t[0],r(t))}))}}},exports.tap=V,exports.throttle=function(t){return function(e){return function(o){function f(n){return c=void 0,i=!1,0}let i=!1,c=void 0;var a=function(n){return void 0!==(n=c)&&clearTimeout(u(n)),0};return m(e,(function(u){if("number"==typeof u)return a(),o(0);if(u.tag)return i?0:(i=!0,a(),c=r(setTimeout(f,t(u[0]))),o(u));var e=u[0];return o(n(0,[function(n){return n?(a(),e(1)):e(n)}]))}))}}},exports.toArray=function(n){let t=[],r=e,u=!1;return m(n,(function(n){return"number"==typeof n?(u=!0,0):n.tag?(t.push(n[0]),r(0)):(r=n=n[0],n(0))})),u||r(1),t},exports.toCallbag=function(n){return function(t,r){return 0===t?m(n,(function(n){if("number"==typeof n)return v(r,2,0);if(n.tag)return v(r,1,n[0]);var t=n[0];return v(r,0,(function(n){switch(n){case 0:return 0;case 1:return t(0);case 2:return t(1)}}))})):0}},exports.toObservable=function(n){var t={subscribe:function(t){let r=e,u=!1;return m(n,(function(n){return"number"==typeof n?(u=!0,t.complete()):n.tag?u?0:(t.next(n[0]),r(0)):(r=n=n[0],n(0))})),{unsubscribe:function(){return u?0:(u=!0,r(1))}}}};return t[H]=function(n){return t},t},exports.toPromise=function(n){return new Promise((function(t,r){return m(I(1)(n),(function(n){return"number"==typeof n?0:n.tag?t(n[0]):n[0](0)}))}))};

package.json

 {
   "name": "wonka",
   "description": "A fast push & pull stream library for Reason/OCaml, Flow, and TypeScript",
-  "version": "4.0.6",
+  "version": "4.0.7",
   "author": "Phil Pluckthun <[e-mail]>",
@@ -6,0 +6,0 @@ "source": "./src/Wonka.ts",

src/Wonka_operators.bs.js

@@ -214,2 +214,3 @@
           var applyInnerSource = function (innerSource) {
+            state.innerActive = true;
             return Curry._1(innerSource, (function (signal) {
@@ -247,3 +248,2 @@ if (typeof signal === "number") {
                             var tb = signal[0];
-                            state.innerActive = true;
                             state.innerTalkback = tb;
@@ -888,5 +888,6 @@ state.innerPulled = false;
                       var innerSource = f(signal[0]);
+                      state.innerActive = true;
                       return Curry._1(innerSource, (function (signal) {
-                                    if (typeof signal === "number") {
-                                      if (state.innerActive) {
+                                    if (state.innerActive) {
+                                      if (typeof signal === "number") {
                                         state.innerActive = false;
@@ -901,7 +902,3 @@ if (state.ended) {
                                         }
-                                      } else {
-                                        return /* () */0;
-                                      }
-                                    } else if (signal.tag) {
-                                      if (state.innerActive) {
+                                      } else if (signal.tag) {
                                         sink(signal);
@@ -915,10 +912,9 @@ if (state.innerPulled) {
                                       } else {
-                                        return /* () */0;
+                                        var tb = signal[0];
+                                        state.innerTalkback = tb;
+                                        state.innerPulled = false;
+                                        return tb(/* Pull */0);
                                       }
                                     } else {
-                                      var tb = signal[0];
-                                      state.innerActive = true;
-                                      state.innerTalkback = tb;
-                                      state.innerPulled = false;
-                                      return tb(/* Pull */0);
+                                      return 0;
                                     }
@@ -925,0 +921,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

Lines of code

8059

increased by0.05%

Worsened metrics

Total package byte prevSize

418049

decreased by-0.02%

No dependency changes