Kotlin Flow 自定义操作符的背压与组合子设计

从零实现 Flow 操作符，掌握背压机制、缓冲区策略和冷热流转换的深层原理。 · 难度：入门 · +10XP

Flow 自定义操作符的背压与组合子设计

大多数教程只教如何使用 Flow 的现有操作符，但作为高级开发者，你需要理解如何实现自己的操作符。本教程将手动实现 map、filter、combine 等核心操作符，重点解析背压如何通过挂起函数自然解决，以及 buffer、conflate 等策略的内部实现。还将设计一个自定义的‘去抖’操作符 debounce，并讨论 Flow 的取消传播与协程作用域的交互。

fun <T, R> Flow<T>.myMap(transform: suspend (T) -> R): Flow<R> = flow {
    collect { value ->
        emit(transform(value))
    }
}
fun <T> Flow<T>.myDebounce(timeMs: Long): Flow<T> = flow {
    var lastValue: T? = null
    var job: Job? = null
    collect { value ->
        job?.cancel()
        job = coroutineScope {
            launch {
                delay(timeMs)
                emit(value)
            }
        }
    }
}