Criando um fluxo do Node.js a partir de dois fluxos de canais
Eu gostaria de combinar dois fluxos Node.js em um, canalizando-os, se possível. estou a usarTransformar fluxos.
Em outras palavras, eu gostaria que minha biblioteca voltassemyStream
para as pessoas usarem. Por exemplo, eles poderiam escrever:
process.stdin.pipe(myStream).pipe(process.stdout);
E internamente estou usando uma terceira partevendorStream
que faz algum trabalho, ligado à minha própria lógica contida emmyInternalStream
. Então, o que está acima se traduziria em:
process.stdin.pipe(vendorStream).pipe(myInternalStream).pipe(process.stdout);
Posso fazer algo assim? eu tenteivar myStream = vendorStream.pipe(myInternalStream)
mas isso obviamente não funciona.
Para fazer uma analogia combash
, digamos que eu queira escrever um programa que verifique se a letrah
está presente na última linha de algum fluxo (tail -n 1 | grep h
), Eu posso criar um script de shell:
# myscript.sh
tail -n 1 | grep h
E então, se as pessoas fizerem:
$ printf "abc\ndef\nghi" | . myscript.sh
Apenas funciona.
Isto é o que eu tenho até agora:
// 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"]
Tudo isso é possível? Deixe-me saber se o que estou tentando fazer não está claro.
Obrigado!