特色栏目： python 批处理 net编程 Javascript Php Asp Css Html5 Android seo centos

KotlinFlow常见场景下的使用实例

来源：互联网收集：自由互联发布时间：2023-02-01

目录 Kotlin Flow在开发中的常用场景使用一、网络请求搭载Retrofit 1.1 LiveDataCallAdapterFactory 1.2 suspend 二、协程与Flow的选择与差异三、StateFlow与SharedFlow的选择总结 Kotlin Flow在开发中的常用

Kotlin Flow在开发中的常用场景使用

大家了解了 Flow 的创建与接收流程，了解 SharedFlow 创建的几种方式，各个参数的用途，了解了SharedFlow的 "青春版" StateFlow 的创建与接收，已经他们与 LiveData 的异同。

注：这里青春版打上引号，只是调侃而已，并不是说 StateFlow 比 SharedFlow 更加轻量，而是StateFlow使用更加简单，更加的场景化而已，使用起来感觉比较青春版而已。

那么在真实的开发环境中我们是如何使用Flow的呢？这里从几点举例说明一下。

一、网络请求搭载Retrofit

之前在网上看到有人提问，为什么Retrofit不能返回 Flow 这样的对象。使用一个 FlowCallAdapterFactory 那我就可以直接使用Flow来传递了。

不是不行，有第三方的依赖实现了此功能，为什么官方不出，其实官方已经给出了建议。

如果我想使用flow来传递数据，有哪些方式返回Flow的方式呢？这里有几种方案

1.1 LiveDataCallAdapterFactory

Retrofit 增加了 LiveDataCallAdapterFactory，我们可以使用LiveData来包裹对象

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

使用的时候

fetchNewsLiveData().asFlow()

这样不就转成了Flow了吗？如果想转为StateFlow 或者SharedFlow，可以继续shareIn stateIn 之类的方法转换为热流。

1.2 suspend

使用挂起函数直接返回对象，然后使用flow函数创建出Flow对象，也是非常的简单，这也是官方推荐的方式。

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

使用的时候,直接就创建了一个flow对象

flow {
  emit(fetchNews())
}

如果想转为StateFlow 或者SharedFlow，可以继续shareIn stateIn 之类的方法转换为热流。

这种网络数据使用Flow的方式，好处是可以很方便的进行合并，合流，展平等操作，很方便的使用操作符转换成我们想要的数据。

二、协程与Flow的选择与差异

协程与Flow的选择，什么情况下我应该使用协程请求网络，什么情况下我才使用Flow 来操作UI。

其实我们对于实时性不高的数据，我们可以使用 Kotlin 协程处理，而对于实时性较高的数据，我们可以用 Flow 来处理。

例如动态详情顶部是详情数据固定的数据，而底部是列表和点赞评论的数量，这些是动态的数据，那么我们再顶部就可以用协程请求，在底部我们使用Flow处理数据再通知其改变。

    @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
    }

而下面的列表与动态点赞分享数据，我们可以使用 Flow 来操作，当点赞或转发数发生变化时，updateUI() 会被执行，UI根据最新的数据更新。

    private val _stateFlow = MutableStateFlow("")
    val stateFlow: StateFlow<String> = _searchFlow
    fun changeState() {
        viewModelScope.launch {
            val detail = mRepository.changeState()
            detail.checkSuccess {
                //进一系列的数据合流
                //进行一系列的排序、转换之后设置给Flow
                _stateFlow.value = it ?: ""
            }
        }
    }

操作UI的伪代码如下：

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

是不是静态的页面不能用 Flow ,能不能用 LiveData ? 当然可以用了，上面的只是推荐使用，其他的方式当然都可以例如：

    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 的区别。

关于 SharedFlow、StateFlow、LiveData的对比，个人的结论是：根据不同的场景 LiveData StateFlow SharedFlow 都有自己特定的使用场景，谁也无法真的完全平替谁。谁也不是谁的超集，都是各有利弊，按需选择即可。这里不过多赘述。

那其实从另一角度，我们区别不同的场景为状态和事件，看此场景是状态驱动还是事件驱动的。

比如我现在点击了按钮，需要弹窗了，然后使用StateFlow来记录状态，然后收集到这个事件弹出弹框了，然后我们关闭弹窗去浏览此页面的其他信息了了，但是当我们旋转手机屏幕之后，我们会发现弹窗又出来了。这就不合理了。

有同学说，这是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）

点击按钮发送事件