Android ROOM LIVEDATA不发布结果

Question

嗨，我有一个项目的列表，我从数据源中检索，然后我在可观察的地图上应用，将数据存储到ROOM。

它设法将它添加到表中，但当我试图检索它的LiveData时，它似乎没有通知我的观察者结果。

有明确的数据在表中，我的查询工作，因为我改变了返回时间从LiveData到简单的列表，这工作得很好

这是我的数据类

@Entity
data class Item(
        @PrimaryKey
        val id:String,
        val title: String,
        val description: String,
        val imgUrl: String,
        val  usageRules : List<String>,

)

这是我的DAO，它公开了一个func，可以添加所有项目列表

@Dao
interface MyDao {

@Insert(onConflict = OnConflictStrategy.IGNORE)
    fun saveAllItems(itemList: MutableList<Item>)

       @Query("SELECT * FROM items")
    fun getAllItems(): LiveData<MutableList<Item>>

}

我的DB类

@Database(entities = arrayOf(Item::class), version = 1, exportSchema = false)
@TypeConverters(UsageRulesTypeConverter::class)
abstract class MyDatabase : RoomDatabase() {
    abstract fun getProductDao(): MyDao
}

以下是我如何将数据插入数据库：

@Inject
lateInt val database : MyDatabase

   override fun getAllItems(): Single<LiveData<MutableList<Item>>> {
     //retrieve new data using rertrofit
        networkController.getItems().map { responseItems ->
            saveAllItems(responseItems )
            getItems()
}

@Transaction
 fun saveAllItems(allItems: ItemsDataSource) {
    database.getProductDao().saveAllItems(allItems.loadedItems)
    database.getProductDao().saveAllItems(allItems.savedItems)
    database.getProductDao().saveAllItems(allItems.expiredItems)
    database.getProductDao().saveAllItems(allItems.unloadedItems)
}

fun getItems() : LiveData<MutableList<Item>>{

    return database.getProductDao().getAllItems()
}

我的数据源检索了4个项目列表，然后我将它们保存在一个实体/表中，但LiveData没有通知我的UI？

视图模型：

override fun getUnloadedOffers(): LiveData<MutableList<ProductOffer>> {
        if (!this::itemsLiveData.isInitialized) {
            itemsLiveData= MutableLiveData()
//get data from network or database
            itemDelegator.getItems()
                    .subscribeOn(Schedulers.io())
                    .observeOn(AndroidSchedulers.mainThread())
                    .subscribe({ items->
                        itemsLiveData= items

                    })
        }

        return itemsLiveData
    }

用户界面

viewModel = ViewModelProviders.of(this, viewModelFactory).get(MyViewModel::class.java)

     viewModel.getItems().observe(this, Observer {
                items->
                items?.let {
                    adapter = SomeAdapter(items)
                    itemsRecyclerView.adapter = adapter
                    adapter.notifyDataSetChanged()
                }

            })

Answer 1

保存数据收集时，尝试使用vararg而不是List。

@Insert(onConflict = OnConflictStrategy.IGNORE)
fun saveAllItems(vararg itemList: Item)

然后，您可以使用列表中的*（也称为扩展运算符）调用此方法，如下所示

saveAllItems(*responseItems.toTypedArray())

Answer 2

函数getUnloadedOffers（）是否返回空的可变列表？我不确定将items传递到itemslvedata是否有效，因为观察LiveData是在bg线程上运行的（如果我没弄错的话）