为什么我的Kotlin Flow onCompletion从不运行？
Kotlin Flow是一种基于协程的异步流处理库，它提供了一种简洁、可组合的方式来处理异步数据流。在使用Kotlin Flow的过程中，我们可以使用onCompletion操作符来注册一个回调函数，以便在Flow完成时执行一些操作。
然而，如果你的onCompletion从不运行，可能有以下几个原因：
- Flow未完成：首先，需要确保Flow已经完成。Flow的完成是由上游发送了一个完成信号或者抛出了一个异常来触发的。如果Flow没有完成，
onCompletion回调函数将不会被执行。你可以通过在Flow的末尾使用collect操作符来触发Flow的完成，或者在Flow中使用catch操作符来捕获异常并处理。 - 未正确使用
onCompletion：确保你正确使用了onCompletion操作符。onCompletion应该在Flow的末尾调用，并且只能调用一次。如果你在Flow的中间或多次调用onCompletion，可能会导致回调函数不被执行。 - 协程作用域问题：
onCompletion回调函数是在Flow的末尾运行的，它依赖于协程的作用域。如果你的协程作用域在Flow完成之前就被取消了，onCompletion回调函数也不会被执行。确保你的协程作用域正确地包含了整个Flow的生命周期。
总结起来，如果你的Kotlin Flow的onCompletion从不运行，你需要确保Flow已经完成，正确使用了onCompletion操作符，并且协程作用域正确地包含了整个Flow的生命周期。如果问题仍然存在，可能需要进一步检查代码逻辑或提供更多的上下文信息来帮助定位问题。
腾讯云相关产品和产品介绍链接地址：
- 腾讯云官网：https://cloud.tencent.com/
- 云函数（Serverless）：https://cloud.tencent.com/product/scf
- 云数据库 TencentDB：https://cloud.tencent.com/product/cdb
- 云原生应用引擎 TKE：https://cloud.tencent.com/product/tke
- 人工智能平台 AI Lab：https://cloud.tencent.com/product/ai
- 物联网平台 IoT Hub：https://cloud.tencent.com/product/iothub
- 移动开发平台 MTA：https://cloud.tencent.com/product/mta
- 云存储 COS：https://cloud.tencent.com/product/cos
- 区块链服务 BaaS：https://cloud.tencent.com/product/baas
- 腾讯元宇宙：https://cloud.tencent.com/solution/metaverse
相关·内容
所以我有一个流，我需要它从缓存中发出一个值，但在结束时，它将发出一个API调用，以便在缓存中没有任何值的情况下拉取值(或刷新它拥有的值)。我在试这个 override val data: Flow<List<Data>> = dataDao.getAllCachedData() coroutineScopeis Data.Unknown } .filterNotNull()
.catch { emi
浏览 90提问于2021-04-02得票数 0
3回答
当我想在普通回调中使用Kotlin Flow时，我一直在寻找合适的解决方案或最佳实践。我的用例是，我在内部编写了一个使用kotlin Flow的Kotlin库，我必须假设用户将使用Java。所以我认为最好的解决方案是将一个基本的回调接口重载到我的flow方法中，并在collect中调用它，如下所示：
class
浏览 1提问于2020-03-10得票数 2
关于Flow的文档描述了为什么不应该在try/catch块中运行emit：与catch不同，此操作
浏览 2提问于2021-06-21得票数 2
回答已采纳
这就是我试图用Flow做的事情，我在onStart中展示了一个ProgressBar，并试图在onCompletion中隐藏ProgressBar。In ViewModel class appDatabase.eventDao().getAllEvents()返回Flow<List<EntityEvents> .map { Outcome.success(it) }
浏览 0提问于2020-01-23得票数 3
1回答
为什么？val flow: Flow<String> = ...var sum = 0
emit(it.toInt()) sum += it下面的测试演示了从不同线程调用collect {}主体：
val ctx =println(c) // prints 5_000_000
浏览 2提问于2022-01-23得票数 2
回答已采纳
我正在完成将类从RxJava重写到Coroutines的任务，并遇到了寻找ignoreElements()操作符类似的问题。在使用协同网络的情况下，什么可以取代它呢？ private fun observeHistory(): Completable = }
.ignoreEle
浏览 6提问于2022-08-26得票数 1
3回答
我正在开发一个全新的安卓应用程序，我想用Kotlin实现一个离线第一策略，就像我们使用RxJava一样。当我使用Rx时，我使用下面的代码作为离线第一功能。我使用下面的代码来实现同样的结果。private suspend fun getOfflineFirst(param: Param) = flow { .onCompletion此外，我在操场项目中使用了另一个
浏览 1提问于2020-07-24得票数 3
回答已采纳
我运行代码A并得到我预期的结果A，代码A中的所有发出操作都是一个接一个地启动的。我运行代码D并得到我预期的结果D，onStart{...}是在返回流之前启动的。但是onCompletion{
浏览 6提问于2022-04-04得票数 0
回答已采纳
1回答
我试图在我的类中保持一个可变的状态流，但是当我对它应用任何方法时，它将被转换为一个不可变的Flow<T> class MyClass : Listener<String> {
}.flowOn(MyDispatchers.b
浏览 23提问于2021-11-10得票数 1
回答已采纳
我想观察一下共同偏好的变化。下面是我如何使用Kotlin流来做这件事：interface DataSource {
// Trigger the flow and但这就是我</
浏览 1提问于2021-07-24得票数 0
回答已采纳
看着，我注意到了一些奇怪的事情： * Returns a flow containing the results of applying the given [transform] function为了测试这一点，我编写了一个试图模仿这种行为的小类： public fun transform (transform>
浏览 15提问于2021-12-28得票数 0
回答已采纳
更新协同1.3.0-RC@FlowPreview listener.onSomeResultoffer(result) }
listener.unsubscribe()}我有一个流发出多个字符串：suspend fun stre
浏览 0提问于2019-07-18得票数 52
回答已采纳
我有一个StateFlow协程，它在我的应用程序的不同部分之间共享。The StateFlow val songsRelay: Flow<List<Song>> by lazy {
MutableStateFlow<List<Song>?我可以完全删除job，然后调用coroutineScope.coroutineContext.cancelChildren()来达到同样的效果。我觉得如果不调用coro
浏览 15提问于2020-07-06得票数 10
回答已采纳
1回答
我不明白为什么Kotlin Flow reduce，fold函数有如下签名： initial: R,crossinline operat
浏览 2提问于2019-12-30得票数 1
2回答
期望的所需的功能类似于MutableLiveData的，它允许将数据添加到现有的MutableLiveData对象中。为了使用Kotlin实现相同的模式，将FeedViewState.kt中的FeedViewState.kt替换为Flow。在FeedViewModel.kt中，期望的结果是将数据添加到_feed流值中。尝试的解决方案一直在将
浏览 3提问于2020-03-10得票数 9
回答已采纳
如何使用OnCompletion listener播放一些音乐？我想按一个按钮转到另一个播放一些音乐的活动，然后在音乐回放结束后返回。我已经把其他东西都写好了。我就是想不通如何使用OnCompletion监听器？
浏览 2提问于2012-04-01得票数 29
回答已采纳
我正在尝试从RxJava切换到Kotlin Flow。Flow真的令人印象深刻。但是现在kotlin Flow中有没有类似于RxJava的"GroupBy“的运算符呢？
浏览 23提问于2019-10-30得票数 7
我在Kotlin中使用反应式编程，并尝试使用Flow作为Flux的等价物(具有挂起函数)Flow只有distinctUntilChanged (1 1 1 2 2 1 -> 1 2 1)，但是为什么没有distinct我遗漏了什么？// distinct
flow.toList().distinct(
浏览 1提问于2021-03-12得票数 5
当使用Kotlin流、Room和Live数据时，我面临着非常奇怪的行为。每当我关闭我的设备大约5-10秒，并打开它，协同工作的流量再次运行，没有任何触发。我不确定这是否是谷歌提供的功能。我的代码如下。trigger again将再次打印出来，当我关闭我的设备大约5-10秒，并打开它。另外，我用来测试的设备是运行
浏览 2提问于2020-02-27得票数 5
回答已采纳
我正在努力学习Kotlin Flow。当我试图添加您能看看我的依赖关系并帮助解决这个问题吗？apply plugin: 'com.android.application'
浏览 4提问于2019-12-04得票数 16
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
