blocks|key|143849|text|您可以递归地对其进行建模：|type|unstyled|depth|inlineStyleRanges|entityRanges|data|143850|Observable<ApiResponse>+getPageAndNext(int+page)+{
++return+getResults(page)
++++++.concatMap(new+Func1<ApiResponse,+Observable<ApiResponse>>()+{

++++++++@Override
++++++++public+Observable<ApiResponse>+call(ApiResponse+response)+{
++++++++++//+Terminal+case.
++++++++++if+(response.next+==+null)+{
++++++++++++return+Observable.just(response);
++++++++++}
++++++++++return+Observable.just(response)
++++++++++++++.concatWith(getPageAndNext(response.next));
++++++++}

++++++});
}|code-block|syntax|javascript|143851|然后，为了消耗它，|143852|getPageAndNext(0)
++++.concatMap(new+Func1<ApiResponse,+Observable<ResponseObject>>()+{

++++++++@Override
++++++++public+Observable<ResponseObject>+call(ApiResponse+response)+{
++++++++++return+Observable.from(response.results);
++++++++}

++++})
++++.subscribe(new+Action1<ResponseObject>()+{+/**+Do+something+with+it+*/+});|143853|这应该会得到一个按顺序到达的ResponseObject流，并且很可能是以页面大小的块到达的。|offset|length|style|CODE|143854|entityMap^0|0|0|0|0|E|E|0^^$0|@$1|2|3|4|5|6|7|S|8|@]|9|@]|A|$]]|$1|B|3|C|5|D|7|T|8|@]|9|@]|A|$E|F]]|$1|G|3|H|5|6|7|U|8|@]|9|@]|A|$]]|$1|I|3|J|5|D|7|V|8|@]|9|@]|A|$E|F]]|$1|K|3|L|5|6|7|W|8|@$M|X|N|Y|O|P]]|9|@]|A|$]]|$1|Q|3|-4|5|6|7|Z|8|@]|9|@]|A|$]]]|R|$]]

You could model it recursively:

<pre><code>Observable&lt;ApiResponse&gt; getPageAndNext(int page) {
 return getResults(page)
 .concatMap(new Func1&lt;ApiResponse, Observable&lt;ApiResponse&gt;&gt;() {

 @Override
 public Observable&lt;ApiResponse&gt; call(ApiResponse response) {
 // Terminal case.
 if (response.next == null) {
 return Observable.just(response);
 }
 return Observable.just(response)
 .concatWith(getPageAndNext(response.next));
 }

 });
}
</code></pre>

Then, to consume it,

<pre><code>getPageAndNext(0)
 .concatMap(new Func1&lt;ApiResponse, Observable&lt;ResponseObject&gt;&gt;() {

 @Override
 public Observable&lt;ResponseObject&gt; call(ApiResponse response) {
 return Observable.from(response.results);
 }

 })
 .subscribe(new Action1&lt;ResponseObject&gt;() { /** Do something with it */ });
</code></pre>

That should get you a stream of <code>ResponseObject</code> that will arrive in order, and most likely arrive in page-size chunks.

blocks|key|140270|text|我在一个类似的帖子中回答了我的解决方案：https://stackoverflow.com/a/34378263/143733|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|140271|@Iopar提供的解决方案的诀窍或修改是包含一个可以通过各种方式发出的“触发器”可观察物。|140272|在我发布的代码中，一旦处理了一整页的元素，它就会发出，但是它也可以基于用户单击按钮/滚动而发生。|140273|entityMap|0|LINK|mutability|MUTABLE|url|https://stackoverflow.com/a/34378263/143733^0|K|17|0|0|0|0^^$0|@$1|2|3|4|5|6|7|P|8|@]|9|@$A|Q|B|R|1|S]]|C|$]]|$1|D|3|E|5|6|7|T|8|@]|9|@]|C|$]]|$1|F|3|G|5|6|7|U|8|@]|9|@]|C|$]]|$1|H|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|I|$J|$5|K|L|M|C|$N|O]]]]

I've answered my solution in a similar post: <a href="https://stackoverflow.com/a/34378263/143733">https://stackoverflow.com/a/34378263/143733</a>

The trick or amendment to the solution provided by @Iopar is the inclusion of a 'trigger' Observable that can be emitted by a variety of ways.

In the code I posted, it is emitted once a full page of elements have been processed however it could also occur based on a user clicking a button/scrolling.

blocks|key|142583|text|Iopar给出了一个很好的例子。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|142584|只是一个小小的补充。|142585|如果您想在一个onNext()调用中获取所有页面。|142586|当你想用更多的观察值来压缩这个结果时，它会很有帮助。|142587|你应该这样写：|142588|private+List<String>+list+=+new+LinkedList()+{
++++{
++++++++add("a");
++++++++add("b");
++++++++add("c");
++++}
};

