在 node.js 异步模块的 forEachOf 方法中未调用可选回调

Question

我正在使用异步模块的 forEachOf 方法在遍历对象后打印最终结果。这是我正在做的事情的简化版本：

var async = require('async'),
    cheerio = require('cheerio'),
    request = require('request');

var returnArray = [];

async.forEachOf(myObj, function (value, key, callback) {
    var anotherObj = {};

    anotherObj.type = "val1";

    request(someurl, function(err, res, body) {
        if (err) {
            return callback(err);
        }

        var $ = cheerio.load(body);

        anotherObj.name = "val2";

        var miniObj = {};
        $('#some-element', "#an-id").each(function(i, value) {
            var val = value.value;
            miniObj[size] = val;
        });

        anotherObj.miniObj = miniObj;

        returnArray.push(anotherObj);

        return callback();
    });
}, function (err) {
    if (err) {
        console.error(err.message);
    }

    console.log(returnArray);
});

但是，当我运行程序时，没有任何东西（即“returnArray”）被打印到控制台上。

作为参考，我查看了这些其他类似的帖子：

• Using async module to fire a callback once all files are read（好像过时了，方法不对，没有解决问题）
• Last callback not being called using async（没有解决问题）

我不确定我在这里做错了什么。谁能指出我做错了什么？

谢谢！

编辑：所以我想我终于弄清楚我做错了什么。在我之前提供的另一个示例中 HERE, using Runnable 我忘记添加“return callback()”语句。然后它起作用了。该示例与此示例之间的唯一区别是我在上面提供的示例中的“return callback()”语句本身是在另一个异步方法中调用的。我认为为了解决我的问题，我必须以某种方式确保（可能使用异步库中的一些控制流函数）在第二个异步方法完成后在正确的“范围/级别”调用“返回回调（）”。我想我会将此归因于我的错误，因为缺少关于在异步文档中正确使用“return callback()”语句的文档。一旦我弄明白了（并睡了一会儿），我会用解决方案更新这篇文章！

Answer 1

您的陈述：

if (err) {
    return callback(err);
}

对异步编程无效。相反，您应该这样做：

if(err) callback(err);

这就是您没有得到任何回报的原因。我用异步概念重写了你的代码：

var async = require('async'),
var cheerio = require('cheerio'),
var request = require('request');

var returnArray = [];
async.forEachOf(myObj, function (value, key, next) {
    var anotherObj = {};

    anotherObj.type = "val1";

    request(someurl, function(err, res, body) {
        if (err) next(err);

        var $ = cheerio.load(body);

        anotherObj.name = "val2";

        var miniObj = {};
        async.each($('#some-element', "#an-id"), function (value, next) {
          var val = value.value;
          miniObj[size] = val;
        });

        anotherObj.miniObj = miniObj;

        returnArray.push(anotherObj);

        next();
    });
}, function (err) {
    if (err) console.error(err.message);

    console.log(returnArray);
    callback(returnArray);

});

请注意，您有两个不同的命名回调。外部函数回调称为callback。内部函数回调称为next。