interface NewsApi {
    @POST("/wanandroid")
    fun fetchNewsLiveData(
        @FieldMap map:Map<String,String>
    ):LiveData<ApiResponse<NewsBean>>
}

使用的時候

fetchNewsLiveData().asFlow()

這樣不就轉(zhuǎn)成了Flow了嗎？如果想轉(zhuǎn)為StateFlow 或者SharedFlow，可以繼續(xù)shareIn stateIn 之類的方法轉(zhuǎn)換為熱流。

1.2 suspend

使用掛起函數(shù)直接返回對象，然后使用flow函數(shù)創(chuàng)建出Flow對象，也是非常的簡單，這也是官方推薦的方式。

interface NewsApi {
    @POST("/wanandroid")
   suspend  fun fetchNews(
        @FieldMap map:Map<String,String>
    ):ApiResponse<NewsBean>
}

使用的時候,直接就創(chuàng)建了一個flow對象

flow {
  emit(fetchNews())
}

如果想轉(zhuǎn)為StateFlow 或者SharedFlow，可以繼續(xù)shareIn stateIn 之類的方法轉(zhuǎn)換為熱流。

這種網(wǎng)絡(luò)數(shù)據(jù)使用Flow的方式，好處是可以很方便的進行合并，合流，展平等操作，很方便的使用操作符轉(zhuǎn)換成我們想要的數(shù)據(jù)。

二、協(xié)程與Flow的選擇與差異

協(xié)程與Flow的選擇，什么情況下我應(yīng)該使用協(xié)程請求網(wǎng)絡(luò)，什么情況下我才使用Flow 來操作UI。

其實我們對于實時性不高的數(shù)據(jù)，我們可以使用 Kotlin 協(xié)程處理，而對于實時性較高的數(shù)據(jù)，我們可以用 Flow 來處理。

例如動態(tài)詳情頂部是詳情數(shù)據(jù)固定的數(shù)據(jù)，而底部是列表和點贊評論的數(shù)量，這些是動態(tài)的數(shù)據(jù)，那么我們再頂部就可以用協(xié)程請求，在底部我們使用Flow處理數(shù)據(jù)再通知其改變。

    @POST("/wanandroid")
    suspend fun fetchNews(
        @FieldMap map: Map<String, String>
    ): BaseBean<NewsBean>

    suspend fun fetchNewsDetail(): OkResult<NewsBean> {
        return extRequestHttp {
            DemoRetrofit.apiService.fetchNews(
                mapOf("id" to "12232", "key" to "2")
            )
        }
    }

    lifecycleScope.launch {
        val detail = mViewModel.mRepository.fetchNewsDetail()
        detail.checkSuccess {
            updateUI(it)
        }
    }
    private fun updateUI(newsBean: NewsBean?) {
       // XXX
    }

而下面的列表與動態(tài)點贊分享數(shù)據(jù)，我們可以使用 Flow 來操作，當(dāng)點贊或轉(zhuǎn)發(fā)數(shù)發(fā)生變化時，updateUI() 會被執(zhí)行，UI根據(jù)最新的數(shù)據(jù)更新。

    private val _stateFlow = MutableStateFlow("")
    val stateFlow: StateFlow<String> = _searchFlow
    fun changeState() {
        viewModelScope.launch {
            val detail = mRepository.changeState()
            detail.checkSuccess {
                //進一系列的數(shù)據(jù)合流
                //進行一系列的排序、轉(zhuǎn)換之后設(shè)置給Flow
                _stateFlow.value = it ?: ""
            }
        }
    }

操作UI的偽代碼如下：

    private fun changeData() {
        mViewModel.changeState()
    }
    private fun updateUI() {
       //更新一些UI
    }
    override fun startObserve() {
        lifecycleScope.launchWhenCreated {
            mViewModel.stateFlow.collect {
                updateUI()
            }
        }
    }

是不是靜態(tài)的頁面不能用 Flow ,能不能用 LiveData ? 當(dāng)然可以用了，上面的只是推薦使用，其他的方式當(dāng)然都可以例如：

    fun getNewsDetail(): LiveData<NewsBean?> {
        return liveData {
            val detail = mRepository.fetchNewsDetail()
            if (detail is OkResult.Success) {
                emit(detail.data)
            } else {
                emit(null)
            }
        }
    }

使用的時候：

    fun getData(){
        mViewModel.getNewsDetail().observe(this) {
            updateUI()
        }
    }
    private fun updateUI() {
        //更新一些UI
    }

三、StateFlow與SharedFlow的選擇

什么時候使用StateFlow ，什么時候使用 SharedFlow ，在之前 SharedFlow 的文章中，我們對比過 StateFlow，SharedFlow，LiveData 的區(qū)別。

關(guān)于 SharedFlow、StateFlow、LiveData的對比，個人的結(jié)論是：根據(jù)不同的場景 LiveData StateFlow SharedFlow 都有自己特定的使用場景，誰也無法真的完全平替誰。誰也不是誰的超集，都是各有利弊，按需選擇即可。這里不過多贅述。

那其實從另一角度，我們區(qū)別不同的場景為狀態(tài)和事件，看此場景是狀態(tài)驅(qū)動還是事件驅(qū)動的。

比如我現(xiàn)在點擊了按鈕，需要彈窗了，然后使用StateFlow來記錄狀態(tài)，然后收集到這個事件彈出彈框了，然后我們關(guān)閉彈窗去瀏覽此頁面的其他信息了了，但是當(dāng)我們旋轉(zhuǎn)手機屏幕之后，我們會發(fā)現(xiàn)彈窗又出來了。這就不合理了。

有同學(xué)說，這是StateFlow的問題，此情況我們需要使用LiveData，那LiveData就沒有問題了嗎？

我們測試一下：

@HiltViewModel
class Demo4ViewModel @Inject constructor(
    val mRepository: Demo5Repository,
    val savedState: SavedStateHandle
) : BaseViewModel() {
    val channel = Channel<String>(Channel.CONFLATED)
    private val _searchLD = MutableLiveData<String>()
    val searchLD: LiveData<String> = _searchLD
    private val _searchFlow = MutableStateFlow("")
    val searchFlow: StateFlow<String> = _searchFlow
    private val _sharedFlow = MutableSharedFlow<String>(replay = 1, onBufferOverflow = BufferOverflow.SUSPEND)
    val sharedFlow: SharedFlow<String> = _sharedFlow
    fun changeSearch(keyword: String) {
        _sharedFlow.tryEmit(keyword)
        _searchFlow.value = keyword
        _searchLD.value = keyword
        channel.trySend(keyword)
    }
}

我們測試 LiveData Channel StateFlow SharedFlow（replay=1）

點擊按鈕發(fā)送事件