Estoy tratando de configurarMangosta para expulsar toda la colección (o simplemente el elemento más nuevo) cuando otra aplicación inserta documentos nuevos en la colección.

supuseQueryStream Era el camino a seguir.

Sin embargo, cuando inicio mi aplicación simple, lee la colección una vez y la cierra.

Cuando inserto un nuevo documento, no pasa nada (¿asumiendo que la conexión ya no está abierta y en busca de nuevos 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');
});

Imprime inmediatamente todos los elementos que se encuentran actualmente en elrecogida de pedidos, y que imprime "cerrado". ¿No debería permanecer abierto el "Stream" imprimiendo nuevos datos cuando elcambios de colección?

¿Qué es lo que no entiendo sobre laMongooseJS QueryStream?

PD. mi objetivo es eventualmenteemit una colección actualizada a través desocket.io como se demuestra aquí:Transmisión de mangosta devuelve pocos resultados por primera vez