node.js ストリームでのエラー処理 質問する

変身

変換ストリームは読み取りと書き込みの両方が可能で、非常に優れた「中間」ストリームです。このため、throughストリームと呼ばれることもあります。この点ではデュプレックス ストリームに似ていますが、データを単に送信するのではなく、データを操作するための優れたインターフェイスを提供します。変換ストリームの目的は、ストリームを介してパイプされるデータを操作することです。たとえば、非同期呼び出しを実行したり、いくつかのフィールドを派生させたり、いくつかのものを再マップしたりする必要がある場合があります。

変換ストリームの作成方法については、ここそしてここあなたがしなければならないことは、次のとおりです。

1. ストリームモジュールを含める
2. Transformクラスをインスタンス化（または継承）する
3. _transformを受け取るメソッドを実装します(chunk, encoding, callback)。

チャンクはデータです。 で作業している場合、ほとんどの場合、エンコードについて心配する必要はありませんobjectMode = true。チャンクの処理が完了すると、コールバックが呼び出されます。その後、このチャンクは次のストリームにプッシュされます。

ストリームを非常に簡単に実行できる便利なヘルパーモジュールが必要な場合は、2 を通して。

エラー処理については、読み続けてください。

パイプ

パイプチェーンでは、エラーの処理は確かに簡単ではありません。このスレッド.pipe() はエラーを転送するようには構築されていません。つまり、次のようなものになります...

var a = createStream();
a.pipe(b).pipe(c).on('error', function(e){handleError(e)});

var a = createStream();
a.on('error', function(e){handleError(e)})
.pipe(b)
.on('error', function(e){handleError(e)})
.pipe(c)
.on('error', function(e){handleError(e)});

var d = domain.create();
 d.on('error', handleAllErrors);
 d.run(function() {
     fs.createReadStream(tarball)
       .pipe(gzip.Gunzip())
       .pipe(tar.Extract({ path: targetPath }))
       .on('close', cb);
 });