async.mapLimit 与 Promise

Question

我正在尝试使用异步模块 (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);
});

结果我得到了单个值，最后得到了“结果”中所有值的数组：

[2,4,6,8,10]

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

我试过了，例如这个，但它只显示第一组请求（这是在 cmets 中的第一个建议之后更新的）：

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"));

我确实正确地取回了所有单个值，但是“.then”会立即执行并给我一个“成功”和一个空的“结果”变量。

注意：我当然看过这个帖子ES6 Promise replacement of async.eachLimit / async.mapLimit，但我认为这不能回答我的问题。

PS：我已经找到了解决这个问题的其他方法，但我对如何正确使用这个模块非常感兴趣（使用简短、干净的代码）。

Answer 1

解决方案非常简单 - 虽然我仍然相信上面的代码应该可以正常工作（根据文档），但我发现还有另一个包可以使用 Promise：'promise-async'

所以我换了行

async = require('async');

与

async = require('promise-async');

现在上面的代码按预期工作了：

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]) //Promise.all is not needed
numPromise
.then((result) => console.log("success:" + result))
.catch(() => console.log("no success"));

返回

2
4
6
8
10
success:2,4,6,8,10

Answer 2

这可能是更好的答案，尽管另一种选择似乎也不错：

const async = require('async');
const delay = require('util').promisify(setTimeout);
const numPromise = async.mapLimit(['1','2','3','4','5'], 3, async num => delay(200).then(() => num*2))
// or const numPromise = async.mapLimit(['1','2','3','4','5'], 3, async num => {
//    await delay(200);
//    return num*2;
// })
numPromise.then(console.log)
// or numPromise.then((results) => console.log(results))

另请参阅 GitHub 上的此问题线程作为参考： GitHub: async.mapLimit does not return a Promise

我认为我的代码的问题出在 iteratee 函数中 - 或者最初它不是异步的，或者我假设使用“回调”而不是“返回”（或者可能两者都使用 ;-)）。