本技能介绍的是一个 Kotlin Flow 使用模式及其常见陷阱，而非可直接安装的工具，原文未提供安装命令或平台信息。
用途 解决两条速率差异很大的流需要配合的场景：一条是“键流”（当前查看的项，变化很少），另一条是高频连续流（位置、尺寸、进度读数）。某些一次性工作在每一项上需执行一次，而不是每个 tick 执行一次。用 flatMapLatest 实现重新订阅：键变化时取消并重建内层收集，避免新键与旧流混配；再用基于复合键的 distinctUntilChanged 把高频流折叠为“真正有意义的变更”。
主要能力与示例
给出以 currentItemState.filterNotNull().flatMapLatest { … }.distinctUntilChanged { … }.collectLatest { … } 为核心的结构：复合键由“时长 + 项 id”组成，因为只看 id 太早（时长未知、请求会带零值），只看时长在回退时会变。收集体内用 if (screenData.value.extraA == null) 等做幂等守卫。
关键陷阱
- 谓词语义：distinctUntilChanged 的谓词回答“是否等价”，返回 true 表示丢弃。误写成
old != new会导致除变更外全部丢弃，症状是副作用每个 tick 都触发。推荐用distinctUntilChangedBy { (t, item) -> t.total to item.entity?.id }提取键，避免比较反转。 - 不要用字符串拼接加 hashCode 构造复合键：拼接有歧义且哈希会碰撞，漏掉的变更会静默不执行。应比较 Pair、data class 或字段本身。
- 键遗漏字段等于一整类更新永远收不到，且症状更隐蔽（功能直接缺失而非误触发）。规则：键必须包含收集体读取的每个字段；宁可键偏宽。示例用
listIds = it.list.map { e -> e.id }投影，避免依赖上游复用实例。 - 收集体仍需自己的幂等守卫；键因无关原因变化（如迟到的时长修正）会再次触发，守卫让重触发无害。
- collectLatest 只取消上一个动作，不取消该动作已启动的工作；若键变化时必须放弃一次性工作，应持有命名句柄并取消，或在写结果处再次校验项 id。
- combine 会在任一源发射时重发，高速流会驱动它、键流不提供结构性作用；zip 按位置配对，速率分歧后立即停滞。二者均不能替代。
- flatMapLatest 为实验性 API，需在文件加
@OptIn(ExperimentalCoroutinesApi::class)。 - 算子顺序应为 filter → flatMapLatest → distinct → collect；把 distinct 放在 flatMapLatest 之前只会对键流去重，几乎无效。
验证方式
原文给出两条 grep 命令，分别普查手写键与投影键：grep -rnE 'distinctUntilChanged *\{|distinctUntilChangedBy' --include='*.kt' . | grep -v '/build/'，以及配合 -A12 查找多行 .map { 后接裸 distinctUntilChanged() 的组合。对每个命中检查两点：此处 true 是否表示丢弃，键是否包含收集体读取的所有字段。随后对闸门（而非收集体）埋点，记录每个通过 distinctUntilChanged 的复合键：单个项播放全程，行数应很少且有界——时长已知时一行，其余为零；每 tick 一行说明谓词反转或键含连续变化字段，已知变化却无行则说明遗漏字段。最后在首项工作返回前快速切换项，确认新项出现新行、旧项结果不再写入。
适用场景 Kotlin 协程项目中需要按键重新订阅下游流、并对合并后的高频流做有意义变更去重的实现与代码审查。
限制 原文聚焦逻辑与陷阱讲解，未提供性能数据、兼容版本、收费或平台信息；示例为改写后泛化名称，非完整可运行工程。