Highland ストリームを使用する node.js アプリケーションがあります。データ ソースを消費し、複数の宛先にデータを送信する必要があります。問題は、データを読み取り、データに基づいて宛先ストリームを作成することによって、宛先が動的に検出されることです。
これは.fork、ストリームに宛先を追加できないことを意味します (消費を開始したストリームは分岐できないためですよね?)
他にできることはありますか？
私の現在のアプローチは、.consume宛先ストリームを作成し、宛先にデータを書き込む場所を持つことです。結果は醜くて厄介です。