开发者社区

文档建议反馈控制台

最新优惠活动

文章/答案/技术大牛

发布

为什么我的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

相关搜索:Kotlin:为什么即使我使用kotlin-maven插件，hibernate实体类也是最终的？为什么Flow会警告我，我返回的承诺已被揭开？为什么flow在我的.js.flow文件上看不到.random属性为什么当我使用background: url()时，我的图像从不显示？为什么我不能像rxJava.Single.create一样在Kotlin Flow中使用emit函数？为什么我不能在Kotlin中创建BigDecimal的扩展？为什么我不能用Kotlin写这个特殊的任务？为什么我无法正常运行我的.jar文件？(MacOS)为什么我的cookies不能运行PHP 为什么我的double for循环不能正确运行？

相关搜索:

页面内容是否对你有帮助？

有帮助

没帮助

相关·内容

Kotlin Coroutines Flow 系列(二) Flow VS RxJava2

Flow 跟 Sequences 之间的区别是 Flow 不会阻塞主线程的运行，而 Sequences 会阻塞主线程的运行。...Flow VS RxJava Kotlin 协程库的设计本身也参考了 RxJava ，下图展示了如何从 RxJava 迁移到 Kotlin 协程。...(火和冰形象地表示了 Hot、Cold Stream) migration from rxjava.jpeg 4.1 Cold Stream flow 的代码块只有调用 collected() 才开始运行...() -> Unit) = flow { collect { value -> emit(value) } action() } 它的使用类似于 onCompletion() fun...该系列的相关文章： Kotlin Coroutines Flow 系列(一) Flow 基本使用 Kotlin Coroutines Flow 系列(三) 异常处理

1K1 0

Google 推荐在 MVVM 架构中使用 Kotlin Flow

Kotlin Flow 是什么？ Kotlin Flow 解决了什么问题？ Kotlin Flow 如何在 MVVM 中使用?...Google 推荐在 MVVM 中使用 Kotlin Flow Google 推荐在 MVVM 中使用 Kotlin Flow我相信如今几乎所有的 Android 开发者至少都听过 MVVM 架构，在...项目也在逐渐切换到 Flow，为什么 Google 会推荐使用它呢，使用 Flow 能带来那些好处呢，为我们解决了什么问题 Kotlin Flow 是什么？...是对 Kotlin 协程的扩展，让我们可以像运行同步代码一样运行异步代码，使得代码更加简洁，提高了代码的可读性易于做单元测试 Kotlin Flow 如何在 MVVM 中使用 Jetpack 的视图模型...神奇宝贝 (PokemonGo) 基于 Jetpack + MVVM + Repository + Data Mapper + Kotlin Flow 的实战项目，我也正在为 PokemonGo 项目设计更多的场景

4.1K2 0

Kotlin Coroutines Flow 系列(三) 异常处理

