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