|
@ -369,7 +369,13 @@ io.origins('*:*') // for latest version |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
function onCollection(err, collection) { |
|
|
function onCollection(err, collection) { |
|
|
var cursor = collection.find({}, { tailable: true, awaitdata: true }), |
|
|
let options = { tailable: true, |
|
|
|
|
|
awaitData: true, |
|
|
|
|
|
numberOfRetries: -1, |
|
|
|
|
|
tailableRetryInterval: 500 |
|
|
|
|
|
}; |
|
|
|
|
|
//collection.find().cursor(options);
|
|
|
|
|
|
var cursor = collection.find({}, options), |
|
|
cursorStream = cursor.stream(), |
|
|
cursorStream = cursor.stream(), |
|
|
itemsProcessed = 0; |
|
|
itemsProcessed = 0; |
|
|
|
|
|
|
|
|