wonka - npm Package Compare versions

Comparing version 1.4.4 to 2.0.0

dist/wonka.es.js

@@ -312,2 +312,17 @@ function pipe(source) {
 
+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) {
@@ -903,2 +918,57 @@ return function(sink) {
 
+var onEnd$1 = function onEnd(f) {
+  return function(source) {
+    return function(sink) {
+      var ended = [!1];
+      return _1(source, function(signal) {
+        if ("number" == typeof signal) {
+          if (ended[0]) {
+            return 0;
+          } else {
+            ended[0] = !0;
+            sink(signal);
+            return f();
+          }
+        } else if (signal.tag) {
+          return sink(signal);
+        } else {
+          var talkback = signal[0];
+          return sink(
+            __(0, [
+              function(signal) {
+                talkback(signal);
+                if (ended[0]) {
+                  return 0;
+                } else {
+                  ended[0] = !0;
+                  return f();
+                }
+              }
+            ])
+          );
+        }
+      });
+    };
+  };
+};
+
+var onPush$1 = onPush;
+
+var tap$1 = onPush;
+
+var onStart$1 = function onStart(f) {
+  return function(source) {
+    return function(sink) {
+      return _1(source, function(signal) {
+        if ("number" == typeof signal || signal.tag) {
+          return sink(signal);
+        } else {
+          sink(signal);
+          return f();
+        }
+      });
+    };
+  };
+};
+
 var scan$1 = function scan(f, seed) {
@@ -1227,57 +1297,2 @@ return function(source) {
 
-var tap$1 = function tap(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);
-      });
-    };
-  };
-};
-
-var tapAll$1 = function tapAll(onStart, onPush, onEnd) {
-  return function(source) {
-    return function(sink) {
-      var ended = [!1];
-      return _1(source, function(signal) {
-        if ("number" == typeof signal) {
-          if (ended[0]) {
-            return 0;
-          } else {
-            ended[0] = !0;
-            return onEnd();
-          }
-        } else if (signal.tag) {
-          onPush(signal[0]);
-          return sink(signal);
-        } else {
-          var talkback = signal[0];
-          onStart();
-          return sink(
-            __(0, [
-              function(signal) {
-                if (signal) {
-                  if (ended[0]) {
-                    return 0;
-                  } else {
-                    ended[0] = !0;
-                    return onEnd();
-                  }
-                } else {
-                  return talkback(signal);
-                }
-              }
-            ])
-          );
-        }
-      });
-    };
-  };
-};
-
 var publish$1 = function publish(source) {
@@ -1636,2 +1651,6 @@ var state = [talkbackPlaceholder, !1];
   flatten$1 as flatten,
+  onEnd$1 as onEnd,
+  onPush$1 as onPush,
+  tap$1 as tap,
+  onStart$1 as onStart,
   scan$1 as scan,
@@ -1648,4 +1667,2 @@ share$1 as share,
   takeWhile$1 as takeWhile,
-  tap$1 as tap,
-  tapAll$1 as tapAll,
   publish$1 as publish,
@@ -1652,0 +1669,0 @@ subscribe$1 as subscribe,

dist/wonka.js

@@ -302,2 +302,17 @@ function __(tag, block) {
 
+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) {
@@ -891,2 +906,57 @@ return function(sink) {
 
+var onEnd$1 = function onEnd(f) {
+  return function(source) {
+    return function(sink) {
+      var ended = [!1];
+      return _1(source, function(signal) {
+        if ("number" == typeof signal) {
+          if (ended[0]) {
+            return 0;
+          } else {
+            ended[0] = !0;
+            sink(signal);
+            return f();
+          }
+        } else if (signal.tag) {
+          return sink(signal);
+        } else {
+          var talkback = signal[0];
+          return sink(
+            __(0, [
+              function(signal) {
+                talkback(signal);
+                if (ended[0]) {
+                  return 0;
+                } else {
+                  ended[0] = !0;
+                  return f();
+                }
+              }
+            ])
+          );
+        }
+      });
+    };
+  };
+};
+
+var onPush$1 = onPush;
+
+var tap$1 = onPush;
+
+var onStart$1 = function onStart(f) {
+  return function(source) {
+    return function(sink) {
+      return _1(source, function(signal) {
+        if ("number" == typeof signal || signal.tag) {
+          return sink(signal);
+        } else {
+          sink(signal);
+          return f();
+        }
+      });
+    };
+  };
+};
+
 var scan$1 = function scan(f, seed) {
@@ -1215,57 +1285,2 @@ return function(source) {
 
-var tap$1 = function tap(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);
-      });
-    };
-  };
-};
-
-var tapAll$1 = function tapAll(onStart, onPush, onEnd) {
-  return function(source) {
-    return function(sink) {
-      var ended = [!1];
-      return _1(source, function(signal) {
-        if ("number" == typeof signal) {
-          if (ended[0]) {
-            return 0;
-          } else {
-            ended[0] = !0;
-            return onEnd();
-          }
-        } else if (signal.tag) {
-          onPush(signal[0]);
-          return sink(signal);
-        } else {
-          var talkback = signal[0];
-          onStart();
-          return sink(
-            __(0, [
-              function(signal) {
-                if (signal) {
-                  if (ended[0]) {
-                    return 0;
-                  } else {
-                    ended[0] = !0;
-                    return onEnd();
-                  }
-                } else {
-                  return talkback(signal);
-                }
-              }
-            ])
-          );
-        }
-      });
-    };
-  };
-};
-
 var publish$1 = function publish(source) {
@@ -1650,2 +1665,10 @@ var state = [talkbackPlaceholder, !1];
 
+exports.onEnd = onEnd$1;
+
+exports.onPush = onPush$1;
+
+exports.tap = tap$1;
+
+exports.onStart = onStart$1;
+
 exports.scan = scan$1;
@@ -1673,6 +1696,2 @@
 
-exports.tap = tap$1;
-
-exports.tapAll = tapAll$1;
-
 exports.publish = publish$1;
@@ -1679,0 +1698,0 @@

lib/js/src/wonka.js

@@ -6,3 +6,2 @@ 'use strict';
 var Wonka_operator_map = require("./operators/wonka_operator_map.js");
-var Wonka_operator_tap = require("./operators/wonka_operator_tap.js");
 var Wonka_sink_publish = require("./sinks/wonka_sink_publish.js");
@@ -12,8 +11,10 @@ var Wonka_operator_scan = require("./operators/wonka_operator_scan.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_tapAll = require("./operators/wonka_operator_tapAll.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");
@@ -68,2 +69,10 @@ var Wonka_source_fromValue = require("./sources/wonka_source_fromValue.js");
 
+var onEnd = Wonka_operator_onEnd.onEnd;
+
+var onPush = Wonka_operator_onPush.onPush;
+
+var tap = Wonka_operator_onPush.tap;
+
+var onStart = Wonka_operator_onStart.onStart;
+
 var scan = Wonka_operator_scan.scan;
@@ -91,6 +100,2 @@
 
-var tap = Wonka_operator_tap.tap;
-
-var tapAll = Wonka_operator_tapAll.tapAll;
-
 var publish = Wonka_sink_publish.publish;
@@ -138,2 +143,6 @@
 exports.flatten = flatten;
+exports.onEnd = onEnd;
+exports.onPush = onPush;
+exports.tap = tap;
+exports.onStart = onStart;
 exports.scan = scan;
@@ -150,4 +159,2 @@ exports.share = share;
 exports.takeWhile = takeWhile;
-exports.tap = tap;
-exports.tapAll = tapAll;
 exports.publish = publish;
@@ -154,0 +161,0 @@ exports.subscribe = subscribe;

package.json

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

src/wonka.d.ts

@@ -15,2 +15,5 @@ /* sources */
 export * from './operators/wonka_operator_mergeMap';
+export * from './operators/wonka_operator_onEnd';
+export * from './operators/wonka_operator_onPush';
+export * from './operators/wonka_operator_onStart';
 export * from './operators/wonka_operator_scan';
@@ -26,4 +29,2 @@ export * from './operators/wonka_operator_share';
 export * from './operators/wonka_operator_takeWhile';
-export * from './operators/wonka_operator_tap';
-export * from './operators/wonka_operator_tapAll';
 
@@ -30,0 +31,0 @@ /* sinks */

src/wonka.js

@@ -6,3 +6,2 @@
 import * as Wonka_operator_map from "./operators/wonka_operator_map.js";
-import * as Wonka_operator_tap from "./operators/wonka_operator_tap.js";
 import * as Wonka_sink_publish from "./sinks/wonka_sink_publish.js";
@@ -12,8 +11,10 @@ import * as Wonka_operator_scan from "./operators/wonka_operator_scan.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_tapAll from "./operators/wonka_operator_tapAll.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";
@@ -68,2 +69,10 @@ import * as Wonka_source_fromValue from "./sources/wonka_source_fromValue.js";
 
+var onEnd = Wonka_operator_onEnd.onEnd;
+
+var onPush = Wonka_operator_onPush.onPush;
+
+var tap = Wonka_operator_onPush.tap;
+
+var onStart = Wonka_operator_onStart.onStart;
+
 var scan = Wonka_operator_scan.scan;
@@ -91,6 +100,2 @@
 
-var tap = Wonka_operator_tap.tap;
-
-var tapAll = Wonka_operator_tapAll.tapAll;
-
 var publish = Wonka_sink_publish.publish;
@@ -139,2 +144,6 @@
   flatten ,
+  onEnd ,
+  onPush ,
+  tap ,
+  onStart ,
   scan ,
@@ -151,4 +160,2 @@ share ,
   takeWhile ,
-  tap ,
-  tapAll ,
   publish ,
@@ -155,0 +162,0 @@ subscribe ,

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

389669

increased by0.5%

Number of package files

202

increased by2.54%

Lines of code

8929

increased by0.8%

No dependency changes