Flow轉(zhuǎn)LiveData數(shù)據(jù)丟失原理詳解
前言
翻譯自:arkadiuszchmura.com/posts/be-ca…
最近我在負(fù)責(zé)一段代碼庫(kù),需要在使用 Flow
的 Data 層和仍然依賴 LiveData
暴露 State 數(shù)據(jù)的 UI 層之間實(shí)現(xiàn)橋接。好在 androidx.lifecycle
框架已經(jīng)提供了一個(gè)叫做 asLiveData()
的方法,可以讓你毫不費(fèi)力地將 Flow
轉(zhuǎn)為 LiveData
。
然而使用這種方式得到的 LiveData 需要牢記一點(diǎn):在擁有一個(gè)及以上活躍的觀察者的條件下,它才會(huì)發(fā)射數(shù)據(jù)。假使上游的 flow 產(chǎn)生了更新,但對(duì)應(yīng)的 LiveData 并非活躍的狀態(tài),那么它將無(wú)法獲得最新的數(shù)值。
讓我通過(guò)如下的實(shí)例,向你展示我們可能會(huì)遇到的這種潛在問(wèn)題。
示例
我們有一個(gè)簡(jiǎn)單的 Activity,它持有 AAC ViewModel
的實(shí)例:
class MainActivity : AppCompatActivity() { private val viewModel: MainViewModel by viewModels() override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) setContentView(R.layout.activity_main) } }
該 ViewModel
的實(shí)現(xiàn)是這樣的:
class MainViewModel : ViewModel() { private val repository = Repository() val state: LiveData<Int> = repository.state.asLiveData() }
它持有一個(gè) Repository 實(shí)例,充當(dāng)瑣碎的數(shù)據(jù)層。
同時(shí) ViewModel
還通過(guò)前面提到的 asLiveData()
方法,將 Repository 持有的 StateFlow
轉(zhuǎn)為了 LiveData 并對(duì)外暴露了其 State 數(shù)據(jù)。
Repository 的實(shí)現(xiàn)如下:
class Repository { private val _state = MutableStateFlow(-1) val state: StateFlow<Int> = _state suspend fun update() { _state.emit(Random.nextInt(until = 1000)) } }
它擁有一個(gè)包裹著 Integer 數(shù)據(jù)(初始值為 -1)的 StateFlow
示例,同時(shí)對(duì)外提供了一個(gè)方法允許外界更新它的 State:從 0 到 1000 之間取得一個(gè)新的隨機(jī)數(shù)。
試想一下,假使希望 Activity 創(chuàng)建的時(shí)候就能執(zhí)行這個(gè)數(shù)據(jù)更新。我們可以這么實(shí)現(xiàn):
- 在
MainViewModel
內(nèi)創(chuàng)建一個(gè)init()
來(lái)做這個(gè)操作 - Activity 的
onCreate()
里調(diào)用該方法
// MainViewModel fun init() { // update() is suspending, so we launch a new coroutine here viewModelScope.launch { repository.update() } } ? // MainActivity override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) setContentView(R.layout.activity_main) viewModel.init() }
這樣的話,Activity 創(chuàng)建的時(shí)候一個(gè)新的協(xié)程將被啟動(dòng),最終會(huì)調(diào)用 Repository 的 update()
,生成一個(gè)隨機(jī)數(shù)并發(fā)射到它的 State。
此外,我們可能還需要在 ViewModel
中去發(fā)送包含了新生成數(shù)值的事件出去??梢栽?ViewModel
中添加一個(gè)sendAnalyticalEvent()
,這樣可以在執(zhí)行完 Repository 的 update()
之后立即調(diào)用它。
// MainViewModel fun init() { viewModelScope.launch { repository.update() sendAnalyticalEvent() // <-- NEW } } private fun sendAnalyticalEvent() { // Typically, we would schedule a network request here val liveDataValue = state.value val flowValue = repository.state.value Log.d("Current number in LiveData", "$liveDataValue") Log.d("Current number in StateFlow", "$flowValue") }
該方法內(nèi),我們可以做些典型的操作,比如向后端服務(wù)器發(fā)送網(wǎng)絡(luò)請(qǐng)求。這里,讓我們僅僅在 Logcat 里打印來(lái)自 LiveData
and Flow
的數(shù)值即可。
上面的運(yùn)行結(jié)果相當(dāng)出乎意料。你可能會(huì)爭(zhēng)辯道:LiveData
沒(méi)有獲取到最新的數(shù)值,是因?yàn)闆](méi)有足夠的時(shí)間從上游的 flow 中收集數(shù)據(jù),不然的話肯定能夠拿到正確的數(shù)值。
但這個(gè) case 里,不僅僅是 LiveData
獲得到的是錯(cuò)誤的數(shù)值,它獲得到的是 null。而且請(qǐng)別忘了,它的存放在 Repository 里的初值是 -1。這只能代表一個(gè)意思:這里的 LiveData
壓根沒(méi)有從 StateFlow
里收集任何數(shù)據(jù)。
原因是我們還沒(méi)有開(kāi)始觀察這個(gè) LiveData
,它自然會(huì)被當(dāng)作是非活躍的。而且根據(jù) asLiveData()
方法的文檔可以知道,在這種情況下 LiveData
不會(huì)從上游的 flow 收集任何數(shù)據(jù)。
asLiveData:Creates a LiveData that has values collected from the origin Flow.
上游 flow 數(shù)據(jù)的收集發(fā)生在 LiveData
變成活躍的時(shí)候,即 LiveData.onActive
。如果 flow 尚未完成,而 LiveData
變成了非激活狀態(tài),即 LiveData.onActive
,那么 flow 的數(shù)據(jù)收集將在timeoutInMs
參數(shù)指定的時(shí)間后被取消。除非在超時(shí)之前,LiveData
變成活躍狀態(tài)。
一旦我們開(kāi)始在 Activity 里觀察 LiveData
的數(shù)據(jù)(因此將促使 LiveData 變成活躍狀態(tài)),它就能夠擁有正確的、最新的數(shù)值了。
// MainActivity override fun onCreate(savedInstanceState: Bundle?) { super.onCreate(savedInstanceState) setContentView(R.layout.activity_main) viewModel.init() viewModel.state.observe(this) { // <-- NEW Log.d("Current number in MainActivity", "$it") } }
如下是 Logcat 里新的輸出。
上面的示例里,我們采用的是 StateFlow
,但規(guī)則同樣適用于 SharedFlow
。
而且,情況將更加糟糕,因?yàn)楫?dāng) LiveData
處于非激活狀態(tài)的時(shí)候,任何發(fā)送給 SharedFlow
的事件都將永久丟失(默認(rèn)情況下 SharedFlow
不會(huì)將任何數(shù)值重新發(fā)送給新的訂閱者)。
總結(jié)
請(qǐng)時(shí)刻記住采用 asLiveData()
方法轉(zhuǎn)換 Flow
得到的 LiveData
將會(huì)和預(yù)期的稍稍不同:它只會(huì)在注冊(cè)了活躍觀察者的情況下發(fā)射數(shù)據(jù)。
就我個(gè)人而言,這種行為無(wú)可厚非:因?yàn)槲覀兌歼€沒(méi)有觀察它、自然不會(huì)在意 LiveData
的數(shù)值是啥、能不能獲取得到。但話說(shuō)回來(lái),確實(shí)存在一些場(chǎng)景,需要在你尚未開(kāi)始觀察的時(shí)候,去訪問(wèn) ViewModel
中 LiveData
的當(dāng)前數(shù)值。
通過(guò)閱讀這篇文章,我希望你在遇到這種獲取不到正確數(shù)值的情況時(shí),不要驚訝、心中有數(shù)。
以上就是Flow轉(zhuǎn)LiveData數(shù)據(jù)丟失原理詳解的詳細(xì)內(nèi)容,更多關(guān)于Flow轉(zhuǎn)LiveData數(shù)據(jù)丟了的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
SafeList?in?Flutter?and?Dart小技巧
這篇文章主要為大家介紹了SafeList?in?Flutter?and?Dart小技巧,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2022-12-12Android檢測(cè)url地址是否可達(dá)的兩種方法
今天小編就為大家分享一篇Android檢測(cè)url地址是否可達(dá)的兩種方法,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2019-01-01Android開(kāi)發(fā)筆記 最好使用eclipse
值得注意一點(diǎn)的是,雖然Myeclipse比eclipse功能更強(qiáng)大,但是在具體的安卓開(kāi)發(fā)過(guò)程當(dāng)中,最好還是選用eclipse,sdk跟eclipse的兼容性更好2012-11-11使用ViewPager實(shí)現(xiàn)左右循環(huán)滑動(dòng)及滑動(dòng)跳轉(zhuǎn)
今天實(shí)現(xiàn)了左右滑動(dòng),至于在最后一頁(yè)滑動(dòng)跳轉(zhuǎn),這個(gè)也做了但是效果不是太好,也希望有實(shí)現(xiàn)的朋友能夠分享下2013-01-01Android開(kāi)發(fā)實(shí)現(xiàn)Launcher3應(yīng)用列表修改透明背景的方法
這篇文章主要介紹了Android開(kāi)發(fā)實(shí)現(xiàn)Launcher3應(yīng)用列表修改透明背景的方法,結(jié)合實(shí)例形式分析了Launcher3相關(guān)配置文件與功能函數(shù)修改設(shè)置操作技巧,需要的朋友可以參考下2017-11-11Android通知欄微技巧一些需要注意的小細(xì)節(jié)
這篇文章主要介紹了Android通知欄微技巧,那些你所沒(méi)關(guān)注過(guò)的小細(xì)節(jié),小編把此文分享到腳本之家平臺(tái),需要的朋友可以參考下2018-04-04android讀取Assets圖片資源保存到SD卡實(shí)例
本文為大家詳細(xì)介紹下android讀取Assets圖片資源保存到SD卡的具體實(shí)現(xiàn),感興趣的各位可以參考下哈,希望對(duì)大家有所幫助2013-07-07