diff --git a/swarmlab-app/src/run/app.js b/swarmlab-app/src/run/app.js index 5b69564..e2d1c8c 100755 --- a/swarmlab-app/src/run/app.js +++ b/swarmlab-app/src/run/app.js @@ -369,7 +369,13 @@ io.origins('*:*') // for latest version 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(), itemsProcessed = 0;