日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

Android開發flow常見API的使用示例詳解_Android

作者：長安皈故里 ? 更新時間： 2022-10-19 編程語言

collect通知flow執行

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是冷流，只有調用collect{}方法時才能觸發flow代碼塊的執行。還有一點要注意，collect{}方法是個suspend聲明的方法，需要在協程作用域的范圍能調用。

除此之外，collect{}方法的參數是一個被crossinline修飾的函數類型，旨在加強內聯，禁止在該函數類型中直接使用return關鍵字（return@標簽除外）。

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

launchIn()指定協程作用域通知flow執行

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

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

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

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

最終的實現類如下：

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

測試代碼如下：

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

輸出日志如下：

map{}變換發送的數據類型

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中都有它的影子，它的作用就是將當前數據類型變換成另一種數據類型（可以相同）。

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

總結

原文鏈接：https://juejin.cn/post/7134478501612093471

欄目分類
最近更新