|
@ -385,7 +385,11 @@ function onCollection(err, collection) { |
|
|
itemsProcessed++; |
|
|
itemsProcessed++; |
|
|
}); |
|
|
}); |
|
|
|
|
|
|
|
|
|
|
|
var cursor1 = collection.find({},options); |
|
|
|
|
|
console.log(JSON.stringify(cursor1)) |
|
|
setInterval(function () { |
|
|
setInterval(function () { |
|
|
|
|
|
var cursor2 = collection.find({},options); |
|
|
|
|
|
console.log(JSON.stringify(cursor1)) |
|
|
console.log('itemsProcessed', itemsProcessed); |
|
|
console.log('itemsProcessed', itemsProcessed); |
|
|
}, 1000); |
|
|
}, 1000); |
|
|
} |
|
|
} |
|
|