int+count+=+1;

public+Observable<List<String>>+getAllStrings(int+c)+{
++++return+Observable.just(list)
++++++++++++.concatMap(
++++++++++++++++++++strings+->+{
++++++++++++++++++++++++if+(c+==+3)+{
++++++++++++++++++++++++++++return+Observable.just(list);
++++++++++++++++++++++++}+else+{
++++++++++++++++++++++++++++count+%2B=+1;
++++++++++++++++++++++++++++return+Observable.zip(
++++++++++++++++++++++++++++++++++++Observable.just(list),
++++++++++++++++++++++++++++++++++++getAllStrings(count),
++++++++++++++++++++++++++++++++++++(strings1,+strings2)+->+{
++++++++++++++++++++++++++++++++++++++++strings1.addAll(strings2);
++++++++++++++++++++++++++++++++++++++++return+strings1;
++++++++++++++++++++++++++++++++++++}
++++++++++++++++++++++++++++);
++++++++++++++++++++++++}
++++++++++++++++++++}
++++++++++++);
}|code-block|syntax|javascript|142589|使用|style|BOLD|142590|getAllStrings(0)
++++++++.subscribe(strings+->+{
++++++++++++Log.w(TAG,+"call:+"+%2B+strings);
++++++++});|142591|你将会得到：|142592|call:+[a,+b,+c,+a,+b,+c,+a,+b,+c,+a,+b,+c]|142593|entityMap|0|LINK|mutability|MUTABLE|url|https://stackoverflow.com/users/1424355/lopar^0|0|5|0|0|0|0|0|0|0|0|2|0|0|0|0^^$0|@$1|2|3|4|5|6|7|18|8|@]|9|@$A|19|B|1A|1|1B]]|C|$]]|$1|D|3|E|5|6|7|1C|8|@]|9|@]|C|$]]|$1|F|3|G|5|6|7|1D|8|@]|9|@]|C|$]]|$1|H|3|I|5|6|7|1E|8|@]|9|@]|C|$]]|$1|J|3|K|5|6|7|1F|8|@]|9|@]|C|$]]|$1|L|3|M|5|N|7|1G|8|@]|9|@]|C|$O|P]]|$1|Q|3|R|5|6|7|1H|8|@$A|1I|B|1J|S|T]]|9|@]|C|$]]|$1|U|3|V|5|N|7|1K|8|@]|9|@]|C|$O|P]]|$1|W|3|X|5|6|7|1L|8|@]|9|@]|C|$]]|$1|Y|3|Z|5|N|7|1M|8|@]|9|@]|C|$O|P]]|$1|10|3|-4|5|6|7|1N|8|@]|9|@]|C|$]]]|11|$12|$5|13|14|15|C|$16|17]]]]

<a href="https://stackoverflow.com/users/1424355/lopar">Iopar</a> gave a great example.

Just a small addition. 
If you want to get all pages in one onNext() call. 
It can be helpful when you want to zip this result with one more Observable. 
You should write:

<pre><code>private List&lt;String&gt; list = new LinkedList() {
 {
 add("a");
 add("b");
 add("c");
 }
};

int count = 1;

public Observable&lt;List&lt;String&gt;&gt; getAllStrings(int c) {
 return Observable.just(list)
 .concatMap(
 strings -&gt; {
 if (c == 3) {
 return Observable.just(list);
 } else {
 count += 1;
 return Observable.zip(
 Observable.just(list),
 getAllStrings(count),
 (strings1, strings2) -&gt; {
 strings1.addAll(strings2);
 return strings1;
 }
 );
 }
 }
 );
}
</code></pre>

Usages:

<pre><code>getAllStrings(0)
 .subscribe(strings -&gt; {
 Log.w(TAG, "call: " + strings);
 });
</code></pre>

and you will get:

<pre><code>call: [a, b, c, a, b, c, a, b, c, a, b, c]
</code></pre>

I'm using Retrofit + RxJava on an Android app and am asking myself about how to handle the API pagination to chain calls until all data is being retrieved. Is something like this:

<pre><code>Observable&lt;ApiResponse&gt; getResults(@Query("page") int page);
</code></pre>

The ApiResponse object has a simple structure:

<pre><code>class ApiResponse {
 int current;
 Integer next;
 List&lt;ResponseObject&gt; results;
}
</code></pre>

The API will return a next value until is last page.

There's some good way to achieve this? Tried to combine some flatMaps(), but had no success.

Handle Paging with RxJava

我在一个安卓应用程序上使用Retrofit + RxJava，并问自己如何处理应用程序接口分页来链接调用，直到检索到所有数据。是这样的：Observable<ApiResponse> getResults(@Query("page") int page);ApiResponse对象有一个简单的结构：class ApiR...

问使用RxJava处理分页
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用RxJava处理分页EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问使用RxJava处理分页
EN