RxJavaリピート操作

Question

私は私がこのようなオブジェクトを取得することができますAPIがあります。

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

を、私は取得する方法に問題

Observable<Answer from API> 

を返すメソッドのgetItems（ページ）といくつかのRestApiServiceを持っていますサーバーからのすべてのページ？

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に関するいくつかのドキュメント