android – 使用RxJava和Retrofit来迭代列表,并根据子查询增加结果

概述我正在使用改装,我觉得像rx java(具有retrolambda)将适合以下流程： >获取小部件列表(http) >为每个小部件 a)获取指定窗口小部件类型的文章(http)列表 b)将所有这些保存到db c)使用列表中的第一个(最新)文章,并使用本文中适当的值更新widget.articleName和widget.articleUrl >转换回列表并完成 不过,我不确定在步骤2a后该怎么做.这 我正在使用改装,我觉得像rx java(具有retrolambda)将适合以下流程：

>获取小部件列表(http)
>为每个小部件

a)获取指定窗口小部件类型的文章(http)列表
b)将所有这些保存到db
c)使用列表中的第一个(最新)文章,并使用本文中适当的值更新@R_404_5537@.articlename和@R_404_5537@.articleUrl
>转换回列表并完成

不过,我不确定在步骤2a后该怎么做.这是我的代码到目前为止

APIService.get@R_404_5537@s(token)  .flatMAPIterable(@R_404_5537@s -> @R_404_5537@s)  .flatMap(@R_404_5537@ -> APIService.getArticles(token,@R_404_5537@.type))  ...  .toList()  .subscribe(     modifIEd@R_404_5537@s -> save@R_404_5537@s(modifIEd@R_404_5537@s),throwable -> process@R_404_5537@Error(throwable)  );

我已经玩了一些 *** 作符,但是在链接的时候,我总是似乎缩小了
太远(例如,单个文章处理),然后再无法访问
原创小部件进行修改.

@GET("/@R_404_5537@s")Observable<List<@R_404_5537@>> get@R_404_5537@s(@header("Authorization") String token);@GET("/articles")Observable<List<Article>> getArticles(@header("Authorization") String token,@query("type") String type);

解决方法 您可以在流的某些点插入doOnNext以添加副作用：

APIService.get@R_404_5537@s(token).flatMAPIterable(v -> v).flatMap(w ->     APIService.getArticles(token,w.type)    .flatMAPIterable(a -> a)    .doOnNext(a -> db.insert(a))    .doOnNext(a -> {         w.articlename = a.name;         w.articleUrl = a.url;    })    .takeLast(1)    .map(a -> w)).toList().subscribe(    modifIEd@R_404_5537@s -> save@R_404_5537@s(modifIEd@R_404_5537@s),throwable -> process@R_404_5537@Error(throwable));

Here is可运行的例子.

总结

以上是内存溢出为你收集整理的android – 使用RxJava和Retrofit来迭代列表,并根据子查询增加结果全部内容，希望文章能够帮你解决android – 使用RxJava和Retrofit来迭代列表,并根据子查询增加结果所遇到的程序开发问题。

如果觉得内存溢出网站内容还不错，欢迎将内存溢出网站推荐给程序员好友。