如何变换 LiveData 数据及注意事项

androidx.lifecycle.Transformations类提供了三个变换 LiveData 数据的方法，最常用的是 Transformations.map()，它使用MediatorLiveData作为数据的中间消费者，并将变换后的数据传递给最终消费者。需要注意的是，数据变化 *** 作都发生在主线程，主线程有可能被耗时 *** 作阻塞。解决方案是将 LiveData 数据变换 *** 作异步化，比如通过CoroutineLiveData。

还是购物-结算的场景：购物车和结算页都是两个 Fragment，将商品列表存在 LiveData 中，购物车及结算页都观察它。结算界面对打折商品有一个特殊的 UI 展示。

此时就可以将商品列表 LiveData 进行一次变换（过滤）得到一个新的打折商品列表：

class MyViewModel : ViewModel() {
    // 商品列表
    val selectsListLiveData = MutableLiveData>()
    // 打折商品列表
    val foodListLiveData = Transformations.map(selectsListLiveData) { list ->
        list.filter { it.startsWith("discount") }
    }
}
复制代码

每当商品列表发生变化，打折商品列表都会收到通知，并过滤出新的打折商品。打折商品列表是一个新的 LiveData，可以单独被观察。

其中的过滤列表 *** 作发生在主线程，如果业务略复杂，数据变换 *** 作耗时的话，可能阻塞主线程。

如何将 LiveData 变换数据异步化？

LiveData 的 Kotlin 扩展包里提供了一个将 LiveData 和协程结合的产物：

class MyViewModel : ViewModel() {
    // 商品列表
    val selectsListLiveData = MutableLiveData>()
    // 用异步方式获取打折商品列表
    val asyncLiveData = selectsListLiveData.switchMap { list ->
        // 将源 LiveData 中的值转换成一个 CoroutineLiveData
        liveData(Dispatchers.Default) {
            emit( list.filter { it.startsWith("discount") } )
        }
    }
}
复制代码

其中的switchMap()是 LiveData 的扩展方法，它是对Transformations.switchMap()的封装，用于方便链式调用：

public inline fun  LiveData.switchMap(
    crossinline transform: (X) -> LiveData
): LiveData = Transformations.switchMap(this) { transform(it) }
复制代码

switchMap() 内部将源 LiveData 的每个值都转换成一个新的 LiveData 并订阅。

liveData是一个顶层方法，用于构建CoroutineLiveData：

public fun  liveData(
    context: CoroutineContext = EmptyCoroutineContext,
    timeoutInMs: Long = DEFAULT_TIMEOUT,
    block: suspend LiveDataScope.() -> Unit
): LiveData = CoroutineLiveData(context, timeoutInMs, block)
复制代码

CoroutineLiveData 将更新 LiveData 值的 *** 作封装到一个挂起方法中，可以通过协程上下文指定执行的线程。

使用 CoroutineLiveData 需要添加如下依赖：

implementation  "androidx.lifecycle:lifecycle-livedata-ktx:2.3.1"