Symbol.asyncIterator for the cursor in version 3.0 alpha 11

help
1

Hello @zodern and @denyhs, as indicated here, to scroll the result of a search we used the syntax below which allows other asynchronous methods to be invoked within the loop:

for await (const doc of collection.find({})) {
   await collection2.findOneAsync(...);
}

This works in version 2.13.3 while alpha version 11 returns the error:

     TypeError: cursor[methodName] is not a function
      at Cursor.<computed> (packages/mongo/mongo_driver.js:879:30)
      at _asyncIterator (/Users/pbeato/Documents/ksource/meteor12.3/meteor-collection2/tests/node_modules/@babel/runtime/helpers/asyncIterator.js:7:41)
      at Hook.<anonymous> (multi.tests.js:92:13)
      at run (packages/meteortesting:mocha-core/server.js:36:29)
      at Context.wrappedFunction (packages/meteortesting:mocha-core/server.js:65:14)
      at processImmediate (node:internal/timers:476:21)
      at process.topLevelDomainCallback (node:domain:161:15)
      at process.callbackTrampoline (node:internal/async_hooks:128:24)

Before opening an issue I wanted to discuss with you to see if I had missed something.

Thanks.

2

Have you tried something like:

for await (const doc of collection.find({}).fetchAsync()) {
   await collection2.findOneAsync(...);
}

Because when you do const doc of collection.find({}), doc is now a cursor, not a document from collection.

3

Hi @denyhs,

I am not sure this: https://github.com/meteor/meteor/pull/12028#issue-1228959844 has been superseded by another concept.
Also discussed here: Migration to 2.8 Async version - #2 by grubba where I see @pbeato has beed the initiator of the conversation.

Once data is fetched, there are many ways to iterate over it. The subject of interest is how to iterate over the cursor like in the “old Meteor”.

collection.find({}) is supposed to be a cursor while doc remains a doc as before. This is what I understand from the conversations above.

4

Just for the sake of completeness, I quote what is stated in the migration document to 2.8 that we have applied in all our applications:

There’s also [Symbol.asyncIterator], so this code should work:
for await (const document of collection.find(query, options)) /* … */

At the time the forEachAsync function did not allow the use of an asynchronous callback, is this now possible?