flow { 
    // 數(shù)據(jù)生產(chǎn)
    emit(1)
    emit(2) 
}
.map { it * 2 } // 轉(zhuǎn)換
.filter { it > 2 } // 過濾
.collect { value -> 
    // 數(shù)據(jù)消費
    println(value) 
}

suspend fun main() {
    println("啟動 Flow")
    val countDownFlow = flow<Int> {
        for (i in 10 downTo 1) {
            emit(i) // 發(fā)送當(dāng)前數(shù)值
            delay(1000) // 模擬每秒倒計時
        }
    }
    countDownFlow
        .map { "倒計時$it 秒" }
        .onEmpty { println("發(fā)射數(shù)據(jù)為空") }
        .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) // 生產(chǎn)者固定節(jié)奏
        }
    }
    countDownFlow
        .map { "倒計時$it 秒" }
        .onEach { println(it) }
        .buffer() // 關(guān)鍵優(yōu)化：添加緩沖隊列
        .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) } // 打印所有生產(chǎn)數(shù)據(jù)
        .collectLatest { 
            println("collectLatest: 開始處理 $it")
            delay(2000) // 模擬耗時處理
            println("collectLatest: 處理完成 $it") // 僅最后一個完成
        }
}