3

A指定されたコールドオブザーバブルからすべてのアイテムを放出し、その完了がホットオブザーバブルで継続するとすぐに、オブザーバブルを構成する適切な方法を見つけるのに苦労していBます。

これは私の特定の使用例です。追加専用データベース (イベント ストリーム) にリアルタイムでデータを追加するデータ コレクターがあります。そして、すべてのイベント ストリームをストリーミングするためのリクエストが到着すると、データベースからすべてのストリーミングを開始することが期待されます。データベースにデータがなくなるとすぐに、コレクター ストリームのストリーミングが開始されます...両方がオブザーバブルとして利用できることがわかります。

私はリアクティブ プログラミングが初めてなので、私の質問は少し抽象的かもしれません。どんな助けでも感謝します。

この動作の図を次に示します。

B ----B---B---B----B--B---B---B---X------>
                   |  |   |   |   |
                   |  |   |   |   |
R --A---A--A----?--B--B---B---B---X------>
    |   |  |    |
    |   |  |    |
A --A---A--A----X------------------------>

これRが観測可能な結果Aで、冷たいものBは熱いものです。Rで終了していBます。

4

2 に答える 2

3

B がホットな場合はA.concat(B)、A が終了したときにのみ B がサブスクライブされるため、単純に機能するはずです。

于 2015-12-24T11:57:20.530 に答える
0

必要なのは、オブザーバブルではなく、2 つのキューであると思われます。

QueueA には優先順位があり、QueueB は、QueueA がメッセージの終了/終了信号を受信した場合にのみ処理されます。

このシナリオは適切だと思いますか?

于 2015-12-24T11:21:18.603 に答える