RxJava 重复操作

Question

我有一个 API 可以让我像这样检索对象：

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

我有一些 RestApiService 方法 getItems(page) 返回

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