Node.js가 파이프 된 스트림을 동적으로 확장합니다.

Question

node.js 시스템을 벤치마킹하고 싶습니다. 그러므로 나는 파일을 암호화하고 압축 할 수있는 작은 프로그램을 만들었다. (나는 앱이 CPU를 강렬하게하고 싶어한다.) 나는 내가 여러 번 암호화 과정을 반복 할 수 있다고 생각했다. 그러나 프로그램을 끝내기 전에 스트림을 동적으로 파이프하고자 할 때마다. 스트림이 끝날 때까지 기다릴 수있는 방법이 있습니까?

내 코드는 다음과 같습니다

for (i = 0; i < algorithmCount; i++) { 
    stream = stream.pipe(encryptStream); 
} 

이 .pipereturns the stream you're piping into 있음을 기억

이

  var readStream = fstream.Reader(sourcePath); 
      var writeStream = fs.createWriteStream(sourcePath + '.tar.gz'); 

      var stream = readStream.on('error', function (e) { 
        handleError(e, errorMessageReadFile); 
       }) 
       .pipe(tar.Pack()).on('error', function (e) { 
        handleError(e, errorMessageTarPack); 
       }); 

      for (i = 0; i < algorithmCount; i++) { 
       stream = stream.pipe(encryptStream).on('error', function (e) { 
        handleError(e, errorMessageEncrypt); 
       }); 
       console.log("enc"); 
      } 

      stream.pipe(gzip).on('error', function (e) { 
        handleError(e, errorMessageCompress); 
       }) 
       .pipe(writeStream).on('error', function (e) { 
        handleError(e, errorMessageWriteFile); 
       }) 
       .on('finish', function() { 
        console.log('done'); 
       }); 

Answer 1

이 가능성이 문제입니다. 즉, stream.pipe(encryptStream)은 encryptStream을 반환합니다. 첫 번째 반복은 괜찮습니다. stream은 처음에는 tar.Pack() 스트림이고, 따라서 encryptStream으로 파이프됩니다. 그러나 두 번째 반복은 이제 encryptStream과 동일하게이되는 stream을 파이프합니다.

반복 할 때마다 중간에 새로운 중간 암호화 스트림을 생성하는 것이 좋습니다. 예 :

for (i = 0; i < algorithmCount; i++) { 
    stream = stream.pipe(createEncryptStream()); 
}