利用Kotlin扩展函数将RxJava可观测数据转换为实时数据

Question

我使用LiveDatareActiveStreams.FromPublisher()库在代码中使用了大量转换为LiveData的RxJavaObservables。所以我想在RxJava Observable中添加一个扩展函数，以便轻松地将它们转换为livedata。

这些是我的扩展函数：

fun <T> Flowable<T>.toLiveData() :  LiveData<T> {
    return LiveDataReactiveStreams.fromPublisher(this)
}

fun <T> Observable<T>.toLiveData(backPressureStrategy: BackpressureStrategy) :  LiveData<T> {
    return LiveDataReactiveStreams.fromPublisher(this.toFlowable(backPressureStrategy))
}

fun <T> Single<T>.toLiveData() :  LiveData<T> {
    return LiveDataReactiveStreams.fromPublisher(this.toFlowable())
}

fun <T> Maybe<T>.toLiveData() :  LiveData<T> {
    return LiveDataReactiveStreams.fromPublisher(this.toFlowable())
}

fun <T> Completable.toLiveData() :  LiveData<T> {
    return LiveDataReactiveStreams.fromPublisher(this.toFlowable())
}

null

附注。

我刚认识Kotlin所以我想问这些问题。如有任何帮助，我们将不胜感激。非常感谢。

Answer 1

简而言之：

• flowable.ToLiveData()已在AndroidX中。lifecycle:lifecycle-reactivestreams-ktx项目
• Observable.ToLiveData()应该很有用
• single.toLiveData()在实践中可能没有用处
• 可能.ToLiveData()在实践中可能不有用
• completable.ToLiveData()实际上没有意义

我觉得这是个不错的主意。LiveData的一个优点是可以直接在数据绑定布局中使用它。假设在您拥有的视图模型中：

val user: LiveData<User>

data class User(val firstName: String, val lastName: String)

android:text="${viewModel.user.firstName}"

binding.setLifecycleOwner(this)

从反应流转换为实时数据时有一些考虑（就像我想在循环后恢复倒计时时那样），但我不认为它们与您提供的扩展函数有关，这些函数似乎起到了作用。这里要记住的问题是，当生命周期所有者从活动状态移动到非活动状态时，publisherlivedata取消对流的订阅，而当状态更改为活动状态时，它将创建一个新的订阅，这意味着在许多情况下重新启动流（我猜是在流为“冷”的情况下），而您可能希望在循环或其他配置更改后从原来的位置恢复流。另一方面，如果流是“热”的，则在非活动状态期间会忽略排放。我认为这个问题必须解决，即使您直接使用反应流和手动处理生命周期。但问题是，仅仅将反应流转换为livedata并不足以解决这个问题。

将这些方法记录为不处理错误状态是很好的，错误状态必须在上游处理。或者，这可能是这些函数的改进之一--首先转换流以处理错误（例如，作为带有默认值的lambda参数）。另一种可能是使用result（目前是实验性的），或者类似于封装成功或错误的东西。

作为事后的思考，关于我上面写的这部分：

从反应流转换为活动数据时有一些考虑因素，但我认为它们与您呈现的扩展函数无关。

我仍然认为它在一般情况下是正确的，但是我不确定您是否真的希望在实践中大多数时候使用single.toLiveData()和maybe.toLiveData()。由于maybe和single是对一次性操作进行建模，因此在没有活动观察者时最好不要取消它，而在有新的活动观察者时必须重新启动它。相反，发布到一些mutablelivedata并在oncleared中处理single/maybe可能是有用的（我不确定是否可以封装在扩展函数中）。它们仍然可能有一些用处，但我现在根本看不出来。

顺便说一下，您的flowable.tolivedata()已经在androidx.lifecycle:lifecycle-reactivestreams-ktx工件中。

这使得Observable.ToLiveData()，我认为它应该和flowable一样有用。