Android Livedata与RxJava单不工作在房间数据库

Question

我在Livedata上使用了Room和RxJavaSingle，但它不起作用<我试了两种方法。我不知道为什么第二个有效，为什么第一个无效。

（1）按单条获取列表-

道

@Dao
interface DiaryDao {
    @Query("SELECT * FROM Review")
    fun getAllReview() : Single<List<Review>>    // <- See the return type!
}

ViewModel我使用了Repository模式（dao的返回类型和Repository的返回类型相同）

    private val _reviewData = MutableLiveData<List<Review>>()
    val reviewData : LiveData<List<Review>>
        get() = _reviewData

    fun getAllReview(){
        addDisposable(repo.getAllReview()
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe({
                _reviewData.value=it
            },{
                Log.d(TAG, it.localizedMessage)
            })
        )
    }

碎片

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        viewModel.getAllReview()
        viewModel.reviewData.observe(viewLifecycleOwner) {
            ...
        }
    }

它在创建片段时工作，但数据在更改时不更新。

道

@Dao
interface DiaryDao {
    @Query("SELECT * FROM Review")
    fun getAllReview() : LiveData<List<Review>>    // <- See the return type!
}

视图模型

    private val _reviewData : LiveData<List<Review>> = repo.getAllReview()
    val reviewData : LiveData<List<Review>>
        get() = _reviewData

碎片

    override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
        super.onViewCreated(view, savedInstanceState)
        viewModel.reviewData.observe(viewLifecycleOwner) {
            // it works!
        }

    }

当数据发生变化时，它工作得很好。

我期待你的建议。

请让我知道，如果有任何额外的代码，你想看到。

Answer 1

单身