Flow轉(zhuǎn)LiveData數(shù)據(jù)丟失原理詳解

更新時間：2023年01月09日 08:39:27 作者：TechMerger

這篇文章主要為大家介紹了Flow轉(zhuǎn)LiveData數(shù)據(jù)丟失原理詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪

前言

最近我在負責一段代碼庫，需要在使用 Flow 的 Data 層和仍然依賴 LiveData 暴露 State 數(shù)據(jù)的 UI 層之間實現(xiàn)橋接。好在 androidx.lifecycle 框架已經(jīng)提供了一個叫做 asLiveData() 的方法，可以讓你毫不費力地將 Flow 轉(zhuǎn)為 LiveData。

然而使用這種方式得到的 LiveData 需要牢記一點：在擁有一個及以上活躍的觀察者的條件下，它才會發(fā)射數(shù)據(jù)。假使上游的 flow 產(chǎn)生了更新，但對應的 LiveData 并非活躍的狀態(tài)，那么它將無法獲得最新的數(shù)值。

讓我通過如下的實例，向你展示我們可能會遇到的這種潛在問題。

示例

我們有一個簡單的 Activity，它持有 AAC ViewModel 的實例：

 class MainActivity : AppCompatActivity() {  
     private val viewModel: MainViewModel by viewModels()  
     override fun onCreate(savedInstanceState: Bundle?) {  
         super.onCreate(savedInstanceState)  
         setContentView(R.layout.activity_main)    
     }  
 }

該 ViewModel 的實現(xiàn)是這樣的：

 class MainViewModel : ViewModel() {  
     private val repository = Repository()  
     val state: LiveData<Int> = repository.state.asLiveData()  
 }

它持有一個 Repository 實例，充當瑣碎的數(shù)據(jù)層。

同時 ViewModel 還通過前面提到的 asLiveData() 方法，將 Repository 持有的 StateFlow 轉(zhuǎn)為了 LiveData 并對外暴露了其 State 數(shù)據(jù)。

Repository 的實現(xiàn)如下：

 class Repository {  
     private val _state = MutableStateFlow(-1)  
     val state: StateFlow<Int> = _state  
     suspend fun update() {  
         _state.emit(Random.nextInt(until = 1000))  
     }  
 }

它擁有一個包裹著 Integer 數(shù)據(jù)（初始值為 -1）的 StateFlow 示例，同時對外提供了一個方法允許外界更新它的 State：從 0 到 1000 之間取得一個新的隨機數(shù)。

試想一下，假使希望 Activity 創(chuàng)建的時候就能執(zhí)行這個數(shù)據(jù)更新。我們可以這么實現(xiàn)：

在 MainViewModel 內(nèi)創(chuàng)建一個 init() 來做這個操作
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)建的時候一個新的協(xié)程將被啟動，最終會調(diào)用 Repository 的 update() ，生成一個隨機數(shù)并發(fā)射到它的 State。

此外，我們可能還需要在 ViewModel 中去發(fā)送包含了新生成數(shù)值的事件出去?？梢栽?ViewModel 中添加一個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)，我們可以做些典型的操作，比如向后端服務器發(fā)送網(wǎng)絡請求。這里，讓我們僅僅在 Logcat 里打印來自 LiveData and Flow 的數(shù)值即可。

上面的運行結(jié)果相當出乎意料。你可能會爭辯道：LiveData 沒有獲取到最新的數(shù)值，是因為沒有足夠的時間從上游的 flow 中收集數(shù)據(jù)，不然的話肯定能夠拿到正確的數(shù)值。

但這個 case 里，不僅僅是 LiveData 獲得到的是錯誤的數(shù)值，它獲得到的是 null。而且請別忘了，它的存放在 Repository 里的初值是 -1。這只能代表一個意思：這里的 LiveData 壓根沒有從 StateFlow 里收集任何數(shù)據(jù)。

原因是我們還沒有開始觀察這個 LiveData，它自然會被當作是非活躍的。而且根據(jù) asLiveData() 方法的文檔可以知道，在這種情況下 LiveData 不會從上游的 flow 收集任何數(shù)據(jù)。

asLiveData:Creates a LiveData that has values collected from the origin Flow.

上游 flow 數(shù)據(jù)的收集發(fā)生在 LiveData 變成活躍的時候，即 LiveData.onActive。如果 flow 尚未完成，而 LiveData 變成了非激活狀態(tài)，即 LiveData.onActive，那么 flow 的數(shù)據(jù)收集將在timeoutInMs 參數(shù)指定的時間后被取消。除非在超時之前，LiveData 變成活躍狀態(tà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 里新的輸出。