public suspend inline fun <T> Flow<T>.collect(crossinline action: suspend (value: T) -> Unit): Unit =
    collect(object : FlowCollector<T> {
        override suspend fun emit(value: T) = action(value)
    })

flow是冷流，只有調(diào)用collect{}方法時才能觸發(fā)flow代碼塊的執(zhí)行。還有一點要注意，collect{}方法是個suspend聲明的方法，需要在協(xié)程作用域的范圍能調(diào)用。

除此之外，collect{}方法的參數(shù)是一個被crossinline修飾的函數(shù)類型，旨在加強內(nèi)聯(lián)，禁止在該函數(shù)類型中直接使用return關(guān)鍵字（return@標(biāo)簽除外）。

fun main() {
    GlobalScope.launch {
        flow {
            emit("haha")
        }.collect {
        }
    }
}

launchIn()指定協(xié)程作用域通知flow執(zhí)行

public fun <T> Flow<T>.launchIn(scope: CoroutineScope): Job = scope.launch {
    collect() // tail-call
}

這個方法允許我們直接傳入一個協(xié)程作用域的參數(shù)，不需要直接在外部開啟一個協(xié)程執(zhí)行。本質(zhì)上就是使用我們傳入的協(xié)程作用域手動開啟一個協(xié)程代碼塊調(diào)用collect{}通知協(xié)程執(zhí)行。

這里看官方的源碼有個tail-call的注釋，也就是尾調(diào)用的意思，猜測這里可能官方會在這里進行了優(yōu)化，減少了棧中方法調(diào)用的層級，降低棧溢出的風(fēng)險。

fun main() {
    flow {
        emit("haha")
    }.launchIn(GlobalScope)
}

catch{}捕捉異常

public fun <T> Flow<T>.catch(action: suspend FlowCollector<T>.(cause: Throwable) -> Unit): Flow<T> =
    flow {
        val exception = catchImpl(this)
        if (exception != null) action(exception)
    }

這個就是用來捕捉異常的，不過注意，只能捕捉catch()之前的異常，下面來個圖闡述下：

即，只能捕捉第一個紅框中的異常，而不能捕捉第二個紅框中的異常。

merge()合流

public fun <T> merge(vararg flows: Flow<T>): Flow<T> = flows.asIterable().merge()

最終的實現(xiàn)類如下：

請注意，這個合流的每個流可以理解為是并行執(zhí)行的，而不是后一個流等待前一個流中的flow代碼塊中的邏輯執(zhí)行完畢再執(zhí)行，這樣做的目的可以提供合流的每個流的執(zhí)行效果。

測試代碼如下：

fun main() {
    GlobalScope.launch {
        merge(flow {
            delay(1000)
            emit(4)
        }, flow {
            println("flow2")
            delay(2000)
            emit(20)
        }).collect {
            println("collect value: $it")
        }
    }
}

輸出日志如下：

map{}變換發(fā)送的數(shù)據(jù)類型

public inline fun <T, R> Flow<T>.map(crossinline transform: suspend (value: T) -> R): Flow<R> = transform { value ->
   return@transform emit(transform(value))
}

這個api沒什么可將的，很多的地方比如集合、livedata中都有它的影子，它的作用就是將當(dāng)前數(shù)據(jù)類型變換成另一種數(shù)據(jù)類型（可以相同）。

fun main() {
    GlobalScope.launch {
        flow {
            emit(5)
        }.map {
            "ha".repeat(it)
        }.collect {
            println("collect value: $it")
        }
    }
}