Nové výsledky Mongoose QueryStream

Zjistil jsem, že aby tato metoda fungovala, musím svou sbírku změnit na 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');
});

Funguje to, protože nyní mohu zacházet s MongoDB collection něco jako fronta zpráv, která se neustále aktualizuje.

Kupodivu, když to zabalím do SocketIO případě dostanu násobky stejných documents což mě nutí si myslet, že stále existuje něco, co nedělám úplně správně...