Kotlin Flow 基础
发出并收集数据流
Kotlin Flow 基础 是 CoddyKit 上的免费 Android Academy 课时。 这是第 3 节课,共 4 节。 你可以在下方免费阅读本课时的完整内容 — 然后在浏览器中使用内置代码编辑器和全天候 AI 导师进行实践。 这是 Android Academy 学习路径的一部分,你的进度在网页和 CoddyKit 应用中同步。 Android Academy 课程共包含 4 节课。
什么是 Flow?
Flow 是一种异步流,会随着时间推移发出多个值。您可以将它理解为一种可挂起、可转换和收集的序列。
构建 Flow
flow { } 构建器允许您使用 emit 发出值,也可以选择在值之间进行挂起。
fun numbers(): Flow<Int> = flow {
for (i in 1..3) {
delay(100)
emit(i)
}
}收集 Flow
在您收集 Flow 之前,它不会执行任何操作。收集是一项挂起操作,因此会在协程中运行。
scope.launch {
numbers().collect { value ->
println(value)
}
}冷流
Flow 是冷流:每个收集者都会重新执行构建器代码块。两个收集者都会从头开始获得各自独立的序列。
使用 map 和 filter 进行转换
运算符会惰性地转换发出的值,只有在收集时才会运行。
numbers()
.map { it * 10 }
.filter { it > 10 }
.collect { println(it) }更多运算符
take(n)— 只获取前 n 个值。onEach— 对每个值执行副作用。distinctUntilChanged— 跳过重复值。
处理错误
使用 catch 运算符捕获上游异常。
numbers()
.map { riskyTransform(it) }
.catch { e -> emit(-1) }
.collect { println(it) }响应完成
使用 onCompletion 在 Flow 完成或被取消时运行代码。
numbers()
.onCompletion { println("done") }
.collect { println(it) }更改生产者线程
使用 flowOn 在指定调度器上运行上游,而不会影响收集者。
fun load(): Flow<Data> = flow {
emit(readFromDisk())
}.flowOn(Dispatchers.IO)终止运算符
有些运算符会结束 Flow 并返回一个值,例如 toList、first 或 reduce。它们都是挂起函数。
val all: List<Int> = numbers().toList()Flow 在 Android 中的应用场景
Flow 可以表示任何随时间发出数据的内容:数据库变化(Room)、位置更新、边输入边搜索,以及多个数据源的组合。
快速检查
测试您对 Flow 基础知识的理解。
回顾
您学会了:
flow { emit(...) }用于构建异步流。- Flow 是冷流,只有在收集时才会运行。
- 使用
map/filter进行转换,使用catch处理错误。 flowOn用于设置生产者调度器。
常见问题解答
「Kotlin Flow 基础」课时是免费的吗?
是的 — 「Kotlin Flow 基础」的完整文本可在网页上免费阅读。要进行交互式练习(内置代码编辑器和全天候 AI 导师)并解锁 Android Academy 课程的其余内容,请升级到 CoddyKit PRO。 Android Academy 课程共包含 4 节课。
「Kotlin Flow 基础」这节课中我会学到什么?
发出并收集数据流 你通过在浏览器中直接运行的动手代码来练习 Android Academy,全天候 AI 导师会在你学习这节课的过程中回答你的问题。
学习 Android Academy 需要有经验吗?
无需任何先前经验。CoddyKit 上的 Android Academy 课程适合初学者到高级学习者,你可以从这里开始或从头开始,按照自己的节奏学习。 这是第 3 节课,共 4 节。
「Kotlin Flow 基础」课时需要多长时间?
大多数 CoddyKit 课程大约需要 5–10 分钟。每节课都很精短且互动,所以你能稳步进步,并在网页和应用中从离开的地方继续。
我能在这节 Android Academy 课中编写并运行代码吗?
能。每节 Android Academy 课都包含内置代码编辑器,你可以在浏览器中直接编写并运行真实代码,并获得即时 AI 反馈 — 无需本地设置。
此课程中的所有课时
- 协程基础和作用域
- viewModelScope 和调度器
- Kotlin Flow 基础
- StateFlow 和 SharedFlow