- android - 多次调用 OnPrimaryClipChangedListener
- android - 无法更新 RecyclerView 中的 TextView 字段
- android.database.CursorIndexOutOfBoundsException : Index 0 requested, 光标大小为 0
- android - 使用 AppCompat 时,我们是否需要明确指定其 UI 组件(Spinner、EditText)颜色
我将 RxJava2 与 Room SQLite 结合使用。我的道:
@Dao
public interface HeroDao {
@Insert
long create(Hero hero);
}
这就是我在 RxJava2 中使用它的方式:
Observable.just((int) heroDao.create(hero))
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(id -> /** do stuff **/);
但是当我运行该应用程序时,我在 Logcat 中遇到的错误是无法访问主线程上的数据库,因为它可能会长时间锁定 UI。
我已经尝试附加.allowMainThreadQueries()
到数据库构建器,然后插入通过,从而确认我的可观察对象的正确性。看来 LiveData 和 AsyncTasks 是我可以尝试的其他方法,但我宁愿不去那里,因为我已经对 RxJava2 进行了认真的投资。
那么为什么我会收到该错误? subscribeOn(Schedulers.io())
是否足以从主线程卸载工作?否则我该如何做到这一点?似乎有一些关于将 Room 查询转换为我缺少的可观察对象的微妙之处?
最佳答案
因为你用了Observable.just
.此方法只是将对象包装到 Observable
中,因此它是在实际订阅之前创建的,并调用 heroDao.create(hero)
在主线程上。你应该使用 Observable.fromCallable()
,或者更喜欢 Single.fromCallable
.您也可以在 DAO 中定义方法,例如 @Insert Single<Int> create(Hero hero);
有些链接可能有用:
Doing queries in Room with RxJava
7 Pro-tips for Room
关于android - subscribeOn() 没有离开主线程,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/48714230/
任何人都可以看一下下面的代码并让我知道为什么它的行为不同: package com.example.rxjava; import rx.Observable; import rx.functions.
我正在自学响应式编程,方法是解决随机问题并毫不羞愧地问愚蠢的新手问题。在弄清楚线程调度的工作原理时,我设法难住了自己。虽然我很确定这段代码没有逻辑意义,但我也无法理解发生了什么。弄清楚这一点可能会帮助
我将 RxJava2 与 Room SQLite 结合使用。我的道: @Dao public interface HeroDao { @Insert long create(Hero
我是 RxJava 的新手,我正在尝试使用 RxJava 进行 Retrofit 调用。当我在 SubscribeOn 上编写这段代码时,它说“无法解析方法 SubscribeOn(io.reacti
我的这个测试基于 4.5.2. The subscribeOn Method (忽略缺少的 new Thread(...) 部分): @Test public void theSubs
为什么subscribe在这里从不打印任何内容?只是出于好奇。无论如何,这是一个坏习惯,我会改用observeOn,但是我无法弄清楚为什么从来没有达到subscribe ... fun main()
嗨,我有一个简单的问题,假设我有一个如下所示的类(class): import lombok.Value; import java.nio.file.Path; @Value class ImageR
我正在将 AsyncTaskLoader 迁移到 RxJava,试图了解有关 RxJava 并发方法的所有细节。简单的事情运行正常,但是我在处理以下代码时遇到了困难: 这是执行的顶级方法: mComp
我想知道当我们在 RxJava 链中有多个 subscribeOn() 方法时会发生什么。例如,如果我有一个像这样的链, Single.fromCallable { repository.ap
我想知道在 Subject 上调用 subscribeOn() 会产生什么后果。 我知道(默认情况下)这不会改变发射的线程项目,我只是好奇它是否会导致其他一些负面影响。 一般来说,从不同的线程调用同一
我刚刚发现了 SubscribeOn,这让我想知道我是否应该使用它而不是 ObserveOn。谷歌带了我here和 here ,但两者都没有帮助我理解差异:它看起来非常微妙。 (在我的上下文中,我在非
我在使用 RxJava concat 运算符时遇到问题。我有两个可观察对象,第一个从服务器数据库发出结果,另一个从本地数据库发出结果,然后我连接: // Uses a Realm in the UI
基于阅读这个问题:What's the difference between SubscribeOn and ObserveOnObserveOn 设置代码在 Subscribe 处理程序中的位置被执
在强制执行 Observable.create 的某部分时代码在特定线程(即后台线程)中运行,我担心使用 subscribeOn运算符可能不起作用,因为有时我可能会将此可观察序列链接到另一个在主线程上
我对在可观察对象上调用 subscribeOn 和 observeOn 方法的顺序有点困惑。我读了几篇文章,一个人说没关系,只是在他的例子中使用了东西,其他人说这很重要。所以这是我的问题: 例如: s
Scheduling and Threading Intro to Rx 部分说 the use of SubscribeOn and ObserveOn should only be invoked
也许我只是真正了解 subscribeOn 和 observeOn 的内部工作原理,但我最近遇到了一些非常奇怪的事情。我的印象是,subscribeOn 决定了调度程序最初开始处理的位置(特别是当我们
我正在尝试使用 Retrofit 和 RxJava 从 api 获取列表并显示在 recyclerview 中。 我使用了下面的代码- ApiInterface apiService =
我在普通的 JDK 8 上。我有这个简单的 RxJava 示例: Observable .from(Arrays.asList("one", "two", "three")) .doOnNext(wo
我遇到了一个问题,我的可观察对象在 IO 线程上订阅并在 android 主 (UI) 线程上观察,但 doFinally 运算符在 IO 线程上运行,它需要在 UI 线程上运行。 用例几乎和这个me
我是一名优秀的程序员,十分优秀!