RxJava重複操作

Question

我有一個API，它讓我找回這樣的對象：

Answer from API 
{ 
    currentPage = some_int; 
    maxPage = some_int; 
    List<String> items; //items on page 
} 

，我有一些RestApiService與方法getItems（頁）誰返回

Observable<Answer from API> 

如何獲得的問題從服務器的所有頁面？

Answer 1

這個代碼庫的例子應該做的伎倆

@Test 
public void repeat() { 
    int maxPage = 10; 
    int[] arrayPages = IntStream.range(0, maxPage).toArray(); 
    List<Integer> pages = IntStream.of(arrayPages).boxed().collect(Collectors.toList()); 
    Observable.from(pages) 
      .map(this::getItemsApi) 
      .toList() 
      .subscribe(list -> System.out.println("All items:" + list)); 
} 

public String getItemsApi(int page) { 
    return "Items form page " + page; 
} 

無論如何，你應該儘量避免複製/粘貼代碼，而無需瞭解如何工作的。你可以在這裏看到一些實際的例子和關於RxJava的一些文檔https://github.com/politrons/reactive