読み込み/書き込みストリームを使用してバイナリファイルを正しく解析および再構成できない

Question

バイナリファイルの特定のセグメントを取得し、圧縮した形式に再結合しようとしています。しかし、このタスクが完了すると、バイナリデータはセミランダムな順序でスクランブルされる。実際には、最初のおよそ15kバイトが正しければ、その後にコンフリクトが連続して発生します。何がうまくいかないのですか？私は、これらのストリームが（より良いメタファの欠如のために）お互いに走っていると信じて、結果のバイトの長さは正しいです。なぜこうなった？私は非同期性に関して十分な注意を払っていると思った？

    var destinationPath = something.bin; 
       Promise.all(sources.map(function (source) { 
        return new Promise(function (resolve, reject) { 
         var output = fs.createWriteStream(destinationPath, {'flags': 'a', 'bufferSize': 64 * 4096}); 
         var input = fs.createReadStream(source.filePath, { 
          start: source.parameters.start, 
          end: source.parameters.end + 3 
         }); 
         input.on('end', function() { 
          output.on('finish', function() { 
           resolve(); 
          }); 
         }); 
         input.pipe(output); 
        }); 
       })); 

Answer 1

この影響があるかどうかはわかりませんが、順番にお試ししましたか？同じファイルに複数の書き込みストリームを同時に作成します。例えば

：

   var destinationPath = something.bin; 
      var promise = Promise.resolve(); 
      sources.forEach(function (source) { 
       promise = promise.then(funtion() { 
       return new Promise(function (resolve, reject) { 
        var output = fs.createWriteStream(destinationPath, {'flags': 'a', 'bufferSize': 64 * 4096}); 
        var input = fs.createReadStream(source.filePath, { 
         start: source.parameters.start, 
         end: source.parameters.end + 3 
        }); 
        input.on('end', function() { 
         output.on('finish', function() { 
          resolve(); 
         }); 
        }); 
        input.pipe(output); 
       }); 
       }); 
      }); 

      promise.then(function() { 
       // we're done here 
      });