android - LiveData 到 Observable 转换使用 RxJava

Question

通过使用 LiveDataReactiveStreams，可以将 LiveData 转换为 Publisher。但是为了使用 RxJava2 方法，例如 withLatestFrom，我需要有一个 Observable 而不是 Publisher。除了使用这个(过时的)库之外，还有其他方法可以将 Publisher 转换为 Observable - RxJava<->ReactiveStreams ？

Answer 1

// Flowable to LiveData

val flowable = Flowable.just(1, 2, 3)
val liveData = LiveDataReactiveStreams.fromPublisher<Int>(flowable)

// From Live Data to Publisher(Flowable is also publisher)

LiveDataReactiveStreams.toPublisher(this, liveData).subscribe(object: Subscriber<Int>{
    override fun onNext(t: Int?) {}

    override fun onComplete() {}

    override fun onSubscribe(s: Subscription?) {}

    override fun onError(t: Throwable?) {}
})