5.1 catch 操作符上一篇文章Flow VS RxJava2曾讲述过 onCompletion 操作符。但是 onCompletion 不能捕获异常，只能用于判断是否有异常。...因此，onCompletion 操作符不再打印"Flow completed exceptionally" fun main() = runBlocking { flow { emit...Flow Lifecycle RxJava 的 do 操作符能够监听 Observables 的生命周期的各个阶段。...Flow 并没有多那么丰富的操作符来监听其生命周期的各个阶段，目前只有 onStart、onCompletion 来监听 Flow 的创建和结束。...: println("Completed $opName") } 该系列的相关文章： Kotlin Coroutines Flow 系列(一) Flow 基本使用 Kotlin Coroutines

1.8K2 0

即学即用Kotlin - 协程

Kotlin - 协程基础篇》《抽丝剥茧Kotlin - 协程Flow篇》目录一、基础 1....除了简单的用法外，这里有两个问题得注意一下： collect 函数是一个 suspend 方法，所以它必须发生在协程或者带有 suspend 的方法里面，这也是我为什么在一开始的时候启动了 lifecycleScope.launch...完成对比 Flow RxJava 完成 onCompletion onComplete Flow 中的 onCompletion 对应这 RxJava 中的 onComplete 回调，onCompletion...我将会在下一篇文章中和大家讨论协程的原理，欢迎大家关注。学习协程和 kotlin 还是很有必要的，我们团队在开发新的功能的时候，也全部选择了 Kotlin。...参考文章： “《最全面的Kotlin协程: Coroutine/Channel/Flow 以及实际应用》《Kotlin中文站》《Kotlin 的协程用力瞥一眼》

1.5K2 0

Kotlin 学习笔记（五）—— Flow 数据流学习实践指北（一）

“最近马斯克收购了推特之后，马上就裁掉了 50% 的推特员工，这不禁让我想起了灭霸的响指......catch、onCompletion 等操作符去处理执行的结果。...，不满足则交给它的尾调函数处理，并且抛出异常； 3）onCompletion ：Flow 最后的兜底器。...无论 Flow 最后是执行完成、被取消、抛出异常，都会走到 onCompletion 操作符中，类似于在 Flow 的 collect 函数外加了个 try，finally。...参考文献 Android 上的 Kotlin 数据流；官方文档 https://developer.android.com/kotlin/flow Flow Kotlin 官方文档； https:/

1.5K1 0

BI为什么我的查询运行多次？

如果查询由一个或多个其他查询引用，则独立计算每个查询（以及它依赖的所有查询）。在桌面环境中，使用单个共享缓存运行数据模型中所有表的单个刷新。...Caching可以减少对同一数据源的多个请求的可能性，因为一个查询可以受益于已针对其他查询运行和缓存的相同请求。...不过，即使在此处，也可以获取多个请求，因为数据源未缓存 (例如本地 CSV 文件) ，因此对数据源的请求不同于由于下游操作 (可以更改折叠) 而缓存的请求，缓存太小 (相对不太可能) ，或因为查询大致同时运行...在云环境中，每个查询都使用自己的单独缓存进行刷新，因此查询无法受益于已为其他查询缓存的相同请求。折叠有时，Power Query的折叠层可能会根据正在下游执行的操作生成对数据源的多个请求。...如果计算零行架构需要提取数据，则可能会出现重复的数据源请求。数据隐私分析数据隐私对每个查询进行自己的评估，以确定查询是否安全运行在一起。此评估有时可能会导致对数据源发出多个请求。

5.5K1 0

【Kotlin 协程】Flow 异步流 ③ ( 冷流 | 流被收集时运行 | 流的连续性 )

文章目录一、冷流 ( 流被收集时运行 ) 二、流的连续性一、冷流 ( 流被收集时运行 ) ---- Flow 异步流的构建器函数 flow 函数中的代码 , 在调用 Flow#collect...函数时 , 也就是在 Flow 异步流收集元素时 , 才会执行 flow 构建器中的代码 ; 这种机制的异步流称为冷流 ; 代码示例 : 在 flow 构建器的开始位置 , 发射元素 ,...在主线程中 Flow#collect 收集元素位置 , 添加日志信息 , 查看日志打印的时机 ; package kim.hsl.coroutine import android.os.Bundle...---- Flow 流的每次调用 Flow#collect 收集元素的操作 , 都是按照固定顺序执行的 , 使用特殊操作符可以改变该顺序 ; Flow 异步流中的元素 , 按照顺序进行...FlowCollector#emit 发射操作 , 则调用 Flow#collect 收集元素时获取的元素也是按照顺序获取的 ; 在流的上游到下游发射元素的过程中 , 会使用过渡操作符

5072 0

再谈协程之第三者Flow基础档案

Flow作为一套异步数据流框架，几乎可以约等于RxJava，但借助Kotlin语法糖和协程，以及Kotlin的DSL语法，可以让Flow的写法变得异常简洁，让你直面人性最善良的地方，一切的黑暗和丑陋，都被编译器消化了...❝末端操作符都是suspend函数，所以需要运行在协程作用域中。...onStart：在上游生产数据前调用 onCompletion：在流完成或者取消时调用 onEach：在上游每次emit前调用 onEmpty：流中未产生任何数据时调用 catch：对上游中的异常进行捕获...❞ Flow的同步非阻塞模型首先，我们要理解下，什么叫同步非阻塞，默认场景下，Flow在没有切换线程的时候，运行在协程作用域指定的线程，这就是同步，那么非阻塞又是什么呢？...向大家推荐下我的网站 https://xuyisheng.top/ 点击原文一键直达专注 Android-Kotlin-Flutter 欢迎大家访问

5641 0

Android面试题之Kotlin异步流、冷流Flow

不再有suspend修饰符流使用emit函数发射值，使用collect函数收集值冷流 Flow是一种类似于序列的冷流，flow构建器中的代码直到流被收集的时候才运行（调用collect的时候）调用...) if (value == 3){ cancel() } } } 背压与处理背压：生产者效率大于消费者效率 buffer()，并发运行流中发射元素的代码...} .reduce{a,b -> a+b} //输出55 println(sum) } 组合操作符就像kotlin标准库中的sequence.zip扩展函数一样，流拥有一个...当流收集完成时（普通情况或异常情况），它可能需要执行一个动作命令式finally块 onCompletion声明式处理，onCompletion还能拿到异常信息，但是不能捕获异常，同时能获取上游异常信息和下游异常信息...@Test fun `test flow exception onCompletion`() = runBlocking { flow { emit(1)

