迭代数组并等待承诺

Question

如何使用 Promise 遍历数据数组并返回数据？我已经看到了一些 promises.push(asyncFunc) 方法，但是我的数组中的一些条目会失败，所以从我收集的信息来看，我不能使用它。

var filesFromDisk = [
    '41679_4_2015-09-06_17-02-12.mp4',
    '41679_4_2015-09-06_17-02-12.smil',
    '41680_4_2015-09-09_10-44-05.mp4'
];

start(filesFromDisk)
    .then((data) => {
        console.log(data); // Want my data here
});

我start(dbFiles)从另一个文件开始，这就是为什么我希望在那里返回数据。

function start(dbFiles) {
    var listOfFiles = [],
        promises = [];
    return new Promise((fulfill, reject) => {
        for (var i = 0; i < dbFiles.length; i++) { 
            getMp4(dbFiles[i])
                .then((data) => {
                    listOfFiles = listOfFiles.concat(data);
                    console.log(listOfFiles);
                })
        }
        fulfill(listOfFiles) // Need to happen AFTER for loop has filled listOfFiles
    });
}

因此，对于数组中的每个条目，我想检查具有新扩展名的文件是否存在并读取该文件。如果带扩展名的文件不存在，则执行原始文件。我的Promise.all链正常工作，所有数据都在上面的 for 循环中返回 ( getMp4(dbFiles[i]))

function getMp4(filename) {
    var mp4Files = [];
    var smil = privateMethods.setSmileExt(localData.devPath + filename.toString());
    return new Promise((fulfill, reject) => {
        Promise.all([
            privateMethods.fileExists(smil),
            privateMethods.readTest(smil)
        ]).then(() => {
            readFile(filename).then((files) => {
                fulfill(files)
            });
        }).catch((err) => {
            if (!err.exists) fulfill([filename]);
        });
    });
}

function readFile(filename){
    var filesFromSmil = [];
    return new Promise((fulfill, reject) => {
        fs.readFile(localData.devPath + filename, function (err, res){
            if (err) {
                reject(err);
            }
            else {
                xmlParser(res.toString(),  {trim: true}, (err, result) => {
                    var entry = JSON.parse(JSON.stringify(result.smil.body[0].switch[0].video));
                    for (var i = 0; i < entry.length; i++) { 
                        filesFromSmil.push(privateMethods.getFileName(entry[i].$.src))
                    }
                });
                fulfill(filesFromSmil);
            }
        });
    });
};

getMp4 中 Promise.all 链中的方法 - 我知道这些方法没有问题。

var privateMethods = {
    getFileName: (str) => {
        var rx = /[a-zA-Z-1\--9-_]*.mp4/g;
        var file = rx.exec(str);   
        return file[0];
    },
    setSmileExt: (videoFile) => {
        return videoFile.split('.').shift() + '.smil';
    },
    fileExists: (file) => {
        return new Promise((fulfill, reject) => {
            try {
                fs.accessSync(file);
                fulfill({exists: true})
            } catch (ex) {
                reject({exists: false})
            }
        })
    },
    readTest: (file) => {
        return new Promise((fulfill, reject) => {
            fs.readFile(file, (err, res) => {
                if (err) reject(err);
                else fulfill(res.toString());
            })
        })
    }
}

Answer 1

如果您需要它们并行运行，Promise.all这就是您想要的：

function start(dbFiles) {
    return Promise.all(dbFiles.map(getMp4));
}

这将启动getMp4对所有文件的操作并等待它们全部完成，然后使用结果数组进行解析。(getMp4将接收多个参数——值、它的索引和对dbFilesarary 的引用——但因为它只使用第一个，所以没问题。)

用法：

start(filesFromDisk).then(function(results) {
    // `results` is an array of the results, in order
});

为了完整起见，如果您需要它们按顺序运行，您可以使用以下reduce模式：

function start(dbFiles) {
    return dbFiles.reduce(function(p, file) {
        return p.then(function(results) {
            return getMp4(file).then(function(data) {
                results.push(data);
                return results;
            });
        });
    }, Promise.resolve([]));
}

用法一样。注意我们是如何从一个用 解析的promise 开始的[]，然后将一堆then处理程序排队，每个处理程序接收数组，进行getMp4调用，当它得到结果时，将结果推送到数组上并返回它；最终分辨率值是填充数组。