|
@ -374,10 +374,10 @@ function onCollection(err, collection) { |
|
|
numberOfRetries: -1, |
|
|
numberOfRetries: -1, |
|
|
tailableRetryInterval: 500 |
|
|
tailableRetryInterval: 500 |
|
|
}; |
|
|
}; |
|
|
var cursor = collection.find().cursor(options).stream(); |
|
|
var cursor = collection.find({},options).stream(); |
|
|
//var cursor = collection.find({}, options),
|
|
|
//var cursor = collection.find({}, options),
|
|
|
// cursorStream = cursor.stream(),
|
|
|
// cursorStream = cursor.stream(),
|
|
|
// itemsProcessed = 0;
|
|
|
var itemsProcessed = 0; |
|
|
|
|
|
|
|
|
//cursorStream.on('data', function (data) {
|
|
|
//cursorStream.on('data', function (data) {
|
|
|
cursor.on('data', function (data) { |
|
|
cursor.on('data', function (data) { |
|
|