नेवला क्वेरीस्ट्रीम नए परिणाम

मैंने पाया कि इस पद्धति के काम करने के लिए मुझे अपने संग्रह को 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 के गुणज मिलते हैं जो मुझे लगता है कि अभी भी कुछ है जो मैं बिल्कुल सही नहीं कर रहा हूँ...