ViewModel 协程 flow 调用Room和网络数据的方式

Posted 2022-10-30 黄毛火烧雪下

ViewModel 调用数据的方式

@Query("SELECT * FROM pocketbook WHERE record_type = :type AND create_time >= :createTimeStart AND create_time <= :createTimeEnd ORDER BY id DESC")
fun getPocketbookListNew(type: String, createTimeStart: Long, createTimeEnd: Long): Flow<List<Pocketbook>>

1.升级前

 fun getPockBookListNew(
        type: String,
        createTimeStart: Long,
        createTimeEnd: Long
    ): Flow<List<Pocketbook>> 
        val cities = db.gePockBookDao().getPocketbookListNew(type, createTimeStart, createTimeEnd)
        return cities.catch  e -> e.printStackTrace() .flowOn(Dispatchers.IO)
    

2.升级后

ViewModel

 val loadStateOfPockBookList = MutableLiveData<List<Pocketbook>>()
  fun getPockBookListNew1(
        type: String,
        createTimeStart: Long,
        createTimeEnd: Long
    ) = launch 
        val cities = db.gePockBookDao().getPocketbookListNew(type, createTimeStart, createTimeEnd)
        cities.catch  e -> e.printStackTrace() .flowOn(Dispatchers.IO).collect 
            loadStateOfPockBookList.postValue(it)
        
    
    
Activity
noteBookVM.loadStateOfPockBookList.observe 
     mAdapter.setNewData(it)

@GET("/marketing/consumer/activities/invite")
suspend fun getInvite(): Response<InviteModel>


val loadStateOfInvite = MutableLiveData<InviteModel>()
fun getInvite1() = launch 
    flow 
         var model= activitiesService.getInvite().data
         emit(model)
    .flowOn(Dispatchers.IO).catch  e->e.printStackTrace() .collect 
         loadStateOfInvite.postValue(it)