Android開發(fā)flow常見API的使用示例詳解
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是冷流,只有調用collect{}方法時才能觸發(fā)flow代碼塊的執(zhí)行。還有一點要注意,collect{}方法是個suspend聲明的方法,需要在協(xié)程作用域的范圍能調用。
除此之外,collect{}方法的參數(shù)是一個被crossinline修飾的函數(shù)類型,旨在加強內聯(lián),禁止在該函數(shù)類型中直接使用return關鍵字(return@標簽除外)。
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í)行。本質上就是使用我們傳入的協(xié)程作用域手動開啟一個協(xié)程代碼塊調用collect{}通知協(xié)程執(zhí)行。
這里看官方的源碼有個tail-call的注釋,也就是尾調用的意思,猜測這里可能官方會在這里進行了優(yōu)化,減少了棧中方法調用的層級,降低棧溢出的風險。
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中都有它的影子,它的作用就是將當前數(shù)據(jù)類型變換成另一種數(shù)據(jù)類型(可以相同)。
fun main() {
GlobalScope.launch {
flow {
emit(5)
}.map {
"ha".repeat(it)
}.collect {
println("collect value: $it")
}
}
}
總結
本篇文章介紹了flow常見的api,接下來還會有一些列文章用來介紹flow的其他api,更多關于Android開發(fā)flow常見API的資料請關注腳本之家其它相關文章!
相關文章
Android開發(fā) Bundle傳值的理解與使用小結
這篇文章主要介紹了Android開發(fā) Bundle傳值的理解與使用小結,本文通過實例代碼給大家介紹的非常詳細,感興趣的朋友一起看看吧2024-07-07
分享10個很棒的學習Android開發(fā)的網(wǎng)站
我推薦的網(wǎng)站,都是我在學習Android 開發(fā)過程中發(fā)現(xiàn)的好網(wǎng)站,給初學者一些建議,少走一些彎路2015-03-03
Android ListView長按彈出菜單二種實現(xiàn)方式示例
這篇文章主要介紹了Android ListView長按彈出菜單的方法,大家參考實現(xiàn)2013-11-11
使用Android studio3.6的java api方式調用opencv
這篇文章主要介紹了Android studio3.6的java api方式調用opencv的代碼詳解,本文通過實例代碼給大家介紹的非常詳細,對大家的學習或工作具有一定的參考借鑒價值,需要的朋友可以參考下2020-03-03
Android自定義可拖拽的懸浮按鈕DragFloatingActionButton
這篇文章主要介紹了Android自定義可拖拽的懸浮按鈕DragFloatingActionButton,需要的朋友可以參考下2017-06-06

