mongo-iterable-cursor

const { MongoClient } = require('mongodb');
const iterable = require('mongo-iterable-cursor');
 
MongoClient.connect('mongodb://localhost:27017/test')
    .then((db) => {
        const users = db.collection('users');
 
        for (const pendingUser of iterable(users.find())) {
            pendingUser.then((user) => {
                // handle user
            });
        }
    })
;

const forAwait = require('for-await');
const { MongoClient } = require('mongodb');
const iterable = require('mongo-iterable-cursor');
 
MongoClient.connect('mongodb://localhost:27017/test')
    .then((db) => {
        const users = db.collection('users');
        return forAwait((user) => {
          // handle user
        }).of(iterable(users.find()));
    })
;

{
  "presets": ["es2017"], // or use Node.js v8 which includes async/await
  "plugins": [
    "transform-async-generator-functions"
  ]
}

const iterable = require('mongo-iterable-cursor');
const { MongoClient } = require('mongodb');
 
(async () => {
  const db = await MongoClient.connect('mongodb://localhost:27017/test');
  const users = db.collection('users');
 
  for await (const user of iterable(users.find())) {
    //
  }
})();

require('mongo-iterable-cursor/register');
 
const { MongoClient } = require('mongodb');
 
(async () => {
  const db = await MongoClient.connect('mongodb://localhost:27017/test');
  const users = db.collection('users');
 
  for await (const user of users.find()) {
    //
  }
})();