791 0

【Kotlin 协程】Flow 流收尾工作 ( finally 代码块收尾 | onCompletion 代码块收尾 | onCompletion 中获取异常信息 | catch 代码块中捕获异常 )

文章目录一、Flow 流收尾工作二、onCompletion 函数原型三、finally 代码块收尾四、onCompletion 代码块收尾五、onCompletion 代码块中获取异常信息...时 , 如果是因为异常导致 Flow 流收集元素失败 , 则可以在 onCompletion 代码块中拿到异常信息 ; 二、onCompletion 函数原型 ---- onCompletion...(it) } // prints a, b, c, Done * ``` * * 在失败或取消的情况下，任何发出额外元素的尝试都会引发相应的异常。...$onCreate$1.invokeSuspend(MainActivity.kt:38) at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith...PID: 29378 SIG: 9 六、catch 代码块中捕获异常 ---- 上面章节中介绍了在 Flow#onCompletion 中可以执行收尾 , 同时可以查看出现的异常 , 但是无法捕获处理异常

5862 0

Kotlin 学习笔记（七）—— Flow 数据流学习实践指北（三）冷流转热流以及代码实例

人大又要召开了，真心希望这一届的委员们能够提一些靠谱的提案，也不枉我上周网购的商品这周还没到北京了··· 前一节（Kotlin 学习笔记（六）—— Flow 数据流学习实践指北（二）StateFlow...那为什么需要将冷流转化为热流呢？假如有这么一个场景：一开始有一个冷流 coldFlow 和它对应的消费者，后来下游又有几个新来的消费者需要使用这个 coldFlow，并且还需要之前已发送过的数据。...StateFlow 代码实战说了这么多 Flow 的东西，最后以一个实际的例子结束这一章节的学习笔记吧！下面我将用一个应用实例来讲解 StateFlow 的实际应用。...flatMapLatest 操作符我看的代码版本这个操作符还是实验性api，后续可能被移除。...参考文献 StateFlow 和 SharedFlow 官方文档 https://developer.android.google.cn/kotlin/flow/stateflow-and-sharedflow

1.3K4 0

Kotlin协程知识累计

