快捷導(dǎo)航

Android開發(fā)flow常見API的使用示例詳解

更新時(shí)間：2022年08月23日 14:15:32 作者：長安皈故里

這篇文章主要為大家介紹了Android開發(fā)flow常見API的使用示例詳解，希望能夠幫助大家更好的掌握flow使用，熟練的應(yīng)用于各種場(chǎng)景，祝大家多多進(jìn)步，早日升職加薪

collect通知flow執(zhí)行

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{}方法時(shí)才能觸發(fā)flow代碼塊的執(zhí)行。還有一點(diǎn)要注意，collect{}方法是個(gè)suspend聲明的方法，需要在協(xié)程作用域的范圍能調(diào)用。

除此之外，collect{}方法的參數(shù)是一個(gè)被crossinline修飾的函數(shù)類型，旨在加強(qiáng)內(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
}

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

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

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)
    }

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

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

merge()合流

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

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

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

測(cè)試代碼如下：

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))
}

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

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