node-mongodb-driver (la capa subyacente que cada cliente mongoDB usa en nodejs) excepto la API del cursor que otros mencionaron tiene una buena API de flujo (# 458). Desafortunadamente, no lo encontré documentado en ningún otro lugar.
Actualización:hay documentos.
Se puede usar así:
var stream = collection.find().stream()
stream.on('error', function (err) {
console.error(err)
})
stream.on('data', function (doc) {
console.log(doc)
})
En realidad, implementa la interfaz ReadableStream, por lo que tiene todas las ventajas (pausar/reanudar, etc.)