修饰只是提醒kotlin这一块是一个耗时操作，避免卡顿。...6、Flow流：是冷流，就是 Kotlin 协程与响应式编程模型结合的产物，你会发现它与 RxJava 非常像，用于替代RxJava。...2.Flow通过flowOn改变数据发射的线程，数据消费线程则由协程所在线程决定 3.与RxJava类似,支持通过catch捕获异常,通过onCompletion 回调完成 4.Flow没有提供取消方法...) } }.flowOn(Dispatchers.Main)//上游流所运行线程 .catch { //异常处理 } .onCompletion { //完成回调 } .collect...所以更为准确的说法是为什么我们使用发送消息的方式来同步信息，而不是多个线程或者协程直接共享内存？

1911 0

优雅实现网络请求：协程+Flow+Retrofit+OkHttp

一、Kotlin协程与Flow Kotlin协程是Kotlin提供的一种轻量级线程管理方式。它可以让我们用同步的方式写异步代码，使得代码更加简洁、易读。...使用协程和Flow，我们可以将网络请求抽象为一个数据流，用一个简单的函数来描述网络请求的过程。 1.1 Flow的用法 Flow是Kotlin提供的一种响应式流处理库，用于处理异步、时间相关的操作。...(anotherFlow) { a, b -> a + b } 异常处理：使用catch、onCompletion等操作符处理Flow中的异常。...Flow的实现主要依赖于Kotlin的协程库，特别是kotlinx.coroutines.flow包中的相关类和函数。...组合操作符：如combine、zip等，用于将多个Flow组合在一起。异常处理操作符：如catch、onCompletion等，用于处理Flow中的异常。

551 0

Coroutine（协程）（二）

