回答編集履歴

 

 

  Aのデータが尽きて`end`イベントが発生すると、pipeされたBでいずれ[`finish`イベント](https://nodejs.org/api/stream.html#stream_event_finish)が発生する(ことが期待される)ので、このタイミングでresolveすればいいことになります。同様に、エラーが発生すると[`error`イベント](https://nodejs.org/api/stream.html#stream_event_error)が発生するのでこのときにrejectすればいいです。promiseと異なりstreamは`.on`でイベントリスナーを設定するので、質問文にあるコードのようになります。