xストリームです。イベントごとに、x_iそれ自体がイベントを生成するストリームを生成します。x_iこのセットアップから、最後まで最新のイベントのみを含むフラット化された出力ストリームを生成したいと思いxます。
x: ├─┬───┬─────┬────────┤
x_3: │ │ └─E────H───I─...
x_2: │ └─B───D────G───────...
x_1: └─A─────C────F─────────...
期待される結果は
├───A───B───D─E────H─┤
flatMaponは使用できません。これは、最新のサブ ストリームのイベントだけでなく、xすべてのイベントが出力ストリームにマージされるためです。x_i
は無限であるconcatMapため、私も使用できません。出力ストリームは事実上.x_ix_1
これはかなり一般的なシナリオのように思えるので、私の質問: 標準の RxDart (私が使用している) を使用してこれは可能ですか、それとも自分で実装する必要がありますか?