Android 如何在 flow.stateIn() 之后从流中的另一个函数发出emits

发布于05月31日

我从数据库中获取页面数据，我有一个返回流的存储库.

class RepositoryImpl (private val db: AppDatabase) : Repository {

    override fun fetchData (page: Int) = flow {
        emit(db.getData(page))
    }
}

在ViewModel中，我调用stateIn()，第一个页面到达，但是如何请求第二个页面呢？通过调用fetchData(第2页)，我得到了一个新的流，我需要数据到达旧的流.

class ViewModel(private val repository: Repository) : ViewModel() {

    val dataFlow = repository.fetchData(page = 1).stateIn(viewModelScope, WhileSubscribed())
}

如何获取数据流中的第二页？

推荐答案

如果您只发出一个值，我看不出在存储库中使用流的原因.我将其更改为suspend函数，在ViewModel中，我将用新值更新MutableStateFlow类型的变量.示例代码可能如下所示:

class RepositoryImpl (private val db: AppDatabase) : Repository {

    override suspend fun fetchData (page: Int): List<Data> {
        return db.getData(page)
    }
}

class ViewModel(private val repository: Repository) : ViewModel() {

    val _dataFlow = MutableStateFlow<List<Data>>(emptyList())
    val dataFlow = _dataFlow.asStateFlow()

    fun fetchData (page: Int): List<Data> {
        viewModelScope.launch {
            _dataFlow.value = repository.fetchData(page) 
        }
    }    
}