fxjs2 - npm Package Compare versions

Comparing version 0.0.19 to 0.0.20

fx.js

@@ -165,22 +165,63 @@ export const
 
-export const take = curry((l, iter) => {
-  if (l === 0) return [];
-  let res = [];
-  iter = L.values(iter);
-  return function recur() {
-    let cur;
-    while (!(cur = iter.next()).done) {
-      const a = cur.value;
-      if (a instanceof Promise) {
-        return a
-          .then(a => (res.push(a), res).length == l ? res : recur())
-          .catch(e => e == nop ? recur() : Promise.reject(e));
+export const
+  take = curry((l, iter) => {
+    if (l === 0) return [];
+    let res = [];
+    iter = L.values(iter);
+    return function recur() {
+      let cur;
+      while (!(cur = iter.next()).done) {
+        const a = cur.value;
+        if (a instanceof Promise) {
+          return a
+            .then(a => (res.push(a), res).length == l ? res : recur())
+            .catch(e => e == nop ? recur() : Promise.reject(e));
+        }
+        res.push(a);
+        if (res.length == l) return res;
       }
-      res.push(a);
-      if (res.length == l) return res;
-    }
-    return res;
-  } ();
-});
+      return res;
+    } ();
+  }),
 
+  takeWhile = curry((f, iter) => {
+    let res = [];
+    iter = L.values(iter);
+    return function recur() {
+      let cur;
+      while (!(cur = iter.next()).done) {
+        const a = cur.value;
+        const b = go1(a, f);
+        if (!b) return res;
+        if (b instanceof Promise) {
+          return b
+            .then(async b => b ? (res.push(await a), recur()) : res)
+            .catch(e => e == nop ? recur() : Promise.reject(e));
+        }
+        res.push(a);
+      }
+      return res;
+    } ();
+  }),
+
+  takeUntil = curry((f, iter) => {
+    let res = [];
+    iter = L.values(iter);
+    return function recur() {
+      let cur;
+      while (!(cur = iter.next()).done) {
+        const a = cur.value;
+        const b = go1(a, f);
+        if (b instanceof Promise) {
+          return b
+            .then(async b => (res.push(await a), b) ? res : recur())
+            .catch(e => e == nop ? recur() : Promise.reject(e));
+        }
+        res.push(a);
+        if (b) break;
+      }
+      return res;
+    } ();
+  });
+
 export const
@@ -187,0 +228,0 @@ takeAll = take(Infinity),

package.json

 {
   "name": "fxjs2",
-  "version": "0.0.19",
+  "version": "0.0.20",
   "description": "Functional Extensions for Javascript",
@@ -5,0 +5,0 @@ "main": "index.js",

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

15214

increased by7.52%

Lines of code

379

increased by11.47%

No dependency changes