如何在 RxJava/RxAndroid 中多次重复相同的网络请求(不同的参数)? [英] How to repeat same network request multiple times(different parameters) in RxJava/RxAndroid?

问题描述

所以，我有一个 /download API，它返回一个通用的 Object(基于索引号，它是它自己的参数)然后我必须将它保存到我的数据库，如果事务成功，我必须增加我的索引并再次重复相同的过程，否则retry().

So, I have a /download API which returns me a generic Object (based on an index number which is its own parameter) then I have to save it to my database, if the transaction is successful, I have to increase my index and repeat the same process again, otherwise retry().

我需要重复大约 50 次.

I'll need to repeat this for about 50 times.

我如何使用 Rx-Java 实现这个过程?我现在卡住了.任何帮助都是极好的.谢谢.

How can I achieve this process using Rx-Java? I'm stuck right now. Any help would be awesome. Thank You.

推荐答案

Observable.range(1, 50)
    .flatMap(index ->      // for every index make new request
        makeRequest(index) // this shall return Observable<Response>
            .retry(N)      // on error => retry this request N times
    )
    .subscribe(response -> saveToDb(response));

回复评论(仅在先前的回复保存到数据库后才发出新请求):

Answer to comment (make new request only after previous response is saved to db):

Observable.range(1, 50)
    .flatMap(index ->      // for every index make new request
        makeRequest(index) // this shall return Observable<Response>
            .retry(N)      // on error => retry this request N times
            .map(response -> saveToDb(response)), // save and report success
        1                  // limit concurrency to single request-save
    )
    .subscribe();

这篇关于如何在 RxJava/RxAndroid 中多次重复相同的网络请求(不同的参数)?的文章就介绍到这了，希望我们推荐的答案对大家有所帮助，也希望大家多多支持IT屋！