Comment utiliser Promise.all() et une boucle async?

Question

J'essaie d'envelopper ma tête autour de Promises et comment les utiliser sur des boucles asynchrones.

Je réunis le code suivant pour lire le contenu de trois fichiers (en utilisant forEach) et lorsque toutes les promesses de résoudre journaliser les résultats de tous les fichiers:

var Promise = require('bluebird'); 
var fs = require('fs'); 
var path = require('path'); 

var files = ['1.json','2.json','3.json']; 
var promises = [] 

files.forEach(function(file){ 
    fs.readFile(path.join('./',file), 'utf8', function(err,data){ 
     promises.push(new Promise(function(resolve, reject){ 
      resolve(data) 
     }) 
       ); 
    }) 
}); 

Promise.all(promises).then(function(values){ 
    console.log(values) 
}); 

Je ne sais pas comment mettre la boucle à l'intérieur le .all()

J'ai essayé ce code mais cela enregistre un tableau vide.

Qu'est-ce que je fais mal?

Answer 1

Utilisez .map() pour parcourir votre tableau, en commençant un appel asynchrone pour chacun d'entre eux, puis en renvoyant la promesse pour chaque appel. La valeur de retour de cette carte sera un nouveau tableau de promesses que vous pouvez ensuite passer à Promise.all().

let Promise = require('bluebird') 
let fs = Promise.promisifyAll(require('fs')) 

let promises = files.map((file) => { 
    // readFile will return promises because of bluebird promisifyAll 
    return fs.readFile(...) 
}) 

Promise.all(promises).then((results) => { 
    // results will be an array of all the files that were read 
    console.log(results); 
}); 

Answer 2

Vous mélangez callbacks avec des promesses, créer un tableau de promesses à l'aide Array#map et le transmettre à Promise.all:

var files = ['1.json', '2.json', '3.json']; 
var promises = files.map(file => { 
    return new Promise((resolve, reject) => { 
    fs.readFile(path.join('./',file), 'utf8', (err, data) => { 
     if (err) { 
     return reject(err); 
     } 
     resolve(data); 
    }); 
    }); 
}); 

Promise.all(promises).then(function(values){ 
    console.log(values) 
});