2

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

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

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({ _ ->
             })
        }
    })
4

1 回答 1

6

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

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

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

于 2017-06-14T08:31:17.013 回答