cosa - npm Package Compare versions

Comparing version 3.0.12 to 3.0.13

lib/cursor.js

@@ -39,5 +39,17 @@ const { times } = require('omnibelt');
     if (!maxParallel || maxParallel < 1) { maxParallel = 1; }
+    let cursorExhausted = false;
+    const getNext = async () => {
+      if (cursorExhausted) { return; }
+      if (!await this._cursor.hasNext()) {
+        cursorExhausted = true;
+        return;
+      }
+      return this.next();
+    };
+    let nextResourceP = getNext();
     const itemWrapper = async () => {
-      if (this.isClosed()) { return; }
-      const item = await this.next();
+      if (cursorExhausted) { return; }
+      const currentResourceP = nextResourceP;
+      nextResourceP = nextResourceP.then(getNext);
+      const item = await currentResourceP;
       if (!item) { return; }
@@ -44,0 +56,0 @@ await iterator(item);

package.json

 {
   "name": "cosa",
-  "version": "3.0.12",
+  "version": "3.0.13",
   "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

57265

increased by0.66%

Lines of code

1375

increased by0.88%

Published versions last months

1

increased byInfinity%

No dependency changes