从响应nodejs发出数据后无法管道

Question

我在使用 node js 的 require 库时遇到了问题。当我尝试通过管道传输到文件和响应流时，出现错误：you cannot pipe after data has been emitted from the response。这是因为我在真正管道数据之前做了一些计算。

例子：

var request = require('request')
var fs = require('fs')
var through2 = require('through2')

options = {
    url: 'url-to-fetch-a-file'
};

var req = request(options)
req.on('response',function(res){
    //Some computations to remove files potentially
    //These computations take quite somme time.
    //Function that creates path recursively
    createPath(path,function(){
        var file = fs.createWriteStream(path+fname)
        var stream = through2.obj(function (chunk, enc, callback) {
            this.push(chunk)
            callback()
        })

        req.pipe(file)
        req.pipe(stream)
    })
})

如果我只是通过管道传输到流而不进行任何计算，那很好。如何使用 nodejs 中的request 模块通过管道传输到文件和流？

我找到了这个：Node.js Piping the same readable stream into multiple (writable) targets，但它不是一回事。在那里，管道在不同的滴答声中发生 2 次。这个例子就像问题中的答案一样管道，但仍然收到错误。

Answer 1

您可以将侦听器添加到您定义的stream，而不是直接通过管道传输到文件。所以你可以用

替换req.pipe(file)

stream.on('data',function(data){
    file.write(data)
})

stream.on('end',function(){
    file.end()
})

或

stream.pipe(file)

这将暂停流，直到它被读取，request 模块不会发生这种情况。

更多信息：https://github.com/request/request/issues/887