Открих, че за да работи този метод, трябва да променя колекцията си на capped collection
:
var OrderSchema = new Mongoose.Schema({...
}, { capped: { size: 10, max: 10, autoIndexId: true }});
var Orders = db.model('orders', OrderSchema);
var stream = Orders.find().tailable().stream();
stream.on('data', function(doc){
console.log('New item!');
console.log(doc);
}).on('error', function (error){
console.log(error);
}).on('close', function () {
console.log('closed');
});
Това работи, защото вече мога да обработвам MongoDB collection
като нещо като опашка от съобщения, която непрекъснато се актуализира.
Колкото и да е странно, когато увивам това вътре в SocketIO
събитие Получавам множество едни и същи documents
което ме кара да мисля, че все още има нещо, което не правя точно както трябва...