rxjavaを使用して複数のAPIエンドポイントを1つのストリームでポーリングする

Question

現在複数のエンドポイント（異なる）をポーリングしようとしています 問題は私が集計した状態を返さなかったエンドポイントやり方は流れが基本的にあるので：

リクエストを構築する - > 1つのストリームにマージ - >投票を応答するために - >チェックは状況が一致している：

1. 待って流れをやり直していない場合
2. ストリームからオブザーバーを取り出す場合

これは私が書かれていると私は

おかげでたくさんの何か

Observable.merge(buildRequests()) 
.repeatWhen(obs -> obs.delay(5000, TimeUnit.MILLISECONDS)) 
.takeUntil(response -> CheckShouldRepeat(response)).subscribe(whatever()); 

を欠けているようにそれが感じるものです！

Answer 1

Observable.fromCallable(() -> buildRequests()) 
.repeatWhen(o -> CheckShouldRepeat(v -> Observable.timer(5000, TimeUnit.MILLISECONDS))); 

これは役立ちます。