node.js - Node ，如何处理/捕获管道

Question

我看过并阅读了一些教程，其中指出您可以将一个流通过管道传输到另一个流，就像乐高积木一样，但是我找不到任何有关如何在流通过管道传输到对象时捕获管道命令的内容。

我的意思是如何创建一个具有函数的对象，以便我可以执行以下操作:

uploadWrapper = function (client, file, callback) {
  upload = function (client,file,callback){
    var file = file
    // this.data = 'undefined'
    stream.Writable.call(this);
    this.end = function () {
        if(typeof this.data !== 'undefined') file.data = this.data
        callback(file.data,200)
    }
    // var path = urlB.host('upload').object('files',file.id).action('content').url
    // // client.upload(path,file,callback)
  }
  util.inherits(upload,stream.Writable)

  upload.prototype._write = function (chunk, encoding, callback) {
    this.data = this.data + chunk.toString('utf8')
    callback()
  }

      return new upload(client,file,callback)
}
exports.upload = uploadWrapper

当数据通过管道传送到我的对象时，我该如何处理？

我看过了，但我真的找不到任何关于此的信息(也许我没有看过写的地方？)。

有人能给我指出正确的方向吗？

如果它有助于了解它，我想要做的就是捕获数据流并构建一个包含二进制编码数据的字符串；无论是来自文件流还是来自服务器的请求流(即来自多部分请求的文件的数据)对象。

编辑:我已经更新了代码来记录数据

编辑:我已经修复了它，我现在可以接收管道数据，我必须将代码放入返回实现流的函数的包装器中。

编辑:现在有不同的问题，_read 中的 this.data 未以上传函数中的 this.data 可以读取的方式存储。

编辑:好的，现在我可以处理回调并捕获数据，我需要弄清楚如何判断数据是否正在通过管道传递给它或者是否被用作普通函数。

Answer 1

如果您想创建自己的可以通过管道传输的流，请查看 Node docs for implementing streams .