的代码与先前示例的下述区别：名为 flow 的 Flow 类型构建器函数。...以下示例展示了当 withTimeoutOrNull 块中代码在运行的时候流是如何在超时的情况下取消并停止执行其代码的： fun simple(): Flow = flow { for...通常，withContext 用于在 Kotlin 协程中改变代码的上下文，但是 flow {...}...这种方式大约花费了 1000 毫秒来运行： 13.处理最新值collectLatest 当发射器和收集器都很慢的时候，合并是加快处理速度的一种方式。它通过删除发射值来实现。...onCompletion 能观察到所有异常并且仅在上游流成功完成（没有取消或失败）的情况下接收一个 null 异常。

5481 0

手把手教你搭建android模块化项目框架（四）network网络库封装

client(provideOkHttpClient()) .baseUrl(BASE_URL)//这里我们不使用gsonconvertadapter,我们先都取String,后续我们再说为什么...，然后利用请求的各种参数进包裹后，使用固定的apiService进行请求。...body: MutableMap): MutableMap { return body }}上述常规封装完成，下面开始优化，我们使用kotlin...，便于操作//这里我们不处理异常，异常正常抛出即可，接下来通过flow的操作符进行异常处理inline fun Repo.toFlow() = flow...后，我们通过flow操作符进行操作，并处理异常。

3353 0

【译】LiveData with Coroutines and Flow

这个系列我做了协程和Flow开发者的一系列文章的翻译，旨在了解当前协程、Flow、LiveData这样设计的原因，从设计者的角度，发现他们的问题，以及如何解决这些问题，pls enjoy it。...它们只运行一次，可以返回一个结果返回多个值的操作。...调用它们是运行非阻塞操作的一种非常方便的方法。...Kotlin的Flow（警告：有些部分仍在试验中）。...(我不知道你为什么要使用不可取消的版本，但请在评论中告诉我！)

1.4K1 0

【Kotlin 协程】Flow 异步流 ⑥ ( 调用 Flow#launchIn 函数指定流收集协程 | 通过取消流收集所在的协程取消流 )

#launchIn 函数指定流收集协程 ---- 1、指定流收集协程响应式编程 , 是基于事件驱动的 , 在 Flow 流中会产生源源不断的事件 , 就是发射元素操作 ; 拿到 Flow 流后..., 开始收集元素 , 按照顺序逐个处理产生的事件 ( 元素 ) ; 调用 Flow#launchIn 函数 , 传入协程作用域作为参数 , 可以指定收集 Flow 流元素的协程 ; 在上一篇博客...【Kotlin 协程】Flow 异步流 ⑤ 中 , 调用 Flow#flowOn 函数 , 可以指定 Flow 流发射元素的协程 ; Flow#launchIn 函数返回值是 Job 对象 ,...* * 此操作符通常与[onEach]， [onCompletion]和[catch]操作符一起使用，以处理所有发出的值 * 处理上游流或处理过程中可能发生的异常，例如: * * ``` *...flow * .onEach { value -> updateUi(value) } * .onCompletion { cause -> updateUi(if (cause =

7702 0

为什么我的 Mac 运行缓慢以及如何使用CleanMyMac X修复它

在本文中，我们将解释 MacBook 运行缓慢的原因，并为您提供十个神奇的修复方法，让您的 MacBook 恢复速度。开始吧！ 为什么 Mac 运行缓慢？浏览器对内存的要求越来越高。...10 种有保证的解决方案，可加快慢速 Mac 的运行速度 1.后台运行过多如果您的 Mac 无法再处理简单的任务，并且您想找到“为什么我的 Mac 这么慢？”...如果您在完成上述工作后仍然问为什么我的 MacBook 这么慢，请确保您的 Mac 已安装所有最新更新。 4....我们所有人都会下载一开始看起来有用且令人兴奋的应用程序，但结果却使我们的磁盘变得杂乱无章，而不是经常使用。快速修复：卸载未使用的应用程序回答“为什么我的 iMac 这么慢？”...这就是为什么最好使用CleanMyMac X等工具清除设备上的残留物。它的卸载程序模块显示您有多少应用程序，并方便地将所有剩余应用程序收集在一个选项卡中。

2.7K3 0

有小伙伴说看不懂 LiveData、Flow、Channel，跟我走

Kotlin Flow 是基于 Kotlin 协程基础能力搭建的一套数据流框架，从功能复杂性上看是介于 LiveData 和 RxJava 之间的解决方案。...Kotlin Flow 拥有比 LiveData 更丰富的能力，但裁剪了 RxJava 大量复杂的操作符，做得更加精简。...并且在 Kotlin 协程的加持下，Kotlin Flow 目前是 Google 主推的数据流框架。 1. 为什么要使用 Flow？...LiveData、Kotlin Flow 和 RxJava 三者都属于可观察的数据容器类，观察者模式是它们相同的基本设计模式，那么相对于其他两者，Kotlin Flow 的优势是什么呢？...根据生产方产生数据的时机，可以将 Kotlin Flow 分为冷流和热流两种：普通 Flow（冷流）：冷流是不共享的，也没有缓存机制。

2.2K1 0

kotlin--Flow的运用

Flow是kotlin提供的一个工具，使用协程封装成生产者-消费者模式，上流来负责生产，下流来接收消耗。...一、Flow的使用 1.Flow的创建 1.可以使用flow构建函数构建一个Flow类型返回值的函数 2.flow{}构建体中可以调用挂起函数，即上流 3.上流使用emit函数发射值 4.下流使用...的取消 Flow的取消和协程的取消相同，流的收集是CPU密集型的，但是如果收集时有挂起函数，那么挂起函数可以抛出取消异常来中断执行使用了新协程的情况，可以使用cancel： fun main() {...的取消检测之前我们调用子协程的取消时，CPU密集型代码并不能结束运行，在不使用挂起函数的情况下，我们在子协程体中通过ensureActive函数来检测该协程是否被取消了 1.而Flow为了方便，Flow...emit(i) } }.onCompletion { println("done") }.collect {

6282 0

点击加载更多

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云

扫码加入开发者社群

相关资讯

热门标签

活动推荐

运营活动

活动名称

广告关闭