RxJavaによるリクエストのキュー

Question

RxJavaとRetrofitの同期コールを実装する必要があります。ArrayListのIDがあります。私はこの配列を繰り返し、各IDのためにWebサーバーへの呼び出しをRetrofitを使用して行う必要がありますが、これを行う方法はわかっていますが、1つの呼び出しが終了した後にキュー内でこれを行う方法を教えてくれます。

Answer 1

あなたの質問は非常にあいまいですが、私はそれを理解していると思います。アイテムのリストから始めて、from()でこれらのオブザーバブルを作成することができます。この値は、API呼び出し後にマップすることができます。 concatMap()を使用すると、結果の順序が保証され、結果を効果的に観察することができます。これらはあなたが望むものを何でもすることができ、それにもtoBlocking()を呼び出して観察可能な同期をとることさえできます。しかし、これは必要ありません。

List<Result> results = 
     Observable.from(ids) 
        .concatMap(id -> callToWebServer(id)) 
        .toList() 
        .toBlocking() 
        .single(); 

Answer 2

このコードは

Observable.from(ids) 
      .map(id -> callToWebServer(id).toBlocking().first()) 

synchroniousそれらを実行します。しかし、あなたは慎重マップ（）に）callToWebServer（からすべてのネットワーク・エラーを処理する必要があります。