cosa - npm Package Compare versions

Comparing version 3.0.10 to 3.0.11

lib/cursor.js

@@ -0,1 +1,2 @@
+const { times } = require('omnibelt');
 /**
@@ -31,2 +32,21 @@ * Wrapper around MongoDB Cursor to convert results to Models.
   /**
+   * Executes the iterator for the max number of items in parallel.
+   * @param {number} maxParallel - the max number of items to run in parallel
+   * @param {function} iterator - a function that will be called for each doc
+   * @returns {Promise} - resolves when list is exhausted.
+   */
+  async forEachParallelLimitP(maxParallel, iterator) {
+    if (!maxParallel || maxParallel < 1) { maxParallel = 1; }
+    const itemWrapper = async () => {
+      if (this.isClosed()) { return; }
+      const item = await this.next();
+      if (!item) { return; }
+      await iterator(item);
+      return itemWrapper();
+    };
+    const promises = times(itemWrapper, maxParallel);
+    return Promise.all(promises);
+  }
+
+  /**
    * Returns the count of documents on the cursor.
@@ -33,0 +53,0 @@ * @param {boolean} applySkipLimit - the number of docs to skip over in the count

package.json

 {
   "name": "cosa",
-  "version": "3.0.10",
+  "version": "3.0.11",
   "description": "Cosa Models for MongoDB",
@@ -5,0 +5,0 @@ "main": "lib/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

56938

increased by1.34%

Lines of code

1367

increased by1.41%

No dependency changes