Estou tentando configurarMongooseJS para empurrar a coleção inteira (ou apenas o item mais novo) quando novos documentos são inseridos na coleção por outro aplicativo.

eu assumiQueryStream foi o caminho a percorrer.

No entanto, quando inicio meu aplicativo simples, ele lê a coleção uma vez e a fecha.

Quando insiro um novo documento, nada acontece (supondo que a conexão não esteja mais aberta e procurando novos resultados ...?)

var Orders = db.model('orders', OrderSchema);

var stream = Orders.find().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');
});

Imediatamente imprime todos os itens que estão atualmente nocoleta de pedidos, e que imprime "fechado". O "Stream" não deve permanecer aberto imprimindo novos dados quando omudanças de coleção?

O que não estou entendendo sobre oMongooseJS QueryStream?

Ps. meu objetivo é eventualmenteemit uma coleção atualizada viasocket.io como demonstrado aqui:Fluxo do Mongoose retorna poucos resultados pela primeira vez