高地中的请求流未正确向前传递

Question

当我传递地图时，我在获取 nodejs request流的工作时遇到问题，它已经是空数组了。

var _       = require('highland'),
    fs      = require('fs'),
    request = require('request');
// This works but not using the stream approach
// function get(path) {
//     return _(function (push, next) {
//         request(path, function (error, response, body) {
//             // The response itself also contains the body
//             push(error, response);
//             push(null, _.nil);
//         });
//     });
// }
var google = _(request.get('http://www.google.com'));
google
// res is empty array
.map(function (res) {
    // console.log(res);
    return res;
})
// res is empty array
.toArray(function (res) {
    console.log(res);
});

Answer 1

request（） 模块使用一种旧式流 - 它从代码 Stream 模块调用流原型上的 .pipe（） 方法：

stream.Stream.prototype.pipe.call(this, dest, opts)

https://github.com/mikeal/request/blob/11224dd1f02e311afcc11df8a8f0be1d9fb2bf83/request.js#L1310

我将实际问题追溯到节点核心流模块中的以下检查：

function ondata(chunk) {
  if (dest.writable) {
    if (false === dest.write(chunk) && source.pause) {
      source.pause();
    }
  }
}

https://github.com/joyent/node/blob/master/lib/stream.js#L50

这可以通过在上面的示例中执行以下操作来修补

var google = _(request.get('http://www.google.com'));
google.writable = true;

我提出了一个拉取请求以在 https://github.com/caolan/highland/pull/42 正确修复此问题，现已合并，因此该错误从版本 1.14.0 开始将不再可重现