Мне нужно запустить сразу две команды, которые должны читать данные из одного потока. После подачи потока в другой буфер освобождается, поэтому я не могу читать данные из этого потока снова, поэтому это не работает:
var spawn = require('child_process').spawn;
var fs = require('fs');
var request = require('request');
var inputStream = request('http://placehold.it/640x360');
var identify = spawn('identify',['-']);
inputStream.pipe(identify.stdin);
var chunks = [];
identify.stdout.on('data',function(chunk) {
chunks.push(chunk);
});
identify.stdout.on('end',function() {
var size = getSize(Buffer.concat(chunks)); //width
var convert = spawn('convert',['-','-scale',size * 0.5,'png:-']);
inputStream.pipe(convert.stdin);
convert.stdout.pipe(fs.createWriteStream('half.png'));
});
function getSize(buffer){
return parseInt(buffer.toString().split(' ')[2].split('x')[0]);
}
Запрос жалуется на это
Error: You cannot pipe after data has been emitted from the response.
и изменение inputStream на fs.createWriteStream
дает ту же проблему, конечно.
Я не хочу записывать в файл, но каким-то образом повторно использовать поток, создаваемый request (или любой другой).
Есть ли способ повторно использовать читаемый поток после завершения конвейера? Какой был бы лучший способ выполнить что-то вроде приведенного выше примера?