Kotlin flow实践

flow { 
    // 数据生产
    emit(1)
    emit(2) 
}
.map { it * 2 } // 转换
.filter { it > 2 } // 过滤
.collect { value -> 
    // 数据消费
    println(value) 
}

suspend fun main() {
    println("启动 Flow")
    val countDownFlow = flow<Int> {
        for (i in 10 downTo 1) {
            emit(i) // 发送当前数值
            delay(1000) // 模拟每秒倒计时
        }
    }
    countDownFlow
        .map { "倒计时$it 秒" }
        .onEmpty { println("发射数据为空") }
        .onEach { println(it) }
        .collect { 
            println("collect: $it") 
        }
}

suspend fun main() {
    println("启动 Flow")
    val countDownFlow = flow<Int> {
        for (i in 10 downTo 1) {
            emit(i)
            delay(1000) // 生产者固定节奏
        }
    }
    countDownFlow
        .map { "倒计时$it 秒" }
        .onEach { println(it) }
        .buffer() // 关键优化：添加缓冲队列
        .collect {
            println("collect: $it") 
        }
}

suspend fun main() {
    println("启动 Flow")
    val countDownFlow = flow<Int> {
        for (i in 10 downTo 1) {
            emit(i)
            delay(1000)
        }
    }
    countDownFlow
        .map { "倒计时$it 秒" }
        .onEach { println(it) } // 打印所有生产数据
        .collectLatest { 
            println("collectLatest: 开始处理 $it")
            delay(2000) // 模拟耗时处理
            println("collectLatest: 处理完成 $it") // 仅最后一个完成
        }
}