KotlinFlow vs Android LiveData

14ifxucb  于 2023-05-27  发布在  Android
关注(0)|答案(5)|浏览(153)

我有一些关于KotlinFlow的问题
1.我可以从多个片段中观察到LiveData。我可以用Flow做这个吗?如果是,那么如何?
1.我们可以使用mapswitchMap从单个LiveData生成多个LiveData。有没有办法从一个源Flow中获得多个Flow
1.使用MutableLiveData,我可以使用变量引用从任何地方更新数据。有没有什么方法可以对Flow做同样的事情?
我有一个用例:我将使用callbackFlow{...}观察一个SharedPreferences,这将给予我一个单一的源流。从这个流中,我想为每个键值对创建多个流。
这些问题可能听起来很傻。我是新的Rx和流动的世界。

abithluo

abithluo1#

我可以从多个片段中观察LiveData。我可以用Flow做这个吗?如果是,那么如何?
是的。您可以使用emitcollect执行此操作。emit类似于实时数据postValuecollect类似于observe。让我们给予个例子。

仓库

// I just faked the weather forecast
val weatherForecast = listOf("10", "12", "9")

// This function returns flow of forecast data
// Whenever the data is fetched, it is emitted so that
// collector can collect (if there is any)
fun getWeatherForecastEveryTwoSeconds(): Flow<String> = flow { 
    for (i in weatherForecast) {
        delay(2000)
        emit(i)
    }
}

视图模型

fun getWeatherForecast(): Flow<String> {
    return forecastRepository.getWeatherForecastEveryTwoSeconds()
}

碎片

override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
    // Collect is suspend function. So you have to call it from a 
    // coroutine scope. You can create a new coroutine or just use 
    // lifecycleScope
    // https://developer.android.com/topic/libraries/architecture/coroutines
    lifecycleScope.launch {
            viewModel.getWeatherForecast().collect {
                    // Use the weather forecast data
                    // This will be called 3 times since we have 3 
                    // weather forecast data
            }
    }
}

我们可以使用map和switchMap从单个LiveData中获得多个LiveData。有没有办法从一个单一的源流有多个流?
Flow非常方便。你可以在流动中创造流动。假设您想将度数符号附加到每个天气预报数据。

视图模型

fun getWeatherForecast(): Flow<String> {
    return flow {
        forecastRepository
            .getWeatherForecastEveryTwoSeconds(spendingDetailsRequest)
                .map {
                    it + " °C"
                }
                .collect {
                    // This will send "10 °C", "12 °C" and "9 °C" respectively
                    emit(it) 
                }
    }
}

然后收集片段中的数据,与#1相同。这里发生的是视图模型从存储库收集数据,片段从视图模型收集数据。
使用MutableLiveData,我可以使用变量引用从任何地方更新数据。有没有什么方法可以用Flow来做同样的事情?
您不能在流之外发出值。只有当存在任何收集器时,才会执行流中的代码块。但是您可以通过使用LiveData的asLiveData扩展将流转换为实时数据。

视图模型

fun getWeatherForecast(): LiveData<String> {
    return forecastRepository
    .getWeatherForecastEveryTwoSeconds()
    .asLiveData() // Convert flow to live data
}

在你的情况下你可以这样做

private fun getSharedPrefFlow() = callbackFlow {
    val sharedPref = context?.getSharedPreferences("SHARED_PREF_NAME", MODE_PRIVATE)
    sharedPref?.all?.forEach {
        offer(it)
    }
}

getSharedPrefFlow().collect {
    val key = it.key
    val value = it.value
}

编辑

感谢@mark的评论。在视图模型中为getWeatherForecast函数创建一个新的流实际上是不必要的。它可以重写为

fun getWeatherForecast(): Flow<String> {
        return forecastRepository
                .getWeatherForecastEveryTwoSeconds(spendingDetailsRequest)
                    .map {
                        it + " °C"
                    }
    }
6ioyuze2

6ioyuze22#

在新的androidx.lifecycle ktx包中有一个新的Flow.asLiveData()扩展函数。你可以在我的文章中了解更多:https://www.netguru.com/codestories/android-coroutines-%EF%B8%8Fin-2020

jum4pzuy

jum4pzuy3#

在3层体系结构中:data-domain-presentation,Flow应该发生在数据层(数据库,网络,缓存...),然后如Samuel Urbanowicz所述,您可以将FlowMap到LiveData。
一般来说,Flow几乎就是RxJava的Observable(或Flowable)。不要将其与LiveData混淆。
更多:https://medium.com/@elizarov/cold-flows-hot-channels-d74769805f9

i5desfxk

i5desfxk4#

只是想补充一下法提赫的答案,因为它已经有一段时间了。
我可以从多个片段中观察LiveData。我可以用Flow做这个吗?如果是,那么如何?
是的。但是你应该做的方式已经改变了一些。您应该使用repeatOnLifecycle来更安全地从Flows发布到UI。它是新的,文档是稀缺的,但这是它看起来像:

lifecycleScope.launch {
    repeatOnLifecycle(Lifecycle.State.STARTED) {
        viewModel.getWeatherForecast().collect {
           // Safely update the UI
        }
    }
}

这确保了天气预报只在显示时更新UI,而不会浪费资源。是的,您可以同时对来自同一个流的多个片段执行此操作。
我们可以使用map和switchMap从单个LiveData中获得多个LiveData。有没有办法从一个单一的源流有多个流?
这是一个明显的是。流有大量的操作符like map and switchMap
使用MutableLiveData,我可以使用变量引用从任何地方更新数据。有没有什么方法可以用Flow来做同样的事情?
是的。我们现在有MutableStateFlow,它非常接近MutableLiveData,而且功能更强大。

val textFlow = MutableStateFlow("Hello")

someButton.onPress {
    textFlow.value = "World"
}

lifecycleScope.launch {
    repeatOnLifecycle(Lifecycle.State.STARTED) {
        textFlow.collect {
           someTextView.text = it
        }
    }
}

上面的SharedPreferences代码可以稍微修改一下:

private fun getSharedPrefFlow() = callbackFlow {
    val sharedPref = context.getSharedPreferences("SHARED_PREF_NAME", MODE_PRIVATE)
    sharedPref?.all?.forEach {
        trySend(it) // offer is deprecated
    }
}

init {
    lifecycleScope.launch {
        repeatOnLifecycle(Lifecycle.State.STARTED) {
            getSharedPrefFlow()
                .filter { it.key == BIRTHDAY_KEY }
                .collect {
                    birthdayTextView.text = it.value
                }
        }
    }
}
c0vxltue

c0vxltue5#

再补充一点,LiveData不是为异步操作构建的。所有的转换和工作都在主线程中。

Presentation layer -> LiveData is enough
All other layers like Repository -> Use Kotlin flow

相关问题