現在、「ChunkingStream」という名前の変換ストリームを使用して、TCP ソケットからデータを受信して処理しています (そして、他の場所にパイプします)。一般的な構造は、nodejs doc に示されている例とほぼ同じです。
ChunkingStream.prototype._transform = function (chunk, encoding, callback) {
// extract data from chunk
this.push(data);
callback();
};
ただし、この問題ではデータ チャンクの順序が重要であり、呼び出しのように見えるため、次のようになります。
this.push(data);
非同期です。
したがって、上記の呼び出しを同期させる方法はありますか?? 乾杯!