android - 将 Koltin Flow 与 LiveData 一起使用时未调用 onCompletion

Question

这就是我试图用 Flow 做的事情, 我正在展示 ProgressBar在onStart并试图隐藏 ProgressBar在onCompletion .

在 ViewModel 类中 appDatabase.eventDao().getAllEvents()返回 Flow<List<EntityEvents>

@ExperimentalCoroutinesApi
val allEvents: LiveData<Outcome<List<Event>>> = _fetchEvents.switchMap { _ ->
    appDatabase.eventDao().getAllEvents()
        .map { eventListMapper.map(it) }
        .map { sortEventsBasedOnPreference(it) }
        .flowOn(Dispatchers.IO)
        .map { Outcome.success(it) }
        .onStart { emitLoading(true) }
        .onCompletion { emitLoading(false) }
        .catch { emitFailure(it, R.string.err_something_wrong) }
        .asLiveData(context = viewModelScope.coroutineContext)
}

一切正常，我无法弄清楚为什么是 onCompletion任务完成时不调用？

Answer 1

如果 appDatabase.eventDao().getAllEvents() 基于 Room on Flow，则从不调用 onCompletion()。

为什么？

因为 getAllXXX() 查询是“热门”。 实际上，查询并没有完成。仅发出数据。

当数据发生变化时，查询将再次发出数据。