在使用 Kotlin Flow 时很多同学会遇到以下痛点：

• 一眼看到一堆操作符，不知道该先学哪几个。
• 创建 Flow、转换、过滤、合并、线程切换、异常处理、收集等环节混在一起，找不到清晰的使用顺序。
• 实际项目中常见的组合写法不知道该怎么记忆和复用。

下面把 Flow 的主要操作符分层整理。并针对这些痛点提供记忆技巧和常用代码示例，方便你上手并在项目中灵活运用。

一、创建 Flow：数据从哪里来

这类操作符负责创建 Flow是所有链式调用的起点。

记忆小技巧

flow { emit;emit } // 手动 emit
flowOf // 固定值
listOf.asFlow // 集合转 Flow
callbackFlow { /* callback -> send */ }
channelFlow { launch { send } }

二、转换操作符：把数据变成另一种形态

对每个元素做加工或产生额外元素。

`map` 示例

flowOf
.map { it * 10 }
.collect { println } // 输出：10 20 30

`transform` 示例

flowOf
.transform {
emit
emit
}
.collect { println }
// 输出：开始 A /结束 A /开始 B /结束 B

`onEach` 常用场景

• 从打印日志来看，.onEach { Log.d }
• 更新 UI 状态：.onEach { viewState = it }Suspend 操作如.delay.

  三、过滤操作符：挑选想要的数据

  "filter""保留满足条件的元素" "filterNot""过滤掉满足条件的元素" "take""只取前 N 个元素" "drop""跳过前 N 个元素" "distinctUntilChanged""相邻重复值只保留一个"

  "operation"	"description"

  `filter` 示例

   flowOf
  . filter{ it %4 ==0}
  . collect{ println }
  // 输出:4
  

  `take` 示例

  flowOf
  . take
  . collect{ println }
  // 输出:10
  20
  

  `distinctUntilChanged` 注意事项

  它只去掉相邻重复 不是全局去重。

  四 、 合 并 操 作 符 ： 多 个 流 的 整 合

  常 用 场 景 对 应 操 作 符

  • 合 并 : merge / combine / zip。​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​​ ​​​​​ ​​​​​​​​​ ​​​​ ​​ ​​​​​ ​
  • /flatMap 系列 : concat → 顺序 | merge → 并发 | latest → 最新
  • /缓冲&背压 : buffer → 上游提前生产;conflate → 下游慢时只保最新;debounce → 防抖;按理说，sample → 定时采样

  操作 符	核 心 概念
  merge	多 条 流 混 合，谁先发谁先到。适用于事件源混合，
  combine	所有上游都有最新值时组合；按理说，任意一个更新都会重新计算。适用于 UIState 合并。
  zip	按顺序配对，两条流第 i 项对应第 i 项。适用于固定对应关系，
  flattenConcat / flattenMerge	把 Flow 展开为单层流；前者串行，后者并行，
  flatMapConcat / flatMapMerge / flatMapLatest	map + 展开 的组合形式；分别代表顺序、并发、仅保留最新子流。
  combineTransform	在 combine 基础上自行 emit 多个值。

  操作符

  作用

  切换上游执行线程