mongo-each


Queued asynchronous iterating over mongodb cursor

API

$3

* cursor - a mongodb cursor
* iteratee - function(doc) - iteratee function, should return promise
* options - optional
* concurrency - how many iteratee functions should be run in parallel (default: 100)
* batch - batch mode (default: false)
* batchSize - batch size (default: 10)

Returns promise which is resolves when all iteratee functions have finished, or rejects if an error occurs

Example

``js
const {MongoClient} = require('mongodb');
const each = require('mongo-each');

async function main() {
const db = await MongoClient.connect('mongodb://127.0.0.1:27017/mongo-each');
const collection = db.collection('data');
const cursor = collection.find();

await each(collection.find(), async (doc) => {
console.log(doc)

await delay(100);
}, {concurrency: 50});
}

function delay(ms) {
return new Promise((resolve) => {
setTimeout(resolve, ms);
});
}

main();
``

License

MIT