如何转换 RX.可观察 IO.reactivex.Observable.

Question

我正在使用rxjava jdbc库查询数据库，但使用rx1支持的库。

rx.Observable<T> rx1 =Database.from(url, user,password).autoMap(resultType);

我正在尝试将其转换为

io.reactivex.Observable.fromIterable(BlockingObservable.from(rx1).toIterable());

但它不起作用，我可以得到 RX Java 2 的等效代码.我的意思是我想回到io.reactivex.Observable<T>而不是rx.Observable<T>。

谢谢你的帮助。

Answer 1

您可以使用RxJavaInterop库在 RxJava1 和 RxJava2 类型之间进行转换。它提供了在两个版本支持的所有不同反应类型之间进行转换的函数。在您的情况下，您可以将 RxJava1Observable转换为 RxJava2Observable如下所示：

io.reactivex.Observable<T> rx2 = RxJavaInterop.toV2Observable(rx1);

该库由 RxJava 项目本身的首席开发人员维护，因此您可以确信它是可靠的。只需确保使用 v0.x 分支中的库版本 - 更新的版本 (3.x( 用于在 RxJava1 和 RxJava3 之间进行转换。