一、简单用法

Flow 概述

Flow 是 Kotlin 协程库中用于处理异步数据流的 API。类似于 RxJava 的 Observable，但更轻量且与协程深度集成。

主要特点这方面。

• 冷流 ：使用者触发时才执行，避免不必要的资源使用情况。
• 基于协程天然支持挂起函数，使用上更直观。
• 响应式编程支持函数式操作符，链式组合简洁。
• 结构化并发自动取消和资源清理，减少内存泄漏风险。

至于常见痛点，

• 误解冷流为热流导致多次网络请求或重复计算。
• 未正确使用collect导致协程被挂起而不释放资源。

. Flow 的创建

val flow1 = flow {
for {
delay // 挂起函数
emit // 发射值
}
}
val flow2 = listOf.asFlow
val flow3 = .asFlow
val flow4 = flowOf
val flow5 = channelFlow {
send
withContext {
send
}
}

说到常见痛点。

• `channelFlow` 与 `flow {}` 的区别不清晰，导致错误地在 `flow {}` 内使用 `withContext`。

. Flow 操作符

. 中间操作符

flow.map { it * it } // 转换
flow.filter { it> 5 } // 过滤
flow.transform { value ->
emit
emit
}
flow.take // 限长
flow.takeWhile { it <= 10 }            // 条件取
// 合并操作
val combined = flowA.zip { a, b -> "$a -> $b" }
combined.combine { a,b -> "$a - $b" }
// 展平操作
flatMapConcat { value ->
flowOf
}
flatMapMerge { value ->
flow {
delay
emit
}
}
flatMapLatest { value ->
flow {
delay
emit
}
}

. 常见痛点：

• `transform` 与 `map` 混用导致意外的多次发射。
• `takeWhile` 用错条件导致提前终止收集。

. Terminal Operators

flow.collect { value -> println } // 收集值
val list = flow.toList // 转换为集合
val set = flow.toSet // 转换为 Set
// 聚合操作
val sum = flow.reduce { acc,value -> acc + value }
val sum2 = flow.fold { acc。v -> acc + v }
// 单个值获取
val first = flow.first
val firstOrNull = flow.firstOrNull
val single = flow.single // 确保只有一个值
//计数
val countVal = flow.count

. 常见痛点：

• `single` 在流为空时抛出异常，应先检查长度或使用 `firstOrNull`。
• `toList` 等收集终端会阻塞整个协程，如果数据量大需慎用。怎么说呢，

. 异常处理

// catch 操作符捕获上游异常，只能放在需要的位置
flow.catch { cause ->
println
emit // 发射备用值
}.collect { v -> println }
// 声明式异常处理 onCompletion 可捕获完整流程结束状态
flow.onCompletion { cause ->
if {
println
} else {
println
}
}
// 多层捕获示例。仅捕获上游异常，不影响下游逻辑
flow.map{ it * it }.catch{ e -> /* 上游错误 */ }.collect{ v ->
try{
println
}catch{
/* 下游错误 */
}
}

. 常见痛点：

• catch 放在错误位置会导致无效，需在需要捕获的上游链段前置。
• onCompletion 捕获不到下游异常，需要配合 catch 使用。
• emit 在 catch 块内若未返回值可能导致后续消费卡住。

说到注意。在 Flow 中所有异常都必须明确定位，否则可能被吞掉或导致协程崩溃。

说到记住，只捕获上游错误。用 `try/catch` 对下游逻辑进行保护！.