Room + RxJava2 无限循环案例

Question

我正在使用带有 RxJava2 的新 Android 持久性库 Room。以下代码导致无限循环。如果我在第二个 observable 中注释掉更新用户的行，它工作正常。如果我把它留在那里，第一个 observable 的 onNext 方法将被一次又一次地调用。

当实体更新时，Room 是否会重新查询表？如果是这样，为什么要在同一个流上再次发布消息？这是预期的行为吗？是图书馆的bug吗？

val userDao = HeyHeyApp.database.userDao();
userDao.getAll()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ listOfUsers ->
        if (!listOfUsers.isEmpty()) {
           HeyHeyApp.currentUser = listOfUsers.first()
           HeyHeyApp.currentUser.fcmDeviceId = getDeviceId()

           Single.fromCallable({
               HeyHeyApp.database.userDao()
                  .updateUser(HeyHeyApp.currentUser)
           }).subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
             .subscribe({ _ ->
             })
        }
    })

Answer 1

当您订阅 userDao.getAll() 事件时 - 每次更改数据库数据时，Room 都会触发您的观察者 onNext() 方法。接下来在 onNext() 方法中更改数据库中的数据：

 Single.fromCallable({
           HeyHeyApp.database.userDao()
              .updateUser(HeyHeyApp.currentUser)
       }).subscribeOn(Schedulers.io())
         .observeOn(AndroidSchedulers.mainThread())
         .subscribe({ _ ->
         }) 

在那个房间之后再次调用你的 onNext() 方法......等等。