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