test(cursor): repro #8352

test/helpers/cursor.eachAsync.test.js

@@ -27,4 +27,36 @@ describe('eachAsync()', function() {
     return eachAsync(next, () => Promise.resolve(++processed), { parallel: 8 }).
       then(() => assert.equal(processed, max));
   });
+
+  it('waits until the end before resolving the promise (gh-8352)', function() {
+    const max = 2;
+    let numCalled = 0;
+    let numDone = 0;
+    function next(cb) {
+      setImmediate(() => {
+        if (++numCalled > max) {
+          return cb(null, null);
+        }
+        cb(null, { num: numCalled });
+      });
+    }
+
+    function fn() {
+      return new Promise(resolve => {
+        setTimeout(() => {
+          ++numDone;
+          resolve();
+        }, 100);
+      });
+    }
+
+    return eachAsync(next, fn, { parallel: 3 }).
+      then(() => assert.equal(numDone, max)).
+      then(() => {
+        numCalled = 0;
+        numDone = 0;
+      }).
+      then(() => eachAsync(next, fn, { parallel: 2 })).
+      then(() => assert.equal(numDone, max));
+  });
 });

test/mocha.opts

@@ -1,2 +1,3 @@
 --reporter dot
---ui bdd
+--ui bdd
+--recursive