迭代数组并等待 Promise

如何使用 Promises 迭代数据数组并返回数据？我已经看到了一些 Promise.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
});

I start 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());
            })
        })
    }
}

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

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

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

Usage:

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([]));
}

用法相同。请注意我们如何从一个已解决的承诺开始[]，然后排队一堆then处理程序，每个处理程序接收数组，执行以下操作getMp4调用，当它得到结果时，将结果推送到数组上并返回它；最终的分辨率值是填充的数组。