node.js - 管道两次相同的流创建一个无限循环

Question

我正在使用 Node.js 流进行练习，但遇到以下代码问题：

'use strict'

let stream = require('stream');

let logger = new stream.Transform({
  transform: function (chunk, encoding, next) {
    console.log(`Chunk: ${chunk}`);
    this.push(chunk);
    next();
  }
})

let liner = new stream.Transform({
  transform: function (chunk, encoding, next) {
    chunk.toString().split('\r\n').forEach(e=>this.push(e));
    next();
  }
})

process.stdin.pipe(logger).pipe(liner).pipe(logger);

我希望对 logger 的两个调用是 logger 流的不同实例，但它们似乎是相同的，并且它们进入了一个无限循环，所以我应该如何调用它们才能使这段代码按预期工作。

非常感谢。

Answer 1

它是同一个对象，因此预期会出现无限循环：

process.stdin.pipe(logger).pipe(liner).pipe(logger);
//                    ^-----------------------|

尝试使用 2 个不同的实例：

'use strict'

let stream = require('stream');


let logger = function () {
    return new stream.Transform({
        transform: function (chunk, encoding, next) {
            console.log(`Chunk: ${chunk}`);
            this.push(chunk);
            next();
        }
    });
}

let liner = new stream.Transform({
    transform: function (chunk, encoding, next) {
        chunk.toString().split('\r\n').forEach(e=> this.push(e));
        next();
    }
})

process.stdin.pipe(logger()).pipe(liner).pipe(logger());