Mongoose QueryStream nye resultater

Jeg opdagede, at for at denne metode kunne fungere, var jeg nødt til at ændre min samling til en 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');
});

Dette virker, fordi jeg nu kan behandle MongoDB collection som noget af en beskedkø, som løbende opdateres.

Mærkeligt nok, når jeg pakker dette ind i en SocketIO hændelse Jeg får multipla af de samme documents hvilket får mig til at tro, at der stadig er noget, jeg ikke gør helt rigtigt...