Я хотел бы объединить два потока Node.js в один, по возможности передав их по трубопроводу. Я'м используюпреобразование потоки.

Другими словами, яя хотел бы вернуть мою библиотекуmyStream для людей, чтобы использовать. Например, они могли написать:

process.stdin.pipe(myStream).pipe(process.stdout);

И внутренне ям с использованием стороннегоvendorStream что делает некоторую работу, подключен к моей собственной логике, содержащейся вmyInternalStream, И что's выше будет означать:

process.stdin.pipe(vendorStream).pipe(myInternalStream).pipe(process.stdout);

Могу ли я сделать что-то подобное? Я'мы пыталисьvar myStream = vendorStream.pipe(myInternalStream) но это явно нет работа.

Провести аналогию сbash, позволять'скажем, я хочу написать программу, которая проверяет, если письмоh присутствует в последней строке некоторого потока (tail -n 1 | grep h), Я могу создать сценарий оболочки:

# myscript.sh
tail -n 1 | grep h

И тогда, если люди делают:

$ printf "abc\ndef\nghi" | . myscript.sh

Это просто работает.

Это то, что я до сих пор:

// Combine a pipe of two streams into one stream

var util = require('util')
  , Transform = require('stream').Transform;

var chunks1 = [];
var stream1 = new Transform();
var soFar = '';
stream1._transform = function(chunk, encoding, done) {
  chunks1.push(chunk.toString());
  var pieces = (soFar + chunk).split('\n');
  soFar = pieces.pop();
  for (var i = 0; i < pieces.length; i++) {
    var piece = pieces[i];
    this.push(piece);
  }
  return done();
};

var chunks2 = [];
var count = 0;
var stream2 = new Transform();
stream2._transform = function(chunk, encoding, done) {
  chunks2.push(chunk.toString());
  count = count + 1;
  this.push(count + ' ' + chunk.toString() + '\n');
  done();
};

var stdin = process.stdin;
var stdout = process.stdout;

process.on('exit', function () {
    console.error('chunks1: ' + JSON.stringify(chunks1));
    console.error('chunks2: ' + JSON.stringify(chunks2));
});
process.stdout.on('error', process.exit);


// stdin.pipe(stream1).pipe(stream2).pipe(stdout);

// $ (printf "abc\nd"; sleep 1; printf "ef\nghi\n") | node streams-combine.js
// Outputs:
// 1 abc
// 2 def
// 3 ghi
// chunks1: ["abc\nd","ef\nghi\n"]
// chunks2: ["abc","def","ghi"]

// Best working solution I could find
var stream3 = function(src) {
  return src.pipe(stream1).pipe(stream2);
};
stream3(stdin).pipe(stdout);

// $ (printf "abc\nd"; sleep 1; printf "ef\nghi\n") | node streams-combine.js
// Outputs:
// 1 abc
// 2 def
// 3 ghi
// chunks1: ["abc\nd","ef\nghi\n"]
// chunks2: ["abc","def","ghi"]

Это вообще возможно? Дайте мне знать, если яя пытаюсь сделать неЯсно.

Спасибо!