问题标签 [rx-android]

我看到的大多数 RxJava 示例都与网络调用有关。我是这个框架的新手，所以我想知道将它用于并行文件解析之类的东西是否也有意义。我有一个文件目录，我需要将其数据解析为 SQL 表。我可以用 RxJava 做到这一点吗？我希望它尽可能多线程以提高效率。

数据说明

我的数据有一个以一堆Sections开头的层次结构。每个Section包含一个或多个Subsection。每个小节包含一个或多个HTML文件。

SQL 表

--有一个引用sections 表的外键

--具有引用部分和子部分表的外键

_id字段是一个自动递增的主键（这不会每次都匹配序数）。subsections表依赖于接收其相关部分的主键。这意味着一旦插入第 1节，就可以插入第1a、1b、1c等节（但不能插入2a）

目录结构

每个 SQL 插入都可以使用 java builder 类构建，对于/1b-2.html ，它看起来像这样

我最终将有大约 50-60 个部分，但是整个部分的每个 SQL 插入、其子部分和它们的 HTML 文件都可以并行插入。使用 RxJava 对这样的事情有意义吗？

我想知道如何忽略异常并继续无限流（在我的情况下是位置流）？

我正在获取当前用户位置（使用Android-ReactiveLocation），然后将它们发送到我的 API（使用Retrofit）。

在我的情况下，当网络调用（例如超时）期间发生异常时，调用onError方法并且流自行停止。如何避免？

活动：

休息服务：

我想为内部使用 RxJava 的组件编写一种“黑盒测试”。

在内部，它使用Retrofitwhich 返回Observable一个 httpcall，然后它用于.flatmap() 将来处理从改造中检索到的数据。我们的想法是为该组件提供一个Transformer用于在观察者上设置调度程序的方法，如下所示：

我的组件做这样的事情：

在生产中，我DefaultTransformer作为参数传递，但是对于单元测试，我想提交一个Transformer在与单元测试相同的线程上运行的，所以一切都应该同步运行（而不是异步）。

我试过了：

但它仍然在我的单元测试中运行异步。我也试过了Scheduler.immediate()。toBlocking()似乎不是一个选项，因为它Observable不再是一个选项。知道有什么问题吗？

我有这样的任务：

getMessagesFromDb方法在哪里同步获取消息，内部没有多线程。根据 subscribeOn 方法的 RxAndroid 文档：

在指定的 Scheduler 上异步订阅 Observable 到这个 Observable

还有我的问题 - 为什么数据库请求在主线程上执行？如何异步执行？

我是 rxjava 的新手。我需要组合两个发出不同类型对象的可观察对象。像Observable<Milk>andObservable<Cereals>和得到一个Observable<CerealsWithMilk>. 我找不到这样的操作员。做这样的事情的 rx 方式是什么？请注意，MilkandCereals是异步的。

我想为android学习RXjava，所以我做了以下工作：

1) 我已经下载了 rxandroid-0.24.jar 、 rxandroid-framework-0.24.jar 的 jar 文件
2) 在 android studio 的 libs 文件夹中添加了文件
3) 将 lib 依赖添加到 android studio，请查看以下截图：

4) 在我的片段中尝试了一些代码，但似乎没有看到 rxandroid，请检查以下代码：

我正在使用本教程https://github.com/ReactiveX/RxJava/wiki/The-RxJava-Android-Module

谁能帮忙告诉我这里缺少什么？

我想使用 rxjava Observable 在 Retrofit 中处理分页。我听从了另一个问题的建议。

我有 100 多个页面需要获取，但链在第 20 页左右失败，并停止对可观察对象的任何进一步订阅，并在 logcat 中使用以下日志

有谁知道为什么会发生这种情况？

更新：我知道这是由于递归而发生的，但是有没有更优雅的方式来处理使用改造和 rxjava 的分页？

如何根据对象的一个​​或多个字段使用 rxjava 对一组对象进行排序？

上述解决方案有点工作，加载结果需要很长时间并且不一致。最后 3 次通话都取决于第一次通话中提供的信息。我在这里做错了什么？

我正在尝试将新对象注入可能存在的流中。

假设我有这个：

ItemUtils.java

在另一个班级：

每次不耐烦的用户按下按钮时，是否可以将项目注入一个独特的项目流？