我想在koa控制器中传递请求，它的工作原理是：
var s = require('through2')();
var req = http.request(url, function(res) {
res.pipe(s);
})
req.end(null);
s.on('close', function() {
console.log('has close');
});
this.body = s;
但是随着重击，似乎是行不通的。
var s = stream();
yield thunk(url, s);
this.body = s;
这是thunk：
var thunk = function (url, s) {
return function(callback) {
var req = http.request(url, function(res) {
res.pipe(s);
});
s.on('close', function() {
callback(null, null);
console.log('req inner close');
});
req.end(null);
}
}
为此使用诺言（返回诺言，而不是笨拙）。离开我的头顶，所以您可能需要尝试一下：
function run(url, s) {
return new Promise(function(resolve, reject) {
var req = http.request(url, function(res) {
res.pipe(s);
res.on('end', function() {
req.end();
});
});
req.on('error', function(err) {
return reject(err);
});
s.on('close', function() {
console.log('req inner close');
return resolve();
});
});
}
然后：
yield run(url, s);
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句