我正在尝试通过异步模块构建一个简单的节点瀑布。我刚刚开始在节点中进行异步编程。
基本上 - 如何调用callback()
内部http.request
函数以在结束后继续瀑布response
?
async.waterfall([
function (callback) {
var req = http.request(options, function (response) {
var str = ''
response.on('data', function (chunk) {
str += chunk;
});
response.on('end', function () {
/* I want to call callback() AFTER `response` is END */
});
});
req.end();
},
function (response, callback) {
// some operations WITH request `output`
}], function (err, results) {
// end
});