2つのオブザーバブルを結合し、最初に完了する出力を取得します。

Question

プッシュ通知を待つサブスクリプションと、応答を取得するためにサーバーをポーリングするサブスクリプションがあります。私はobservableを一緒に開始し、最初に終了するものからデータを返したいと思います。ここで使う演算子は何でしょうか？

Answer 1

最初のデータを完成させたいので、それぞれを独自のリストに集め、イベントを通知するソースを選択するambを使用して、ターミナルイベントに到達するまで、データをどこかに置く必要があります（収集されたリスト）が最初に表示されます。その後、リストを個々のアイテムに戻すことができます。

Observable<A> source1 = ... 
Observable<A> source2 = ... 

Observable.amb(source1.toList(), source2.toList()) 
.flatMapIterable(list -> list) 
.subscribe(...); 

Answer 2

あなたが探しているオペレータはfirstです。もちろん、Observablesを最初にマージする必要があります（mergeを使用するか、おそらくmergeDelayErrorを使います。そのうちの1つだけが失敗した場合でも、最初にvaildの結果で終了します）。

Observable.mergeDelayError(pushObservable, pullObservable) 
     .first() 
     .subscribe(data->...); 

：

は次のようになります。