在异步瀑布中的第二个函数中,我的代码中的eachSeries
回调(urlCallback
)在瀑布回调(waterfallCallback
)后执行,原因我无法理解。在瀑布中嵌套的async.eachSeries按错误顺序执行
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,回调)和以该顺序执行它们。不知何故不在这里。
非常有帮助。但是,它看起来像'urlCallback(null,itemUrls)'不会根据需要返回数组。 – Erasmus
'urlCallback'是否在'eachSeries'回调中返回指定的数组? – Erasmus
啊,是的。我已经更新了我的答案。 – clay