fairmont-reactive - npm Package Compare versions

Comparing version 1.0.0-beta-31 to 1.0.0-beta-32

lib/filters.js

@@ -359,18 +359,56 @@ // Generated by CoffeeScript 1.9.3
 
-  tee = curry(function(f, i) {
+  tee = Method.create();
+
+  Method.define(tee, Function, isDefined, function(f, x) {
+    return tee(f, producer(x));
+  });
+
+  Method.define(tee, Function, isReactor, function(f, r) {
     return reactor(function() {
-      return (next(i)).then(function(arg) {
-        var done, value;
+      return (next(r)).then(function(arg) {
+        var done, ref4, value;
         done = arg.done, value = arg.value;
         if (!done) {
-          f(value);
+          return ((ref4 = f(value)) != null ? typeof ref4.then === "function" ? ref4.then(function() {
+            return {
+              done: done,
+              value: value
+            };
+          }) : void 0 : void 0) || {
+            done: done,
+            value: value
+          };
+        } else {
+          return {
+            done: done
+          };
         }
-        return {
+      });
+    });
+  });
+
+  Method.define(tee, Function, isIterator, function(f, i) {
+    return iterator(function() {
+      var done, ref4, ref5, value;
+      ref4 = next(i), done = ref4.done, value = ref4.value;
+      if (!done) {
+        return ((ref5 = f(value)) != null ? typeof ref5.then === "function" ? ref5.then(function() {
+          return {
+            done: done,
+            value: value
+          };
+        }) : void 0 : void 0) || {
           done: done,
           value: value
         };
-      });
+      } else {
+        return {
+          done: done
+        };
+      }
     });
   });
 
+  tee = curry(binary(tee));
+
   throttle = curry(function(ms, i) {
@@ -377,0 +415,0 @@ var last;

package.json

 {
   "name": "fairmont-reactive",
-  "version": "1.0.0-beta-31",
+  "version": "1.0.0-beta-32",
   "description": "Functional reactive programming in JavaScript and CoffeeScript.",
@@ -5,0 +5,0 @@ "files": [

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

44367

increased by2.36%

Lines of code

1413

increased by2.47%

No dependency changes