node.js - waterfall 中的嵌套async.eachSeries执行顺序错误

在异步 waterfall 的第二个函数中，出于我无法逾越的原因，我的代码中的eachSeries回调(urlCallback)在 waterfall 回调(waterfallCallback)之后执行。

   async.waterfall([
      function(callback) {
        request(website, function (error, response, html) {
            if (!error && response.statusCode == 200) {
              pageUrls = getPageUrls(html)
              callback(null, pageUrls)
            }
          })
      },
      function (pageUrls, waterfallCallback) {
          async.eachSeries(pageUrls, function (url, urlCallback) {
              console.log('SET ' + url)
              request(url, function (err, response, body) {
                  var $ = cheerio.load(body)
                  $('#div').children().each(function(){
                    console.log($(this).children("a").attr("href"));
                    itemUrl = $(this).children("a").attr("href")
                    itemUrls.push(itemUrl)
                  })
                  urlCallback(null,itemUrls)
              })
          },
          waterfallCallback(null, itemUrls))
      }
    ],
      function(err, results) {
        console.log("results: " + results)
    })

在AFAIK中，async.eachSeries接受三个参数(数组，functionToBeExecuteOnEachItem，回调)并按此顺序执行。不知何故不在这里。

最佳答案

async.eachSeries的参数是函数定义。类似于waterfallCallback或function(err,result){}。

当您调用waterfallCallback(null, itemUrls)时，这不是函数定义，而是在运行函数本身!

更改为简单的waterfallCallback应该可以解决问题。

更新:此外，.eachSeries不会将值作为数组返回，它的最终回调只是function(err)。而是 check out .mapSeries link，它将在最终的回调function(err,finalArray)中返回结果数组。 (请注意，.map的每次返回将是数组中的一个元素，因此，如果返回数组，您将获得类似于[ [], [], [] ]的数据结构)

关于node.js - waterfall 中的嵌套async.eachSeries执行顺序错误，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/39534571/