小编Eri*_*der的帖子

带有 Promise 的 async.mapLimit

我正在尝试使用异步模块 (v3),尤其是 async.mapLimit 方法来提交有限数量的并行异步请求。这适用于以下(简化的)示例代码中的回调:

async = require('async');
async.mapLimit(['1','2','3','4','5'], 3, function(num, callback){
setTimeout(function(){
    num = num * 2,
    console.log(num);
    callback(null, num);
}, 
4000);  
},function(err, results){
    console.log(results);
});
Run Code Online (Sandbox Code Playgroud)

结果,我得到了单个值,最后得到了包含“结果”中所有值的数组:

[2,4,6,8,10]
Run Code Online (Sandbox Code Playgroud)

现在我正在努力使用这种方法的基于 Promise 的版本。文档说,如果我不提供回调,它会返回一个 Promise。如何将此基于回调的代码更改为使用 Promises?

我试过例如这个,但它只显示第一组请求(这是在评论中的第一个建议之后更新的):

let numPromise = async.mapLimit(['1','2','3','4','5'], 3, function(num, callback){
    setTimeout(function(){
        num = num * 2,
        console.log(num);
        callback(null, num);
    }, 
    4000); 
});
Promise.all([numPromise]) //always calls .then immediately, without result
.then((result) => console.log("success:" + result))
.catch(() => console.log("no success"));
Run Code Online (Sandbox Code Playgroud)

我确实正确地取回了所有单个值,但是 '.then' 会立即执行并给我一个空的 'result' 变量的 'Success'。

注意:我当然看过这个线程ES6 Promise …

node.js promise async.js

2
推荐指数
1
解决办法
1934
查看次数

标签 统计

async.js ×1

node.js ×1

promise ×1