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 funLiveData .switchMap( crossinline transform: (X) -> LiveData ): LiveData = Transformations.switchMap(this) { transform(it) } 复制代码
switchMap() 内部将源 LiveData 的每个值都转换成一个新的 LiveData 并订阅。
liveData是一个顶层方法,用于构建CoroutineLiveData:
public funliveData( 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"



