Node.js PassThroughストリームが正しく閉じられていませんか？

Question

PassThroughストリームが不思議で、なぜリソースが閉じた後に閉じないのですか？私はそれをメディエータとして使用していますが、1つのリソースにはReadableStreamが必要です。ユーザーにWriteableStreamを渡して、基になるリソースを書き込めるようにする必要があります。最初はDuplexストリームが理想的だと思われましたが実装が必要でしたが、PassThroughストリームが見つかりました。

編集：ここでは、この問題のベスト説明：https://gist.github.com/four43/46fd38fd0c929b14deb6f1744b63026a

オリジナル例： チェックこのアウト：

const fs = require('fs'); 
const stream = require('stream'); 

const passThrough = new stream.PassThrough({allowHalfOpen: false}); 
const writeStream = new fs.createWriteStream('/tmp/output.txt'); 

passThrough.pipe(writeStream) 
    .on('end',() => console.log('full-end')) 
    .on('close',() => console.log('full-close')) 
    .on('unpipe',() => console.log('full-unpipe')) 
    .on('finish',() => console.log('full-finish')); 
passThrough 
    .on('end',() => console.log('passThrough-end')) 
    .on('close',() => console.log('passThrough-close')) 
    .on('unpipe',() => console.log('passThrough-unpipe')) 
    .on('finish',() => console.log('passThrough-finish')); 

passThrough.end('hello world'); 

実際の出力：

passThrough-finish 
passThrough-end 
full-unpipe 
full-finish 
full-close 

は書き込み側のように思えますそれは仕事ですが、PassThroughストリームの「読み取り」側はクロージャを宣言しませんe、 "allowHalfOpen"オプションがfalseとして渡されたとしても（デバッガでのオプションの確認が可能です）。

私はこれについてすべて間違っていますか？ writeStreamのクローズをどのように伝播しますか？

ありがとうございました。

編集：私はトランスフォームストリームの真実であることを知っています、彼らはちょうどコーンパイプが閉じられていません。それらを手動で閉じる方法はありますか？ transform.end（）は、ストリームに "close"イベントを送り込ませません。基底リソースが成功する前に起動される "finish"イベントと "end"イベントだけです。

EDIT2：私は一緒にこの要点を置く：https://gist.github.com/four43/46fd38fd0c929b14deb6f1744b63026a

時に書き込み可能な仕上げreadable.pipe（書き込み可能）で読めるが適切に閉鎖されたことを私に示すこと。そうすれば、私はtransform.pipe（書き込み可能）を行うと、変換ストリームの "読み込み可能な"側を閉じ、書き込み可能な側を.end（）で "閉じて"いるので、全体を閉じなければならないと信じていますストリーム。私たちがテスト2で使っていないにもかかわらず、読んでしまうイベントは、孤立問題かもしれませんが、私のタイムアウト待ちはかなりうまくいくと思います。

Answer 1

あなたはwriteStreamはちょうど私ができるが、基になるストリームが不透明であり、私から隠されていることをwriteStream

const fs = require('fs'); 
const stream = require('stream'); 

const passThrough = new stream.PassThrough({allowHalfOpen: false}); 
const writeStream = new fs.createWriteStream('/tmp/output.txt'); 

passThrough 
    .on('error', (err) => console.error(err)) 
    .on('end',() => console.log('passThrough-end')) 
    .on('close',() => console.log('passThrough-close')) 
    .on('unpipe',() => console.log('passThrough-unpipe')) 
    .on('finish',() => console.log('passThrough-finish')); 

writeStream 
    .on('error', (err) => console.error(err)) 
    .on('close',() => console.log('full-close')) 
    .on('unpipe',() => console.log('full-unpipe')) 
    .on('finish',() => console.log('full-finish')); 

// passThrough-finish written because all Writes are complete 
passThrough.end('hello world'); 

passThrough.pipe(writeStream);