Parece que o problema foi resolvido definindo um tamanho de lote no Cursor Stream: var stream = myCollection.find(query, fields, options).batchSize(10000).stream();