RxJava的請求隊列

Question

我需要與RxJava和Retrofit實現同步調用。我有一個ArrayList的ids。我需要遍歷這個數組，並使用Retrofit來調用web服務器的每個id，但我知道如何做到這一點只有異步，可以告訴我如何做到這一點，當一個通話結束後，下一個開始。

Answer 1

你的問題措辭很模糊，但我想我可能已經理解了。從項目列表開始，您可以使用from()創建這些項目的觀察值。此值可以在您的API調用後映射。使用concatMap()可以保證結果的順序，所以您可以有效地觀察結果。你可以做任何你想做的事情，甚至可以打電話給toBlocking()，並使可觀察的同步。但是這不應該有任何需要。

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

Answer 2

此代碼將執行它們synchronious

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

但是你需要從callToWebServer（處理所有的網絡錯誤）仔細圖（）。