javascript - 实现 Promise.series 作为 Promise.all 的替代品

Question

我看到了 Promise.all 的这个示例实现 - 它并行运行所有 promise - Implementing Promise.all

请注意，我正在寻找的功能类似于 Bluebird 的 Promise.mapSeries http://bluebirdjs.com/docs/api/mapseries.html

我正在尝试创建 Promise.series，我有这个似乎按预期工作(它实际上是完全错误的，不要使用它，查看答案):

Promise.series = function series(promises){

    return new Promise(function(resolve,reject){

    const ret = Promise.resolve(null);
    const results = [];

    promises.forEach(function(p,i){
         ret.then(function(){
            return p.then(function(val){
               results[i] = val;
            });
         });
    });

    ret.then(function(){
         resolve(results);
    },
     function(e){
        reject(e);
     });

    });

}


Promise.series([
    new Promise(function(resolve){
            resolve('a');
    }),
    new Promise(function(resolve){
            resolve('b');
    })
    ]).then(function(val){
        console.log(val);
    }).catch(function(e){
        console.error(e.stack);
    });

但是，此实现的一个潜在问题是，如果我拒绝一个 promise，它似乎并没有捕捉到它:

 Promise.series([
    new Promise(function(resolve, reject){
            reject('a');   // << we reject here
    }),
    new Promise(function(resolve){
            resolve('b');
    })
    ]).then(function(val){
        console.log(val);
    }).catch(function(e){
        console.error(e.stack);
    });

有谁知道为什么错误没有被捕获，是否有办法用 Promises 解决这个问题？

根据评论，我做了这个更改:

Promise.series = function series(promises){

    return new Promise(function(resolve,reject){

    const ret = Promise.resolve(null);
    const results = [];

    promises.forEach(function(p,i){
         ret.then(function(){
            return p.then(function(val){
               results[i] = val;
            },
            function(r){
                console.log('rejected');
                reject(r);   // << we handle rejected promises here
            });
         });
    });

    ret.then(function(){
         resolve(results);
    },
     function(e){
        reject(e);
     });

    });

}

但这仍然没有按预期工作......

Answer 1

forEach 循环中 then 返回的 promise 不处理潜在的错误。

正如@slezica 在评论中指出的那样，尝试使用 reduce 而不是 forEach，这会将所有 promise 链接在一起。

Promise.series = function series(promises) {
    const ret = Promise.resolve(null);
    const results = [];

    return promises.reduce(function(result, promise, index) {
         return result.then(function() {
            return promise.then(function(val) {
               results[index] = val;
            });
         });
    }, ret).then(function() {
        return results;
    });
}

请记住， promise 此时已经“运行”。如果你真的想串行运行你的 promise ，你应该调整你的功能并传入一个返回 promise 的函数数组。像这样:

Promise.series = function series(providers) {
    const ret = Promise.resolve(null);
    const results = [];

    return providers.reduce(function(result, provider, index) {
         return result.then(function() {
            return provider().then(function(val) {
               results[index] = val;
            });
         });
    }, ret).then(function() {
        return results;
    });
}