wonka - npm Package Compare versions

Comparing version 2.0.2 to 3.0.0-1.beta

bsconfig.json

 {
   "name": "wonka",
+  "namespace": true,
   "version": "0.1.0",
@@ -35,2 +36,14 @@ "bsc-flags": ["-bs-super-errors", "-bs-no-version-header"],
     {
+      "dir": "include",
+      "subdirs": [
+        {
+          "dir": "rebel_native"
+        },
+        {
+          "dir": "rebel_js",
+          "backend": ["js"]
+        }
+      ]
+    },
+    {
       "dir": "__tests__",
@@ -40,9 +53,6 @@ "type": "dev"
   ],
-  "bs-dependencies" : [
-    "bs-rebel"
-  ],
+  "bs-dependencies" : [],
   "bs-dev-dependencies": [
     "@glennsl/bs-jest"
-  ],
-  "namespace": false
+  ]
 }

dist/wonka.es.js

@@ -32,3 +32,4 @@ function pipe(source) {
     var f = _f;
-    var arity = f.length;
+    var init_arity = f.length;
+    var arity = 0 === init_arity ? 1 : init_arity;
     var d = (arity - args.length) | 0;
@@ -177,3 +178,3 @@ if (0 === d) {
   return _1(source, function(signal) {
-    if ("number" != typeof signal) {
+    if ('number' != typeof signal) {
       if (!signal.tag) {
@@ -192,3 +193,3 @@ talkback[0] = signal[0];
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           return (function makeTrampoline(sink, f) {
@@ -271,3 +272,3 @@ var state = [!1, !1, !1];
     return _1(takeLast(1)(source), function(signal) {
-      if ("number" == typeof signal) {
+      if ('number' == typeof signal) {
         return 0;
@@ -287,3 +288,3 @@ } else if (signal.tag) {
     _1(source, function(signal) {
-      if ("number" == typeof signal) {
+      if ('number' == typeof signal) {
         state[1] = !0;
@@ -317,17 +318,2 @@ return 0;
 
-function onPush(f) {
-  return function(source) {
-    return function(sink) {
-      return _1(source, function(signal) {
-        if ("number" != typeof signal) {
-          if (signal.tag) {
-            f(signal[0]);
-          }
-        }
-        return sink(signal);
-      });
-    };
-  };
-}
-
 function fromArray(arr) {
@@ -371,2 +357,17 @@ return function(sink) {
 
+function onPush(f) {
+  return function(source) {
+    return function(sink) {
+      return _1(source, function(signal) {
+        if ('number' != typeof signal) {
+          if (signal.tag) {
+            f(signal[0]);
+          }
+        }
+        return sink(signal);
+      });
+    };
+  };
+}
+
 function mergeMap(f) {
@@ -377,3 +378,3 @@ return function(source) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[2]) {
@@ -396,3 +397,3 @@ return 0;
               _1(innerSource, function(signal) {
-                if ("number" == typeof signal) {
+                if ('number' == typeof signal) {
                   state[1] = state[1].filter(function(x) {
@@ -474,3 +475,3 @@ return x !== talkback[0];
         return _1(innerSource, function(signal) {
-          if ("number" == typeof signal) {
+          if ('number' == typeof signal) {
             state[3] = !1;
@@ -502,3 +503,3 @@ state[2] = talkbackPlaceholder;
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[5]) {
@@ -568,3 +569,3 @@ return 0;
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[4]) {
@@ -589,3 +590,3 @@ return 0;
             _1(f(signal[0]), function(signal) {
-              if ("number" == typeof signal) {
+              if ('number' == typeof signal) {
                 state[2] = !1;
@@ -646,5 +647,5 @@ state[1] = talkbackPlaceholder;
 
-var fromArray$1 = fromArray;
+var fromArray$2 = fromArray;
 
-var fromList$1 = function fromList(ls) {
+var fromList$2 = function fromList(ls) {
   return function(sink) {
@@ -685,3 +686,3 @@ var state = [ls, !1, !1, !1];
 
-var fromValue$1 = function fromValue(x) {
+var fromValue$2 = function fromValue(x) {
   return function(sink) {
@@ -705,3 +706,3 @@ var ended = [!1];
 
-var make$1 = function make(f) {
+var make$2 = function make(f) {
   return function(sink) {
@@ -736,3 +737,3 @@ var teardown = [
 
-var makeSubject$1 = function makeSubject(param) {
+var makeSubject$2 = function makeSubject(param) {
   var state = [new Array(), !1];
@@ -781,3 +782,3 @@ return [
 
-var empty$1 = function empty(sink) {
+var empty$2 = function empty(sink) {
   sink(__(0, [talkbackPlaceholder]));
@@ -787,7 +788,7 @@ return sink(0);
 
-var never$1 = function never(sink) {
+var never$2 = function never(sink) {
   return sink(__(0, [talkbackPlaceholder]));
 };
 
-var combine$1 = function combine(sourceA) {
+var combine$2 = function combine(sourceA) {
   return function(sourceB) {
@@ -798,3 +799,3 @@ return function(sink) {
         var match = state[3];
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[5] < 1) {
@@ -831,3 +832,3 @@ state[5] = (state[5] + 1) | 0;
         var match = state[2];
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[5] < 1) {
@@ -885,5 +886,5 @@ state[5] = (state[5] + 1) | 0;
 
-var concatMap$1 = concatMap;
+var concatMap$2 = concatMap;
 
-var concat$1 = function concat(sources) {
+var concat$2 = function concat(sources) {
   return concatMap(function(x) {
@@ -894,3 +895,3 @@ return x;
 
-var concatAll$1 = function concatAll(source) {
+var concatAll$2 = function concatAll(source) {
   return concatMap(function(x) {
@@ -901,7 +902,7 @@ return x;
 
-var filter$1 = function filter(f) {
+var filter$2 = function filter(f) {
   return function(source) {
     return function(sink) {
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !signal.tag || f(signal[0])) {
+        if ('number' == typeof signal || !signal.tag || f(signal[0])) {
           return sink(signal);
@@ -916,3 +917,3 @@ } else {
 
-var map$1 = function map(f) {
+var map$2 = function map(f) {
   return function(source) {
@@ -923,3 +924,3 @@ return function(sink) {
         tmp =
-          "number" == typeof signal ? 0 : signal.tag ? __(1, [f(signal[0])]) : __(0, [signal[0]]);
+          'number' == typeof signal ? 0 : signal.tag ? __(1, [f(signal[0])]) : __(0, [signal[0]]);
         return sink(tmp);
@@ -931,5 +932,5 @@ });
 
-var mergeMap$1 = mergeMap;
+var mergeMap$2 = mergeMap;
 
-var merge$1 = function merge(sources) {
+var merge$2 = function merge(sources) {
   return mergeMap(function(x) {
@@ -940,7 +941,7 @@ return x;
 
-var mergeAll$1 = mergeAll;
+var mergeAll$2 = mergeAll;
 
-var flatten$1 = mergeAll;
+var flatten$2 = mergeAll;
 
-var onEnd$1 = function onEnd(f) {
+var onEnd$2 = function onEnd(f) {
   return function(source) {
@@ -950,3 +951,3 @@ return function(sink) {
       return _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (ended[0]) {
@@ -985,11 +986,11 @@ return 0;
 
-var onPush$1 = onPush;
+var onPush$2 = onPush;
 
-var tap$1 = onPush;
+var tap$2 = onPush;
 
-var onStart$1 = function onStart(f) {
+var onStart$2 = function onStart(f) {
   return function(source) {
     return function(sink) {
       return _1(source, function(signal) {
-        if ("number" == typeof signal || signal.tag) {
+        if ('number' == typeof signal || signal.tag) {
           return sink(signal);
@@ -1005,3 +1006,3 @@ } else {
 
-var scan$1 = function scan(f, seed) {
+var scan$2 = function scan(f, seed) {
   return function(source) {
@@ -1012,3 +1013,3 @@ return function(sink) {
         var tmp;
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           tmp = 0;
@@ -1027,3 +1028,3 @@ } else if (signal.tag) {
 
-var share$1 = function share(source) {
+var share$2 = function share(source) {
   var state = [new Array(), talkbackPlaceholder, !1];
@@ -1034,3 +1035,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           state[0].forEach(function(sink) {
@@ -1077,3 +1078,3 @@ return sink(0);
 
-var skip$1 = function skip(wait) {
+var skip$2 = function skip(wait) {
   return function(source) {
@@ -1083,3 +1084,3 @@ return function(sink) {
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !(signal.tag && rest[0] > 0)) {
+        if ('number' == typeof signal || !(signal.tag && rest[0] > 0)) {
           return sink(signal);
@@ -1095,3 +1096,3 @@ } else {
 
-var skipUntil$1 = function skipUntil(notifier) {
+var skipUntil$2 = function skipUntil(notifier) {
   return function(source) {
@@ -1101,3 +1102,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[0]) {
@@ -1121,3 +1122,3 @@ state[4](1);
           return _1(notifier, function(signal) {
-            if ("number" == typeof signal) {
+            if ('number' == typeof signal) {
               return 0;
@@ -1158,3 +1159,3 @@ } else if (signal.tag) {
 
-var skipWhile$1 = function skipWhile(f) {
+var skipWhile$2 = function skipWhile(f) {
   return function(source) {
@@ -1164,3 +1165,3 @@ return function(sink) {
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !signal.tag || !skip[0]) {
+        if ('number' == typeof signal || !signal.tag || !skip[0]) {
           return sink(signal);
@@ -1178,5 +1179,5 @@ } else if (f(signal[0])) {
 
-var switchMap$1 = switchMap;
+var switchMap$2 = switchMap;
 
-var switchAll$1 = function switchAll(source) {
+var switchAll$2 = function switchAll(source) {
   return switchMap(function(x) {
@@ -1187,3 +1188,3 @@ return x;
 
-var take$1 = function take(max) {
+var take$2 = function take(max) {
   return function(source) {
@@ -1193,3 +1194,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[0] < max) {
@@ -1239,5 +1240,5 @@ state[0] = max;
 
-var takeLast$1 = takeLast;
+var takeLast$2 = takeLast;
 
-var takeUntil$1 = function takeUntil(notifier) {
+var takeUntil$2 = function takeUntil(notifier) {
   return function(source) {
@@ -1247,3 +1248,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[0]) {
@@ -1265,3 +1266,3 @@ return 0;
           return _1(notifier, function(signal) {
-            if ("number" == typeof signal) {
+            if ('number' == typeof signal) {
               return 0;
@@ -1299,3 +1300,3 @@ } else if (signal.tag) {
 
-var takeWhile$1 = function takeWhile(f) {
+var takeWhile$2 = function takeWhile(f) {
   return function(source) {
@@ -1306,3 +1307,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (ended[0]) {
@@ -1347,6 +1348,6 @@ return 0;
 
-var publish$1 = function publish(source) {
+var publish$2 = function publish(source) {
   var state = [talkbackPlaceholder, !1];
   _1(source, function(signal) {
-    if ("number" == typeof signal) {
+    if ('number' == typeof signal) {
       state[1] = !0;
@@ -1378,5 +1379,5 @@ return 0;
 
-var subscribe$1 = subscribe;
+var subscribe$2 = subscribe;
 
-var forEach$1 = function forEach(f) {
+var forEach$2 = function forEach(f) {
   return function(source) {
@@ -1404,3 +1405,3 @@ subscribe(f)(source);
       return _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           gotEndSignal[0] = !0;
@@ -1452,3 +1453,3 @@ if (void 0 !== id[0]) {
         var exit = 0;
-        if ("number" == typeof signal || signal.tag) {
+        if ('number' == typeof signal || signal.tag) {
           exit = 1;
@@ -1535,3 +1536,3 @@ } else {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           state[0] = !0;
@@ -1550,3 +1551,3 @@ state[3](1);
         var match = state[1];
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           state[0] = !0;
@@ -1600,3 +1601,3 @@ state[2](1);
       return _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           $$clearTimeout$1();
@@ -1688,48 +1689,48 @@ return sink(0);
 export {
-  pipe,
   Types,
-  fromArray$1 as fromArray,
-  fromList$1 as fromList,
-  fromValue$1 as fromValue,
-  make$1 as make,
-  makeSubject$1 as makeSubject,
-  empty$1 as empty,
-  never$1 as never,
-  combine$1 as combine,
-  concatMap$1 as concatMap,
-  concat$1 as concat,
-  concatAll$1 as concatAll,
-  filter$1 as filter,
-  map$1 as map,
-  mergeMap$1 as mergeMap,
-  merge$1 as merge,
-  mergeAll$1 as mergeAll,
-  flatten$1 as flatten,
-  onEnd$1 as onEnd,
-  onPush$1 as onPush,
-  tap$1 as tap,
-  onStart$1 as onStart,
-  scan$1 as scan,
-  share$1 as share,
-  skip$1 as skip,
-  skipUntil$1 as skipUntil,
-  skipWhile$1 as skipWhile,
-  switchMap$1 as switchMap,
-  switchAll$1 as switchAll,
-  take$1 as take,
-  takeLast$1 as takeLast,
-  takeUntil$1 as takeUntil,
-  takeWhile$1 as takeWhile,
-  publish$1 as publish,
-  subscribe$1 as subscribe,
-  forEach$1 as forEach,
+  combine$2 as combine,
+  concat$2 as concat,
+  concatAll$2 as concatAll,
+  concatMap$2 as concatMap,
   debounce$2 as debounce,
   delay$2 as delay,
+  empty$2 as empty,
+  filter$2 as filter,
+  flatten$2 as flatten,
+  forEach$2 as forEach,
+  fromArray$2 as fromArray,
+  fromDomEvent$2 as fromDomEvent,
+  fromList$2 as fromList,
+  fromListener$2 as fromListener,
+  fromPromise$2 as fromPromise,
+  fromValue$2 as fromValue,
   interval$2 as interval,
+  make$2 as make,
+  makeSubject$2 as makeSubject,
+  map$2 as map,
+  merge$2 as merge,
+  mergeAll$2 as mergeAll,
+  mergeMap$2 as mergeMap,
+  never$2 as never,
+  onEnd$2 as onEnd,
+  onPush$2 as onPush,
+  onStart$2 as onStart,
+  pipe,
+  publish$2 as publish,
   sample$2 as sample,
+  scan$2 as scan,
+  share$2 as share,
+  skip$2 as skip,
+  skipUntil$2 as skipUntil,
+  skipWhile$2 as skipWhile,
+  subscribe$2 as subscribe,
+  switchAll$2 as switchAll,
+  switchMap$2 as switchMap,
+  take$2 as take,
+  takeLast$2 as takeLast,
+  takeUntil$2 as takeUntil,
+  takeWhile$2 as takeWhile,
+  tap$2 as tap,
   throttle$2 as throttle,
-  toPromise$2 as toPromise,
-  fromDomEvent$2 as fromDomEvent,
-  fromListener$2 as fromListener,
-  fromPromise$2 as fromPromise
+  toPromise$2 as toPromise
 };

dist/wonka.js

@@ -0,1 +1,3 @@
+'use strict';
+
 function __(tag, block) {
@@ -22,3 +24,4 @@ block.tag = tag;
     var f = _f;
-    var arity = f.length;
+    var init_arity = f.length;
+    var arity = 0 === init_arity ? 1 : init_arity;
     var d = (arity - args.length) | 0;
@@ -167,3 +170,3 @@ if (0 === d) {
   return _1(source, function(signal) {
-    if ("number" != typeof signal) {
+    if ('number' != typeof signal) {
       if (!signal.tag) {
@@ -182,3 +185,3 @@ talkback[0] = signal[0];
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           return (function makeTrampoline(sink, f) {
@@ -261,3 +264,3 @@ var state = [!1, !1, !1];
     return _1(takeLast(1)(source), function(signal) {
-      if ("number" == typeof signal) {
+      if ('number' == typeof signal) {
         return 0;
@@ -277,3 +280,3 @@ } else if (signal.tag) {
     _1(source, function(signal) {
-      if ("number" == typeof signal) {
+      if ('number' == typeof signal) {
         state[1] = !0;
@@ -307,17 +310,2 @@ return 0;
 
-function onPush(f) {
-  return function(source) {
-    return function(sink) {
-      return _1(source, function(signal) {
-        if ("number" != typeof signal) {
-          if (signal.tag) {
-            f(signal[0]);
-          }
-        }
-        return sink(signal);
-      });
-    };
-  };
-}
-
 function fromArray(arr) {
@@ -361,2 +349,17 @@ return function(sink) {
 
+function onPush(f) {
+  return function(source) {
+    return function(sink) {
+      return _1(source, function(signal) {
+        if ('number' != typeof signal) {
+          if (signal.tag) {
+            f(signal[0]);
+          }
+        }
+        return sink(signal);
+      });
+    };
+  };
+}
+
 function mergeMap(f) {
@@ -367,3 +370,3 @@ return function(source) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[2]) {
@@ -386,3 +389,3 @@ return 0;
               _1(innerSource, function(signal) {
-                if ("number" == typeof signal) {
+                if ('number' == typeof signal) {
                   state[1] = state[1].filter(function(x) {
@@ -464,3 +467,3 @@ return x !== talkback[0];
         return _1(innerSource, function(signal) {
-          if ("number" == typeof signal) {
+          if ('number' == typeof signal) {
             state[3] = !1;
@@ -492,3 +495,3 @@ state[2] = talkbackPlaceholder;
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[5]) {
@@ -558,3 +561,3 @@ return 0;
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[4]) {
@@ -579,3 +582,3 @@ return 0;
             _1(f(signal[0]), function(signal) {
-              if ("number" == typeof signal) {
+              if ('number' == typeof signal) {
                 state[2] = !1;
@@ -634,5 +637,5 @@ state[1] = talkbackPlaceholder;
 
-var fromArray$1 = fromArray;
+var fromArray$2 = fromArray;
 
-var fromList$1 = function fromList(ls) {
+var fromList$2 = function fromList(ls) {
   return function(sink) {
@@ -673,3 +676,3 @@ var state = [ls, !1, !1, !1];
 
-var fromValue$1 = function fromValue(x) {
+var fromValue$2 = function fromValue(x) {
   return function(sink) {
@@ -693,3 +696,3 @@ var ended = [!1];
 
-var make$1 = function make(f) {
+var make$2 = function make(f) {
   return function(sink) {
@@ -724,3 +727,3 @@ var teardown = [
 
-var makeSubject$1 = function makeSubject(param) {
+var makeSubject$2 = function makeSubject(param) {
   var state = [new Array(), !1];
@@ -769,3 +772,3 @@ return [
 
-var empty$1 = function empty(sink) {
+var empty$2 = function empty(sink) {
   sink(__(0, [talkbackPlaceholder]));
@@ -775,7 +778,7 @@ return sink(0);
 
-var never$1 = function never(sink) {
+var never$2 = function never(sink) {
   return sink(__(0, [talkbackPlaceholder]));
 };
 
-var combine$1 = function combine(sourceA) {
+var combine$2 = function combine(sourceA) {
   return function(sourceB) {
@@ -786,3 +789,3 @@ return function(sink) {
         var match = state[3];
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[5] < 1) {
@@ -819,3 +822,3 @@ state[5] = (state[5] + 1) | 0;
         var match = state[2];
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[5] < 1) {
@@ -873,5 +876,5 @@ state[5] = (state[5] + 1) | 0;
 
-var concatMap$1 = concatMap;
+var concatMap$2 = concatMap;
 
-var concat$1 = function concat(sources) {
+var concat$2 = function concat(sources) {
   return concatMap(function(x) {
@@ -882,3 +885,3 @@ return x;
 
-var concatAll$1 = function concatAll(source) {
+var concatAll$2 = function concatAll(source) {
   return concatMap(function(x) {
@@ -889,7 +892,7 @@ return x;
 
-var filter$1 = function filter(f) {
+var filter$2 = function filter(f) {
   return function(source) {
     return function(sink) {
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !signal.tag || f(signal[0])) {
+        if ('number' == typeof signal || !signal.tag || f(signal[0])) {
           return sink(signal);
@@ -904,3 +907,3 @@ } else {
 
-var map$1 = function map(f) {
+var map$2 = function map(f) {
   return function(source) {
@@ -911,3 +914,3 @@ return function(sink) {
         tmp =
-          "number" == typeof signal ? 0 : signal.tag ? __(1, [f(signal[0])]) : __(0, [signal[0]]);
+          'number' == typeof signal ? 0 : signal.tag ? __(1, [f(signal[0])]) : __(0, [signal[0]]);
         return sink(tmp);
@@ -919,5 +922,5 @@ });
 
-var mergeMap$1 = mergeMap;
+var mergeMap$2 = mergeMap;
 
-var merge$1 = function merge(sources) {
+var merge$2 = function merge(sources) {
   return mergeMap(function(x) {
@@ -928,7 +931,7 @@ return x;
 
-var mergeAll$1 = mergeAll;
+var mergeAll$2 = mergeAll;
 
-var flatten$1 = mergeAll;
+var flatten$2 = mergeAll;
 
-var onEnd$1 = function onEnd(f) {
+var onEnd$2 = function onEnd(f) {
   return function(source) {
@@ -938,3 +941,3 @@ return function(sink) {
       return _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (ended[0]) {
@@ -973,11 +976,11 @@ return 0;
 
-var onPush$1 = onPush;
+var onPush$2 = onPush;
 
-var tap$1 = onPush;
+var tap$2 = onPush;
 
-var onStart$1 = function onStart(f) {
+var onStart$2 = function onStart(f) {
   return function(source) {
     return function(sink) {
       return _1(source, function(signal) {
-        if ("number" == typeof signal || signal.tag) {
+        if ('number' == typeof signal || signal.tag) {
           return sink(signal);
@@ -993,3 +996,3 @@ } else {
 
-var scan$1 = function scan(f, seed) {
+var scan$2 = function scan(f, seed) {
   return function(source) {
@@ -1000,3 +1003,3 @@ return function(sink) {
         var tmp;
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           tmp = 0;
@@ -1015,3 +1018,3 @@ } else if (signal.tag) {
 
-var share$1 = function share(source) {
+var share$2 = function share(source) {
   var state = [new Array(), talkbackPlaceholder, !1];
@@ -1022,3 +1025,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           state[0].forEach(function(sink) {
@@ -1065,3 +1068,3 @@ return sink(0);
 
-var skip$1 = function skip(wait) {
+var skip$2 = function skip(wait) {
   return function(source) {
@@ -1071,3 +1074,3 @@ return function(sink) {
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !(signal.tag && rest[0] > 0)) {
+        if ('number' == typeof signal || !(signal.tag && rest[0] > 0)) {
           return sink(signal);
@@ -1083,3 +1086,3 @@ } else {
 
-var skipUntil$1 = function skipUntil(notifier) {
+var skipUntil$2 = function skipUntil(notifier) {
   return function(source) {
@@ -1089,3 +1092,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[0]) {
@@ -1109,3 +1112,3 @@ state[4](1);
           return _1(notifier, function(signal) {
-            if ("number" == typeof signal) {
+            if ('number' == typeof signal) {
               return 0;
@@ -1146,3 +1149,3 @@ } else if (signal.tag) {
 
-var skipWhile$1 = function skipWhile(f) {
+var skipWhile$2 = function skipWhile(f) {
   return function(source) {
@@ -1152,3 +1155,3 @@ return function(sink) {
       return captureTalkback(source, function(signal, talkback) {
-        if ("number" == typeof signal || !signal.tag || !skip[0]) {
+        if ('number' == typeof signal || !signal.tag || !skip[0]) {
           return sink(signal);
@@ -1166,5 +1169,5 @@ } else if (f(signal[0])) {
 
-var switchMap$1 = switchMap;
+var switchMap$2 = switchMap;
 
-var switchAll$1 = function switchAll(source) {
+var switchAll$2 = function switchAll(source) {
   return switchMap(function(x) {
@@ -1175,3 +1178,3 @@ return x;
 
-var take$1 = function take(max) {
+var take$2 = function take(max) {
   return function(source) {
@@ -1181,3 +1184,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[0] < max) {
@@ -1227,5 +1230,5 @@ state[0] = max;
 
-var takeLast$1 = takeLast;
+var takeLast$2 = takeLast;
 
-var takeUntil$1 = function takeUntil(notifier) {
+var takeUntil$2 = function takeUntil(notifier) {
   return function(source) {
@@ -1235,3 +1238,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (state[0]) {
@@ -1253,3 +1256,3 @@ return 0;
           return _1(notifier, function(signal) {
-            if ("number" == typeof signal) {
+            if ('number' == typeof signal) {
               return 0;
@@ -1287,3 +1290,3 @@ } else if (signal.tag) {
 
-var takeWhile$1 = function takeWhile(f) {
+var takeWhile$2 = function takeWhile(f) {
   return function(source) {
@@ -1294,3 +1297,3 @@ return function(sink) {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           if (ended[0]) {
@@ -1335,6 +1338,6 @@ return 0;
 
-var publish$1 = function publish(source) {
+var publish$2 = function publish(source) {
   var state = [talkbackPlaceholder, !1];
   _1(source, function(signal) {
-    if ("number" == typeof signal) {
+    if ('number' == typeof signal) {
       state[1] = !0;
@@ -1366,5 +1369,5 @@ return 0;
 
-var subscribe$1 = subscribe;
+var subscribe$2 = subscribe;
 
-var forEach$1 = function forEach(f) {
+var forEach$2 = function forEach(f) {
   return function(source) {
@@ -1392,3 +1395,3 @@ subscribe(f)(source);
       return _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           gotEndSignal[0] = !0;
@@ -1440,3 +1443,3 @@ if (void 0 !== id[0]) {
         var exit = 0;
-        if ("number" == typeof signal || signal.tag) {
+        if ('number' == typeof signal || signal.tag) {
           exit = 1;
@@ -1523,3 +1526,3 @@ } else {
       _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           state[0] = !0;
@@ -1538,3 +1541,3 @@ state[3](1);
         var match = state[1];
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           state[0] = !0;
@@ -1588,3 +1591,3 @@ state[2](1);
       return _1(source, function(signal) {
-        if ("number" == typeof signal) {
+        if ('number' == typeof signal) {
           $$clearTimeout$1();
@@ -1675,100 +1678,100 @@ return sink(0);
 
-exports.pipe = function pipe(source) {
-  var args = arguments;
-  var len = args.length;
-  var x = source;
-  for (var i = 1; i < len; i++) {
-    x = args[i](x);
-  }
-  return x;
-};
-
 exports.Types = 0;
 
-exports.fromArray = fromArray$1;
+exports.combine = combine$2;
 
-exports.fromList = fromList$1;
+exports.concat = concat$2;
 
-exports.fromValue = fromValue$1;
+exports.concatAll = concatAll$2;
 
-exports.make = make$1;
+exports.concatMap = concatMap$2;
 
-exports.makeSubject = makeSubject$1;
+exports.debounce = debounce$2;
 
-exports.empty = empty$1;
+exports.delay = delay$2;
 
-exports.never = never$1;
+exports.empty = empty$2;
 
-exports.combine = combine$1;
+exports.filter = filter$2;
 
-exports.concatMap = concatMap$1;
+exports.flatten = flatten$2;
 
-exports.concat = concat$1;
+exports.forEach = forEach$2;
 
-exports.concatAll = concatAll$1;
+exports.fromArray = fromArray$2;
 
-exports.filter = filter$1;
+exports.fromDomEvent = fromDomEvent$2;
 
-exports.map = map$1;
+exports.fromList = fromList$2;
 
-exports.mergeMap = mergeMap$1;
+exports.fromListener = fromListener$2;
 
-exports.merge = merge$1;
+exports.fromPromise = fromPromise$2;
 
-exports.mergeAll = mergeAll$1;
+exports.fromValue = fromValue$2;
 
-exports.flatten = flatten$1;
+exports.interval = interval$2;
 
-exports.onEnd = onEnd$1;
+exports.make = make$2;
 
-exports.onPush = onPush$1;
+exports.makeSubject = makeSubject$2;
 
-exports.tap = tap$1;
+exports.map = map$2;
 
-exports.onStart = onStart$1;
+exports.merge = merge$2;
 
-exports.scan = scan$1;
+exports.mergeAll = mergeAll$2;
 
-exports.share = share$1;
+exports.mergeMap = mergeMap$2;
 
-exports.skip = skip$1;
+exports.never = never$2;
 
-exports.skipUntil = skipUntil$1;
+exports.onEnd = onEnd$2;
 
-exports.skipWhile = skipWhile$1;
+exports.onPush = onPush$2;
 
-exports.switchMap = switchMap$1;
+exports.onStart = onStart$2;
 
-exports.switchAll = switchAll$1;
+exports.pipe = function pipe(source) {
+  var args = arguments;
+  var len = args.length;
+  var x = source;
+  for (var i = 1; i < len; i++) {
+    x = args[i](x);
+  }
+  return x;
+};
 
-exports.take = take$1;
+exports.publish = publish$2;
 
-exports.takeLast = takeLast$1;
+exports.sample = sample$2;
 
-exports.takeUntil = takeUntil$1;
+exports.scan = scan$2;
 
-exports.takeWhile = takeWhile$1;
+exports.share = share$2;
 
-exports.publish = publish$1;
+exports.skip = skip$2;
 
-exports.subscribe = subscribe$1;
+exports.skipUntil = skipUntil$2;
 
-exports.forEach = forEach$1;
+exports.skipWhile = skipWhile$2;
 
-exports.debounce = debounce$2;
+exports.subscribe = subscribe$2;
 
-exports.delay = delay$2;
+exports.switchAll = switchAll$2;
 
-exports.interval = interval$2;
+exports.switchMap = switchMap$2;
 
-exports.sample = sample$2;
+exports.take = take$2;
 
-exports.throttle = throttle$2;
+exports.takeLast = takeLast$2;
 
-exports.toPromise = toPromise$2;
+exports.takeUntil = takeUntil$2;
 
-exports.fromDomEvent = fromDomEvent$2;
+exports.takeWhile = takeWhile$2;
 
-exports.fromListener = fromListener$2;
+exports.tap = tap$2;
 
-exports.fromPromise = fromPromise$2;
+exports.throttle = throttle$2;
+
+exports.toPromise = toPromise$2;

lib/js/src/operators/wonka_operator_combine.js

@@ -6,3 +6,3 @@ 'use strict';
 var Caml_option = require("bs-platform/lib/js/caml_option.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -13,4 +13,4 @@ function combine(sourceA) {
           var state = /* record */[
-            /* talkbackA */Wonka_helpers.talkbackPlaceholder,
-            /* talkbackB */Wonka_helpers.talkbackPlaceholder,
+            /* talkbackA */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* talkbackB */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* lastValA */undefined,
@@ -17,0 +17,0 @@ /* lastValB */undefined,

lib/js/src/operators/wonka_operator_concatMap.js

@@ -6,5 +6,5 @@ 'use strict';
 var Caml_option = require("bs-platform/lib/js/caml_option.js");
-var Wonka_helpers = require("../wonka_helpers.js");
-var MutableQueue_js = require("bs-rebel/lib/js/src/js/MutableQueue_js.js");
-var Wonka_source_fromArray = require("../sources/wonka_source_fromArray.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
+var MutableQueue_js$Wonka = require("../../include/rebel_js/MutableQueue_js.js");
+var Wonka_source_fromArray$Wonka = require("../sources/wonka_source_fromArray.js");
 
@@ -16,4 +16,4 @@ function concatMap(f) {
             /* inputQueue */new Array(),
-            /* outerTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* innerTalkback */Wonka_helpers.talkbackPlaceholder,
+            /* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* innerActive */false,
@@ -27,3 +27,3 @@ /* closed */false,
                             state[/* innerActive */3] = false;
-                            state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
+                            state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
                             var match = state[/* inputQueue */0].shift();
@@ -58,3 +58,3 @@ if (match !== undefined) {
                       state[/* ended */5] = true;
-                      if (!state[/* innerActive */3] && MutableQueue_js.isEmpty(state[/* inputQueue */0])) {
+                      if (!state[/* innerActive */3] && MutableQueue_js$Wonka.isEmpty(state[/* inputQueue */0])) {
                         return sink(/* End */0);
@@ -92,3 +92,3 @@ } else {
                                 state[/* outerTalkback */1](/* Close */1);
-                                state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
+                                state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
                                 return /* () */0;
@@ -115,3 +115,3 @@ }
                   return x;
-                }))(Wonka_source_fromArray.fromArray(sources));
+                }))(Wonka_source_fromArray$Wonka.fromArray(sources));
 }
@@ -118,0 +118,0 @@

lib/js/src/operators/wonka_operator_filter.js

 'use strict';
 
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -8,3 +8,3 @@ function filter(f) {
       return (function (sink) {
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number" || !(signal.tag && !f(signal[0]))) {
@@ -11,0 +11,0 @@ return sink(signal);

lib/js/src/operators/wonka_operator_mergeMap.js

@@ -5,4 +5,4 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
-var Wonka_source_fromArray = require("../sources/wonka_source_fromArray.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
+var Wonka_source_fromArray$Wonka = require("../sources/wonka_source_fromArray.js");
 
@@ -13,3 +13,3 @@ function mergeMap(f) {
           var state = /* record */[
-            /* outerTalkback */Wonka_helpers.talkbackPlaceholder,
+            /* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* innerTalkbacks */new Array(),
@@ -19,3 +19,3 @@ /* ended */false
           var applyInnerSource = function (innerSource) {
-            var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
+            var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
             return Curry._1(innerSource, (function (signal) {
@@ -103,3 +103,3 @@ if (typeof signal === "number") {
                   return x;
-                }))(Wonka_source_fromArray.fromArray(sources));
+                }))(Wonka_source_fromArray$Wonka.fromArray(sources));
 }
@@ -106,0 +106,0 @@

lib/js/src/operators/wonka_operator_share.js

@@ -5,3 +5,3 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -11,3 +11,3 @@ function share(source) {
     /* sinks */new Array(),
-    /* talkback */Wonka_helpers.talkbackPlaceholder,
+    /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
     /* gotSignal */false
@@ -14,0 +14,0 @@ ];

lib/js/src/operators/wonka_operator_skip.js

 'use strict';
 
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -9,3 +9,3 @@ function skip(wait) {
           var rest = /* record */[/* contents */wait];
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number" || !(signal.tag && rest[0] > 0)) {
@@ -12,0 +12,0 @@ return sink(signal);

lib/js/src/operators/wonka_operator_skipUntil.js

@@ -5,3 +5,3 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -15,4 +15,4 @@ function skipUntil(notifier) {
             /* gotSignal */false,
-            /* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* notifierTalkback */Wonka_helpers.talkbackPlaceholder
+            /* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
           ];
@@ -19,0 +19,0 @@ Curry._1(source, (function (signal) {

lib/js/src/operators/wonka_operator_skipWhile.js

 'use strict';
 
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -9,3 +9,3 @@ function skipWhile(f) {
           var skip = /* record */[/* contents */true];
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number" || !(signal.tag && skip[0])) {
@@ -12,0 +12,0 @@ return sink(signal);

lib/js/src/operators/wonka_operator_switchMap.js

@@ -5,3 +5,3 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -12,4 +12,4 @@ function switchMap(f) {
           var state = /* record */[
-            /* outerTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* innerTalkback */Wonka_helpers.talkbackPlaceholder,
+            /* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* innerActive */false,
@@ -23,3 +23,3 @@ /* closed */false,
                             state[/* innerActive */2] = false;
-                            state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
+                            state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
                             if (state[/* ended */4]) {
@@ -63,3 +63,3 @@ return sink(/* End */0);
                         state[/* innerTalkback */1](/* Close */1);
-                        state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
+                        state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
                       }
@@ -84,3 +84,3 @@ applyInnerSource(f(signal[0]));
                                 state[/* outerTalkback */0](/* Close */1);
-                                state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
+                                state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
                                 return /* () */0;
@@ -87,0 +87,0 @@ }

lib/js/src/operators/wonka_operator_take.js

@@ -5,3 +5,3 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -13,3 +13,3 @@ function take(max) {
             /* taken */0,
-            /* talkback */Wonka_helpers.talkbackPlaceholder
+            /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder
           ];
@@ -16,0 +16,0 @@ Curry._1(source, (function (signal) {

lib/js/src/operators/wonka_operator_takeLast.js

 'use strict';
 
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -9,5 +9,5 @@ function takeLast(max) {
           var queue = new Array();
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number") {
-                          return Wonka_helpers.makeTrampoline(sink, (function () {
+                          return Wonka_helpers$Wonka.makeTrampoline(sink, (function () {
                                         return queue.shift();
@@ -14,0 +14,0 @@ }));

lib/js/src/operators/wonka_operator_takeUntil.js

@@ -5,3 +5,3 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -13,4 +13,4 @@ function takeUntil(notifier) {
             /* ended */false,
-            /* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* notifierTalkback */Wonka_helpers.talkbackPlaceholder
+            /* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
           ];
@@ -17,0 +17,0 @@ Curry._1(source, (function (signal) {

lib/js/src/operators/wonka_operator_takeWhile.js

@@ -5,3 +5,3 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -12,3 +12,3 @@ function takeWhile(f) {
           var ended = /* record */[/* contents */false];
-          var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
+          var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
           Curry._1(source, (function (signal) {
@@ -15,0 +15,0 @@ if (typeof signal === "number") {

lib/js/src/sinks/wonka_sink_publish.js

 'use strict';
 
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
 function publish(source) {
   var state = /* record */[
-    /* talkback */Wonka_helpers.talkbackPlaceholder,
+    /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
     /* ended */false
@@ -10,0 +10,0 @@ ];

lib/js/src/sinks/wonka_sink_subscribe.js

 'use strict';
 
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -9,3 +9,3 @@ function subscribe(f) {
       var state = /* record */[
-        /* talkback */Wonka_helpers.talkbackPlaceholder,
+        /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
         /* ended */false
@@ -12,0 +12,0 @@ ];

lib/js/src/sources/wonka_source_primitives.js

 'use strict';
 
 var Block = require("bs-platform/lib/js/block.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
 function empty(sink) {
-  sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
+  sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
   return sink(/* End */0);
@@ -12,3 +12,3 @@ }
 function never(sink) {
-  return sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
+  return sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
 }
@@ -15,0 +15,0 @@

lib/js/src/web/wonka_operator_delay.js

@@ -5,3 +5,3 @@ 'use strict';
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_helpers = require("../wonka_helpers.js");
+var Wonka_helpers$Wonka = require("../wonka_helpers.js");
 
@@ -12,3 +12,3 @@ function delay(wait) {
           var state = /* record */[
-            /* talkback */Wonka_helpers.talkbackPlaceholder,
+            /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* active */0,
@@ -15,0 +15,0 @@ /* gotEndSignal */false

lib/js/src/web/wonka_sink_toPromise.js

 'use strict';
 
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_operator_takeLast = require("../operators/wonka_operator_takeLast.js");
+var Wonka_operator_takeLast$Wonka = require("../operators/wonka_operator_takeLast.js");
 
 function toPromise(source) {
   return new Promise((function (resolve, param) {
-                return Curry._1(Wonka_operator_takeLast.takeLast(1)(source), (function (signal) {
+                return Curry._1(Wonka_operator_takeLast$Wonka.takeLast(1)(source), (function (signal) {
                               if (typeof signal === "number") {
@@ -10,0 +10,0 @@ return /* () */0;

lib/js/src/web/wonka_source_fromDomEvent.js

 'use strict';
 
 var Curry = require("bs-platform/lib/js/curry.js");
-var Wonka_source_fromListener = require("./wonka_source_fromListener.js");
+var Wonka_source_fromListener$Wonka = require("./wonka_source_fromListener.js");
 
@@ -18,3 +18,3 @@ function fromDomEvent(element, $$event) {
   );
-      return Wonka_source_fromListener.fromListener((function (handler) {
+      return Wonka_source_fromListener$Wonka.fromListener((function (handler) {
                       return Curry._3(addEventListener, element, $$event, handler);
@@ -21,0 +21,0 @@ }), (function (handler) {

lib/js/src/web/wonkaJs.js

 'use strict';
 
-var Wonka_operator_delay = require("./wonka_operator_delay.js");
-var Wonka_sink_toPromise = require("./wonka_sink_toPromise.js");
-var Wonka_operator_sample = require("./wonka_operator_sample.js");
-var Wonka_operator_debounce = require("./wonka_operator_debounce.js");
-var Wonka_operator_interval = require("./wonka_operator_interval.js");
-var Wonka_operator_throttle = require("./wonka_operator_throttle.js");
-var Wonka_source_fromPromise = require("./wonka_source_fromPromise.js");
-var Wonka_source_fromDomEvent = require("./wonka_source_fromDomEvent.js");
-var Wonka_source_fromListener = require("./wonka_source_fromListener.js");
+var Wonka_operator_delay$Wonka = require("./wonka_operator_delay.js");
+var Wonka_sink_toPromise$Wonka = require("./wonka_sink_toPromise.js");
+var Wonka_operator_sample$Wonka = require("./wonka_operator_sample.js");
+var Wonka_operator_debounce$Wonka = require("./wonka_operator_debounce.js");
+var Wonka_operator_interval$Wonka = require("./wonka_operator_interval.js");
+var Wonka_operator_throttle$Wonka = require("./wonka_operator_throttle.js");
+var Wonka_source_fromPromise$Wonka = require("./wonka_source_fromPromise.js");
+var Wonka_source_fromDomEvent$Wonka = require("./wonka_source_fromDomEvent.js");
+var Wonka_source_fromListener$Wonka = require("./wonka_source_fromListener.js");
 
-var debounce = Wonka_operator_debounce.debounce;
+var debounce = Wonka_operator_debounce$Wonka.debounce;
 
-var delay = Wonka_operator_delay.delay;
+var delay = Wonka_operator_delay$Wonka.delay;
 
-var interval = Wonka_operator_interval.interval;
+var interval = Wonka_operator_interval$Wonka.interval;
 
-var sample = Wonka_operator_sample.sample;
+var sample = Wonka_operator_sample$Wonka.sample;
 
-var throttle = Wonka_operator_throttle.throttle;
+var throttle = Wonka_operator_throttle$Wonka.throttle;
 
-var toPromise = Wonka_sink_toPromise.toPromise;
+var toPromise = Wonka_sink_toPromise$Wonka.toPromise;
 
-var fromDomEvent = Wonka_source_fromDomEvent.fromDomEvent;
+var fromDomEvent = Wonka_source_fromDomEvent$Wonka.fromDomEvent;
 
-var fromListener = Wonka_source_fromListener.fromListener;
+var fromListener = Wonka_source_fromListener$Wonka.fromListener;
 
-var fromPromise = Wonka_source_fromPromise.fromPromise;
+var fromPromise = Wonka_source_fromPromise$Wonka.fromPromise;
 
@@ -31,0 +31,0 @@ exports.debounce = debounce;

lib/js/src/wonka.js

 'use strict';
 
-var WonkaJs = require("./web/wonkaJs.js");
-var Wonka_source_make = require("./sources/wonka_source_make.js");
-var Wonka_operator_map = require("./operators/wonka_operator_map.js");
-var Wonka_sink_publish = require("./sinks/wonka_sink_publish.js");
-var Wonka_operator_scan = require("./operators/wonka_operator_scan.js");
-var Wonka_operator_skip = require("./operators/wonka_operator_skip.js");
-var Wonka_operator_take = require("./operators/wonka_operator_take.js");
-var Wonka_operator_onEnd = require("./operators/wonka_operator_onEnd.js");
-var Wonka_operator_share = require("./operators/wonka_operator_share.js");
-var Wonka_sink_subscribe = require("./sinks/wonka_sink_subscribe.js");
-var Wonka_operator_filter = require("./operators/wonka_operator_filter.js");
-var Wonka_operator_onPush = require("./operators/wonka_operator_onPush.js");
-var Wonka_source_fromList = require("./sources/wonka_source_fromList.js");
-var Wonka_operator_combine = require("./operators/wonka_operator_combine.js");
-var Wonka_operator_onStart = require("./operators/wonka_operator_onStart.js");
-var Wonka_source_fromArray = require("./sources/wonka_source_fromArray.js");
-var Wonka_source_fromValue = require("./sources/wonka_source_fromValue.js");
-var Wonka_operator_mergeMap = require("./operators/wonka_operator_mergeMap.js");
-var Wonka_operator_takeLast = require("./operators/wonka_operator_takeLast.js");
-var Wonka_source_primitives = require("./sources/wonka_source_primitives.js");
-var Wonka_operator_concatMap = require("./operators/wonka_operator_concatMap.js");
-var Wonka_operator_skipUntil = require("./operators/wonka_operator_skipUntil.js");
-var Wonka_operator_skipWhile = require("./operators/wonka_operator_skipWhile.js");
-var Wonka_operator_switchMap = require("./operators/wonka_operator_switchMap.js");
-var Wonka_operator_takeUntil = require("./operators/wonka_operator_takeUntil.js");
-var Wonka_operator_takeWhile = require("./operators/wonka_operator_takeWhile.js");
-var Wonka_source_makeSubject = require("./sources/wonka_source_makeSubject.js");
+var WonkaJs$Wonka = require("./web/wonkaJs.js");
+var Wonka_sinks$Wonka = require("./wonka_sinks.js");
+var Wonka_sources$Wonka = require("./wonka_sources.js");
+var Wonka_operators$Wonka = require("./wonka_operators.js");
 
 var Types = 0;
 
-var fromArray = Wonka_source_fromArray.fromArray;
+var fromArray = Wonka_sources$Wonka.fromArray;
 
-var fromList = Wonka_source_fromList.fromList;
+var fromList = Wonka_sources$Wonka.fromList;
 
-var fromValue = Wonka_source_fromValue.fromValue;
+var fromValue = Wonka_sources$Wonka.fromValue;
 
-var make = Wonka_source_make.make;
+var make = Wonka_sources$Wonka.make;
 
-var makeSubject = Wonka_source_makeSubject.makeSubject;
+var makeSubject = Wonka_sources$Wonka.makeSubject;
 
-var empty = Wonka_source_primitives.empty;
+var empty = Wonka_sources$Wonka.empty;
 
-var never = Wonka_source_primitives.never;
+var never = Wonka_sources$Wonka.never;
 
-var combine = Wonka_operator_combine.combine;
+var combine = Wonka_operators$Wonka.combine;
 
-var concatMap = Wonka_operator_concatMap.concatMap;
+var concatMap = Wonka_operators$Wonka.concatMap;
 
-var concat = Wonka_operator_concatMap.concat;
+var concat = Wonka_operators$Wonka.concat;
 
-var concatAll = Wonka_operator_concatMap.concatAll;
+var concatAll = Wonka_operators$Wonka.concatAll;
 
-var filter = Wonka_operator_filter.filter;
+var filter = Wonka_operators$Wonka.filter;
 
-var map = Wonka_operator_map.map;
+var map = Wonka_operators$Wonka.map;
 
-var mergeMap = Wonka_operator_mergeMap.mergeMap;
+var mergeMap = Wonka_operators$Wonka.mergeMap;
 
-var merge = Wonka_operator_mergeMap.merge;
+var merge = Wonka_operators$Wonka.merge;
 
-var mergeAll = Wonka_operator_mergeMap.mergeAll;
+var mergeAll = Wonka_operators$Wonka.mergeAll;
 
-var flatten = Wonka_operator_mergeMap.flatten;
+var flatten = Wonka_operators$Wonka.flatten;
 
-var onEnd = Wonka_operator_onEnd.onEnd;
+var onEnd = Wonka_operators$Wonka.onEnd;
 
-var onPush = Wonka_operator_onPush.onPush;
+var onPush = Wonka_operators$Wonka.onPush;
 
-var tap = Wonka_operator_onPush.tap;
+var tap = Wonka_operators$Wonka.tap;
 
-var onStart = Wonka_operator_onStart.onStart;
+var onStart = Wonka_operators$Wonka.onStart;
 
-var scan = Wonka_operator_scan.scan;
+var scan = Wonka_operators$Wonka.scan;
 
-var share = Wonka_operator_share.share;
+var share = Wonka_operators$Wonka.share;
 
-var skip = Wonka_operator_skip.skip;
+var skip = Wonka_operators$Wonka.skip;
 
-var skipUntil = Wonka_operator_skipUntil.skipUntil;
+var skipUntil = Wonka_operators$Wonka.skipUntil;
 
-var skipWhile = Wonka_operator_skipWhile.skipWhile;
+var skipWhile = Wonka_operators$Wonka.skipWhile;
 
-var switchMap = Wonka_operator_switchMap.switchMap;
+var switchMap = Wonka_operators$Wonka.switchMap;
 
-var switchAll = Wonka_operator_switchMap.switchAll;
+var switchAll = Wonka_operators$Wonka.switchAll;
 
-var take = Wonka_operator_take.take;
+var take = Wonka_operators$Wonka.take;
 
-var takeLast = Wonka_operator_takeLast.takeLast;
+var takeLast = Wonka_operators$Wonka.takeLast;
 
-var takeUntil = Wonka_operator_takeUntil.takeUntil;
+var takeUntil = Wonka_operators$Wonka.takeUntil;
 
-var takeWhile = Wonka_operator_takeWhile.takeWhile;
+var takeWhile = Wonka_operators$Wonka.takeWhile;
 
-var publish = Wonka_sink_publish.publish;
+var publish = Wonka_sinks$Wonka.publish;
 
-var subscribe = Wonka_sink_subscribe.subscribe;
+var subscribe = Wonka_sinks$Wonka.subscribe;
 
-var forEach = Wonka_sink_subscribe.forEach;
+var forEach = Wonka_sinks$Wonka.forEach;
 
-var debounce = WonkaJs.debounce;
+var debounce = WonkaJs$Wonka.debounce;
 
-var delay = WonkaJs.delay;
+var delay = WonkaJs$Wonka.delay;
 
-var interval = WonkaJs.interval;
+var interval = WonkaJs$Wonka.interval;
 
-var sample = WonkaJs.sample;
+var sample = WonkaJs$Wonka.sample;
 
-var throttle = WonkaJs.throttle;
+var throttle = WonkaJs$Wonka.throttle;
 
-var toPromise = WonkaJs.toPromise;
+var toPromise = WonkaJs$Wonka.toPromise;
 
-var fromDomEvent = WonkaJs.fromDomEvent;
+var fromDomEvent = WonkaJs$Wonka.fromDomEvent;
 
-var fromListener = WonkaJs.fromListener;
+var fromListener = WonkaJs$Wonka.fromListener;
 
-var fromPromise = WonkaJs.fromPromise;
+var fromPromise = WonkaJs$Wonka.fromPromise;
 
@@ -121,0 +98,0 @@ exports.Types = Types;

package.json

 {
   "name": "wonka",
-  "version": "2.0.2",
+  "version": "3.0.0-1.beta",
   "author": "Phil Pluckthun <[e-mail]>",
@@ -12,2 +12,3 @@ "source": "./src/index.js",
     "src",
+    "include",
     "lib/js",
@@ -17,2 +18,3 @@ "dist",
     "*.md",
+    "index.js.flow",
     "bsconfig.json"
@@ -27,13 +29,6 @@ ],
     "test:watch": "jest --watch",
-    "terser:es": "terser --config-file .terser.config.json --module -o ./dist/wonka.es.js ./dist/wonka.es.js",
-    "terser:cjs": "terser --config-file .terser.config.json -o ./dist/wonka.js ./dist/wonka.js",
-    "terser": "run-p terser:es terser:cjs",
-    "prettier": "prettier --write ./dist/*.js",
     "refmt": "bsrefmt --in-place **/**/*.{re,rei}",
-    "prebundle": "rimraf ./dist",
-    "bundle": "microbundle --external none --no-compress --no-sourcemap --format es,cjs",
-    "postbundle": "run-s terser prettier",
-    "prebundlesize": "run-s bundle",
-    "bundlesize": "bundlesize",
-    "prepublishOnly": "run-s clean build bundle test"
+    "flowgen": "./scripts/generate-flow-files.js",
+    "bundle": "rollup -c rollup.config.js",
+    "prepublishOnly": "run-s clean build bundle flowgen test"
   },
@@ -54,20 +49,25 @@ "keywords": [
   "license": "MIT",
-  "dependencies": {
-    "bs-rebel": "^0.2.3"
-  },
+  "dependencies": {},
   "devDependencies": {
-    "@glennsl/bs-jest": "^0.4.6",
-    "bs-platform": "^4.0.17",
-    "bundlesize": "^0.17.0",
-    "coveralls": "^3.0.0",
+    "@glennsl/bs-jest": "^0.4.8",
+    "bs-platform": "^5.0.4",
+    "flowgen": "^1.8.0",
+    "globby": "^9.2.0",
     "husky": "^1.3.1",
-    "lint-staged": "^8.1.5",
-    "microbundle": "^0.9.0",
+    "lint-staged": "^8.1.6",
     "npm-run-all": "^4.1.5",
-    "prettier": "^1.15.3",
-    "rimraf": "^2.6.3",
-    "terser": "^3.14.1"
+    "prettier": "^1.17.0",
+    "rollup": "^1.11.3",
+    "rollup-plugin-buble": "^0.19.6",
+    "rollup-plugin-commonjs": "^9.3.4",
+    "rollup-plugin-node-resolve": "^4.2.3",
+    "rollup-plugin-prettier": "^0.6.0",
+    "rollup-plugin-terser": "^4.0.4"
   },
   "lint-staged": {
-    "*.{re, rei}": [
+    "*.{d.ts,js}": [
+      "prettier --write",
+      "git add"
+    ],
+    "*.{re,rei}": [
       "bsrefmt --in-place",
@@ -83,2 +83,3 @@ "git add"
   "prettier": {
+    "singleQuote": true,
     "printWidth": 100
@@ -93,9 +94,3 @@ },
     ]
-  },
-  "bundlesize": [
-    {
-      "path": "./dist/wonka.es.js",
-      "maxSize": "9 kB"
-    }
-  ]
+  }
 }

src/operators/wonka_operator_combine.js

@@ -6,3 +6,3 @@
 import * as Caml_option from "bs-platform/lib/es6/caml_option.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -13,4 +13,4 @@ function combine(sourceA) {
           var state = /* record */[
-            /* talkbackA */Wonka_helpers.talkbackPlaceholder,
-            /* talkbackB */Wonka_helpers.talkbackPlaceholder,
+            /* talkbackA */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* talkbackB */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* lastValA */undefined,
@@ -17,0 +17,0 @@ /* lastValB */undefined,

src/operators/wonka_operator_concatMap.js

@@ -6,5 +6,5 @@
 import * as Caml_option from "bs-platform/lib/es6/caml_option.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
-import * as MutableQueue_js from "bs-rebel/src/js/MutableQueue_js.js";
-import * as Wonka_source_fromArray from "../sources/wonka_source_fromArray.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
+import * as MutableQueue_js$Wonka from "../../include/rebel_js/MutableQueue_js.js";
+import * as Wonka_source_fromArray$Wonka from "../sources/wonka_source_fromArray.js";
 
@@ -16,4 +16,4 @@ function concatMap(f) {
             /* inputQueue */new Array(),
-            /* outerTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* innerTalkback */Wonka_helpers.talkbackPlaceholder,
+            /* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* innerActive */false,
@@ -27,3 +27,3 @@ /* closed */false,
                             state[/* innerActive */3] = false;
-                            state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
+                            state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
                             var match = state[/* inputQueue */0].shift();
@@ -58,3 +58,3 @@ if (match !== undefined) {
                       state[/* ended */5] = true;
-                      if (!state[/* innerActive */3] && MutableQueue_js.isEmpty(state[/* inputQueue */0])) {
+                      if (!state[/* innerActive */3] && MutableQueue_js$Wonka.isEmpty(state[/* inputQueue */0])) {
                         return sink(/* End */0);
@@ -92,3 +92,3 @@ } else {
                                 state[/* outerTalkback */1](/* Close */1);
-                                state[/* innerTalkback */2] = Wonka_helpers.talkbackPlaceholder;
+                                state[/* innerTalkback */2] = Wonka_helpers$Wonka.talkbackPlaceholder;
                                 return /* () */0;
@@ -115,3 +115,3 @@ }
                   return x;
-                }))(Wonka_source_fromArray.fromArray(sources));
+                }))(Wonka_source_fromArray$Wonka.fromArray(sources));
 }
@@ -118,0 +118,0 @@

src/operators/wonka_operator_filter.js

 
 
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -8,3 +8,3 @@ function filter(f) {
       return (function (sink) {
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number" || !(signal.tag && !f(signal[0]))) {
@@ -11,0 +11,0 @@ return sink(signal);

src/operators/wonka_operator_mergeMap.js

@@ -5,4 +5,4 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
-import * as Wonka_source_fromArray from "../sources/wonka_source_fromArray.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
+import * as Wonka_source_fromArray$Wonka from "../sources/wonka_source_fromArray.js";
 
@@ -13,3 +13,3 @@ function mergeMap(f) {
           var state = /* record */[
-            /* outerTalkback */Wonka_helpers.talkbackPlaceholder,
+            /* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* innerTalkbacks */new Array(),
@@ -19,3 +19,3 @@ /* ended */false
           var applyInnerSource = function (innerSource) {
-            var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
+            var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
             return Curry._1(innerSource, (function (signal) {
@@ -103,3 +103,3 @@ if (typeof signal === "number") {
                   return x;
-                }))(Wonka_source_fromArray.fromArray(sources));
+                }))(Wonka_source_fromArray$Wonka.fromArray(sources));
 }
@@ -106,0 +106,0 @@

src/operators/wonka_operator_share.js

@@ -5,3 +5,3 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -11,3 +11,3 @@ function share(source) {
     /* sinks */new Array(),
-    /* talkback */Wonka_helpers.talkbackPlaceholder,
+    /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
     /* gotSignal */false
@@ -14,0 +14,0 @@ ];

src/operators/wonka_operator_skip.js

 
 
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -9,3 +9,3 @@ function skip(wait) {
           var rest = /* record */[/* contents */wait];
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number" || !(signal.tag && rest[0] > 0)) {
@@ -12,0 +12,0 @@ return sink(signal);

src/operators/wonka_operator_skipUntil.js

@@ -5,3 +5,3 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -15,4 +15,4 @@ function skipUntil(notifier) {
             /* gotSignal */false,
-            /* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* notifierTalkback */Wonka_helpers.talkbackPlaceholder
+            /* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
           ];
@@ -19,0 +19,0 @@ Curry._1(source, (function (signal) {

src/operators/wonka_operator_skipWhile.js

 
 
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -9,3 +9,3 @@ function skipWhile(f) {
           var skip = /* record */[/* contents */true];
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number" || !(signal.tag && skip[0])) {
@@ -12,0 +12,0 @@ return sink(signal);

src/operators/wonka_operator_switchMap.js

@@ -5,3 +5,3 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -12,4 +12,4 @@ function switchMap(f) {
           var state = /* record */[
-            /* outerTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* innerTalkback */Wonka_helpers.talkbackPlaceholder,
+            /* outerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* innerTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* innerActive */false,
@@ -23,3 +23,3 @@ /* closed */false,
                             state[/* innerActive */2] = false;
-                            state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
+                            state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
                             if (state[/* ended */4]) {
@@ -63,3 +63,3 @@ return sink(/* End */0);
                         state[/* innerTalkback */1](/* Close */1);
-                        state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
+                        state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
                       }
@@ -84,3 +84,3 @@ applyInnerSource(f(signal[0]));
                                 state[/* outerTalkback */0](/* Close */1);
-                                state[/* innerTalkback */1] = Wonka_helpers.talkbackPlaceholder;
+                                state[/* innerTalkback */1] = Wonka_helpers$Wonka.talkbackPlaceholder;
                                 return /* () */0;
@@ -87,0 +87,0 @@ }

src/operators/wonka_operator_take.js

@@ -5,3 +5,3 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -13,3 +13,3 @@ function take(max) {
             /* taken */0,
-            /* talkback */Wonka_helpers.talkbackPlaceholder
+            /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder
           ];
@@ -16,0 +16,0 @@ Curry._1(source, (function (signal) {

src/operators/wonka_operator_takeLast.js

 
 
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -9,5 +9,5 @@ function takeLast(max) {
           var queue = new Array();
-          return Wonka_helpers.captureTalkback(source, (function (signal, talkback) {
+          return Wonka_helpers$Wonka.captureTalkback(source, (function (signal, talkback) {
                         if (typeof signal === "number") {
-                          return Wonka_helpers.makeTrampoline(sink, (function () {
+                          return Wonka_helpers$Wonka.makeTrampoline(sink, (function () {
                                         return queue.shift();
@@ -14,0 +14,0 @@ }));

src/operators/wonka_operator_takeUntil.js

@@ -5,3 +5,3 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -13,4 +13,4 @@ function takeUntil(notifier) {
             /* ended */false,
-            /* sourceTalkback */Wonka_helpers.talkbackPlaceholder,
-            /* notifierTalkback */Wonka_helpers.talkbackPlaceholder
+            /* sourceTalkback */Wonka_helpers$Wonka.talkbackPlaceholder,
+            /* notifierTalkback */Wonka_helpers$Wonka.talkbackPlaceholder
           ];
@@ -17,0 +17,0 @@ Curry._1(source, (function (signal) {

src/operators/wonka_operator_takeWhile.js

@@ -5,3 +5,3 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -12,3 +12,3 @@ function takeWhile(f) {
           var ended = /* record */[/* contents */false];
-          var talkback = /* record */[/* contents */Wonka_helpers.talkbackPlaceholder];
+          var talkback = /* record */[/* contents */Wonka_helpers$Wonka.talkbackPlaceholder];
           Curry._1(source, (function (signal) {
@@ -15,0 +15,0 @@ if (typeof signal === "number") {

src/sinks/wonka_sink_publish.js

 
 
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
 function publish(source) {
   var state = /* record */[
-    /* talkback */Wonka_helpers.talkbackPlaceholder,
+    /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
     /* ended */false
@@ -10,0 +10,0 @@ ];

src/sinks/wonka_sink_subscribe.js

 
 
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -9,3 +9,3 @@ function subscribe(f) {
       var state = /* record */[
-        /* talkback */Wonka_helpers.talkbackPlaceholder,
+        /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
         /* ended */false
@@ -12,0 +12,0 @@ ];

src/sources/wonka_source_primitives.js

 
 
 import * as Block from "bs-platform/lib/es6/block.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
 function empty(sink) {
-  sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
+  sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
   return sink(/* End */0);
@@ -12,3 +12,3 @@ }
 function never(sink) {
-  return sink(/* Start */Block.__(0, [Wonka_helpers.talkbackPlaceholder]));
+  return sink(/* Start */Block.__(0, [Wonka_helpers$Wonka.talkbackPlaceholder]));
 }
@@ -15,0 +15,0 @@

src/web/wonka_operator_delay.js

@@ -5,3 +5,3 @@
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_helpers from "../wonka_helpers.js";
+import * as Wonka_helpers$Wonka from "../wonka_helpers.js";
 
@@ -12,3 +12,3 @@ function delay(wait) {
           var state = /* record */[
-            /* talkback */Wonka_helpers.talkbackPlaceholder,
+            /* talkback */Wonka_helpers$Wonka.talkbackPlaceholder,
             /* active */0,
@@ -15,0 +15,0 @@ /* gotEndSignal */false

src/web/wonka_sink_toPromise.js

 
 
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_operator_takeLast from "../operators/wonka_operator_takeLast.js";
+import * as Wonka_operator_takeLast$Wonka from "../operators/wonka_operator_takeLast.js";
 
 function toPromise(source) {
   return new Promise((function (resolve, param) {
-                return Curry._1(Wonka_operator_takeLast.takeLast(1)(source), (function (signal) {
+                return Curry._1(Wonka_operator_takeLast$Wonka.takeLast(1)(source), (function (signal) {
                               if (typeof signal === "number") {
@@ -10,0 +10,0 @@ return /* () */0;

src/web/wonka_source_fromDomEvent.js

 
 
 import * as Curry from "bs-platform/lib/es6/curry.js";
-import * as Wonka_source_fromListener from "./wonka_source_fromListener.js";
+import * as Wonka_source_fromListener$Wonka from "./wonka_source_fromListener.js";
 
@@ -18,3 +18,3 @@ function fromDomEvent(element, $$event) {
   );
-      return Wonka_source_fromListener.fromListener((function (handler) {
+      return Wonka_source_fromListener$Wonka.fromListener((function (handler) {
                       return Curry._3(addEventListener, element, $$event, handler);
@@ -21,0 +21,0 @@ }), (function (handler) {

src/web/wonkaJs.js

 
 
-import * as Wonka_operator_delay from "./wonka_operator_delay.js";
-import * as Wonka_sink_toPromise from "./wonka_sink_toPromise.js";
-import * as Wonka_operator_sample from "./wonka_operator_sample.js";
-import * as Wonka_operator_debounce from "./wonka_operator_debounce.js";
-import * as Wonka_operator_interval from "./wonka_operator_interval.js";
-import * as Wonka_operator_throttle from "./wonka_operator_throttle.js";
-import * as Wonka_source_fromPromise from "./wonka_source_fromPromise.js";
-import * as Wonka_source_fromDomEvent from "./wonka_source_fromDomEvent.js";
-import * as Wonka_source_fromListener from "./wonka_source_fromListener.js";
+import * as Wonka_operator_delay$Wonka from "./wonka_operator_delay.js";
+import * as Wonka_sink_toPromise$Wonka from "./wonka_sink_toPromise.js";
+import * as Wonka_operator_sample$Wonka from "./wonka_operator_sample.js";
+import * as Wonka_operator_debounce$Wonka from "./wonka_operator_debounce.js";
+import * as Wonka_operator_interval$Wonka from "./wonka_operator_interval.js";
+import * as Wonka_operator_throttle$Wonka from "./wonka_operator_throttle.js";
+import * as Wonka_source_fromPromise$Wonka from "./wonka_source_fromPromise.js";
+import * as Wonka_source_fromDomEvent$Wonka from "./wonka_source_fromDomEvent.js";
+import * as Wonka_source_fromListener$Wonka from "./wonka_source_fromListener.js";
 
-var debounce = Wonka_operator_debounce.debounce;
+var debounce = Wonka_operator_debounce$Wonka.debounce;
 
-var delay = Wonka_operator_delay.delay;
+var delay = Wonka_operator_delay$Wonka.delay;
 
-var interval = Wonka_operator_interval.interval;
+var interval = Wonka_operator_interval$Wonka.interval;
 
-var sample = Wonka_operator_sample.sample;
+var sample = Wonka_operator_sample$Wonka.sample;
 
-var throttle = Wonka_operator_throttle.throttle;
+var throttle = Wonka_operator_throttle$Wonka.throttle;
 
-var toPromise = Wonka_sink_toPromise.toPromise;
+var toPromise = Wonka_sink_toPromise$Wonka.toPromise;
 
-var fromDomEvent = Wonka_source_fromDomEvent.fromDomEvent;
+var fromDomEvent = Wonka_source_fromDomEvent$Wonka.fromDomEvent;
 
-var fromListener = Wonka_source_fromListener.fromListener;
+var fromListener = Wonka_source_fromListener$Wonka.fromListener;
 
-var fromPromise = Wonka_source_fromPromise.fromPromise;
+var fromPromise = Wonka_source_fromPromise$Wonka.fromPromise;
 
@@ -31,0 +31,0 @@ export {

src/wonka_types.d.ts

@@ -1,17 +0,8 @@
-// Reason Helper Types:
+export type List<T> = [T, any] | 0;
 
-interface ListNode<T> {
-  [0]: T,
-  [1]: 0 | List<T>
-}
-
-export type List<T> = ListNode<T> | 0;
-
-// Wonka Types:
-
 export type Talkback = 0 | 1;
 
 export type Signal<A> =
-  | { tag: 0, [0]: (talkback: Talkback) => void }
-  | { tag: 1, [0]: A }
+  | ({ tag: 0 } & [(talkback: Talkback) => void])
+  | ({ tag: 1 } & [A])
   | 0;
@@ -18,0 +9,0 @@

src/wonka.js

 
 
-import * as WonkaJs from "./web/wonkaJs.js";
-import * as Wonka_source_make from "./sources/wonka_source_make.js";
-import * as Wonka_operator_map from "./operators/wonka_operator_map.js";
-import * as Wonka_sink_publish from "./sinks/wonka_sink_publish.js";
-import * as Wonka_operator_scan from "./operators/wonka_operator_scan.js";
-import * as Wonka_operator_skip from "./operators/wonka_operator_skip.js";
-import * as Wonka_operator_take from "./operators/wonka_operator_take.js";
-import * as Wonka_operator_onEnd from "./operators/wonka_operator_onEnd.js";
-import * as Wonka_operator_share from "./operators/wonka_operator_share.js";
-import * as Wonka_sink_subscribe from "./sinks/wonka_sink_subscribe.js";
-import * as Wonka_operator_filter from "./operators/wonka_operator_filter.js";
-import * as Wonka_operator_onPush from "./operators/wonka_operator_onPush.js";
-import * as Wonka_source_fromList from "./sources/wonka_source_fromList.js";
-import * as Wonka_operator_combine from "./operators/wonka_operator_combine.js";
-import * as Wonka_operator_onStart from "./operators/wonka_operator_onStart.js";
-import * as Wonka_source_fromArray from "./sources/wonka_source_fromArray.js";
-import * as Wonka_source_fromValue from "./sources/wonka_source_fromValue.js";
-import * as Wonka_operator_mergeMap from "./operators/wonka_operator_mergeMap.js";
-import * as Wonka_operator_takeLast from "./operators/wonka_operator_takeLast.js";
-import * as Wonka_source_primitives from "./sources/wonka_source_primitives.js";
-import * as Wonka_operator_concatMap from "./operators/wonka_operator_concatMap.js";
-import * as Wonka_operator_skipUntil from "./operators/wonka_operator_skipUntil.js";
-import * as Wonka_operator_skipWhile from "./operators/wonka_operator_skipWhile.js";
-import * as Wonka_operator_switchMap from "./operators/wonka_operator_switchMap.js";
-import * as Wonka_operator_takeUntil from "./operators/wonka_operator_takeUntil.js";
-import * as Wonka_operator_takeWhile from "./operators/wonka_operator_takeWhile.js";
-import * as Wonka_source_makeSubject from "./sources/wonka_source_makeSubject.js";
+import * as WonkaJs$Wonka from "./web/wonkaJs.js";
+import * as Wonka_sinks$Wonka from "./wonka_sinks.js";
+import * as Wonka_sources$Wonka from "./wonka_sources.js";
+import * as Wonka_operators$Wonka from "./wonka_operators.js";
 
 var Types = 0;
 
-var fromArray = Wonka_source_fromArray.fromArray;
+var fromArray = Wonka_sources$Wonka.fromArray;
 
-var fromList = Wonka_source_fromList.fromList;
+var fromList = Wonka_sources$Wonka.fromList;
 
-var fromValue = Wonka_source_fromValue.fromValue;
+var fromValue = Wonka_sources$Wonka.fromValue;
 
-var make = Wonka_source_make.make;
+var make = Wonka_sources$Wonka.make;
 
-var makeSubject = Wonka_source_makeSubject.makeSubject;
+var makeSubject = Wonka_sources$Wonka.makeSubject;
 
-var empty = Wonka_source_primitives.empty;
+var empty = Wonka_sources$Wonka.empty;
 
-var never = Wonka_source_primitives.never;
+var never = Wonka_sources$Wonka.never;
 
-var combine = Wonka_operator_combine.combine;
+var combine = Wonka_operators$Wonka.combine;
 
-var concatMap = Wonka_operator_concatMap.concatMap;
+var concatMap = Wonka_operators$Wonka.concatMap;
 
-var concat = Wonka_operator_concatMap.concat;
+var concat = Wonka_operators$Wonka.concat;
 
-var concatAll = Wonka_operator_concatMap.concatAll;
+var concatAll = Wonka_operators$Wonka.concatAll;
 
-var filter = Wonka_operator_filter.filter;
+var filter = Wonka_operators$Wonka.filter;
 
-var map = Wonka_operator_map.map;
+var map = Wonka_operators$Wonka.map;
 
-var mergeMap = Wonka_operator_mergeMap.mergeMap;
+var mergeMap = Wonka_operators$Wonka.mergeMap;
 
-var merge = Wonka_operator_mergeMap.merge;
+var merge = Wonka_operators$Wonka.merge;
 
-var mergeAll = Wonka_operator_mergeMap.mergeAll;
+var mergeAll = Wonka_operators$Wonka.mergeAll;
 
-var flatten = Wonka_operator_mergeMap.flatten;
+var flatten = Wonka_operators$Wonka.flatten;
 
-var onEnd = Wonka_operator_onEnd.onEnd;
+var onEnd = Wonka_operators$Wonka.onEnd;
 
-var onPush = Wonka_operator_onPush.onPush;
+var onPush = Wonka_operators$Wonka.onPush;
 
-var tap = Wonka_operator_onPush.tap;
+var tap = Wonka_operators$Wonka.tap;
 
-var onStart = Wonka_operator_onStart.onStart;
+var onStart = Wonka_operators$Wonka.onStart;
 
-var scan = Wonka_operator_scan.scan;
+var scan = Wonka_operators$Wonka.scan;
 
-var share = Wonka_operator_share.share;
+var share = Wonka_operators$Wonka.share;
 
-var skip = Wonka_operator_skip.skip;
+var skip = Wonka_operators$Wonka.skip;
 
-var skipUntil = Wonka_operator_skipUntil.skipUntil;
+var skipUntil = Wonka_operators$Wonka.skipUntil;
 
-var skipWhile = Wonka_operator_skipWhile.skipWhile;
+var skipWhile = Wonka_operators$Wonka.skipWhile;
 
-var switchMap = Wonka_operator_switchMap.switchMap;
+var switchMap = Wonka_operators$Wonka.switchMap;
 
-var switchAll = Wonka_operator_switchMap.switchAll;
+var switchAll = Wonka_operators$Wonka.switchAll;
 
-var take = Wonka_operator_take.take;
+var take = Wonka_operators$Wonka.take;
 
-var takeLast = Wonka_operator_takeLast.takeLast;
+var takeLast = Wonka_operators$Wonka.takeLast;
 
-var takeUntil = Wonka_operator_takeUntil.takeUntil;
+var takeUntil = Wonka_operators$Wonka.takeUntil;
 
-var takeWhile = Wonka_operator_takeWhile.takeWhile;
+var takeWhile = Wonka_operators$Wonka.takeWhile;
 
-var publish = Wonka_sink_publish.publish;
+var publish = Wonka_sinks$Wonka.publish;
 
-var subscribe = Wonka_sink_subscribe.subscribe;
+var subscribe = Wonka_sinks$Wonka.subscribe;
 
-var forEach = Wonka_sink_subscribe.forEach;
+var forEach = Wonka_sinks$Wonka.forEach;
 
-var debounce = WonkaJs.debounce;
+var debounce = WonkaJs$Wonka.debounce;
 
-var delay = WonkaJs.delay;
+var delay = WonkaJs$Wonka.delay;
 
-var interval = WonkaJs.interval;
+var interval = WonkaJs$Wonka.interval;
 
-var sample = WonkaJs.sample;
+var sample = WonkaJs$Wonka.sample;
 
-var throttle = WonkaJs.throttle;
+var throttle = WonkaJs$Wonka.throttle;
 
-var toPromise = WonkaJs.toPromise;
+var toPromise = WonkaJs$Wonka.toPromise;
 
-var fromDomEvent = WonkaJs.fromDomEvent;
+var fromDomEvent = WonkaJs$Wonka.fromDomEvent;
 
-var fromListener = WonkaJs.fromListener;
+var fromListener = WonkaJs$Wonka.fromListener;
 
-var fromPromise = WonkaJs.fromPromise;
+var fromPromise = WonkaJs$Wonka.fromPromise;
 
@@ -121,0 +98,0 @@ export {

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

No v1

Quality

Package is not semver >=1. This means it is not stable and does not support ^ ranges.

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

488869

increased by17.22%

Dependency count

0

decreased by-100%

Number of package files

287

increased by42.08%

Lines of code

10819

increased by15.96%

Worsened metrics

Dev dependency count

14

increased by27.27%

Number of low quality alerts

1

increased byInfinity%

Dependency changes

• - Removedbs-rebel@^0.2.3

• - Removedbs-platform@9.0.2(transitive)

• - Removedbs-rebel@0.2.3(transitive)