dependencies {    implementation"com.github.akarnokd:rxjava3-bridge:3.0.2"}

Features

Convert between Flowables

via static methods

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.Flowablef2 =RxJavaBridge.toV2Flowable(io.reactivex.rxjava3.core.Flowable)io.reactivex.rxjava3.core.Flowablef3 =RxJavaBridge.toV3Flowable(io.reactivex.Flowable)

via FlowableConverter application

f3 =f2.as(RxJavaBridge.toV3Flowable())f2 =f3.to(RxJavaBridge.toV2Flowable())

Convert between Observables

via static methods

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.Observableo2 =RxJavaBridge.toV2Observable(io.reactivex.rxjava3.core.Observable)io.reactivex.rxjava3.core.Observableo3 =RxJavaBridge.toV3Observable(io.reactivex.Observable)

via ObservableConverter application

o3 =o2.as(RxJavaBridge.toV3Observable())o2 =o3.to(RxJavaBridge.toV2Observable())

Convert between Maybes

via static methods

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.Maybem2 =RxJavaBridge.toV2Maybe(io.reactivex.rxjava3.core.Maybe)io.reactivex.rxjava3.core.Maybem3 =RxJavaBridge.toV3Maybe(io.reactivex.Maybe)

via MaybeConverter application

m3 =m2.as(RxJavaBridge.toV3Maybe())m2 =m3.to(RxJavaBridge.toV2Maybe())

Convert between Singles

via static methods

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.Singles2 =RxJavaBridge.toV2Single(io.reactivex.rxjava3.core.Single)io.reactivex.rxjava3.core.Singles3 =RxJavaBridge.toV3Single(io.reactivex.Single)

via SingleConverter application

s3 =s2.as(RxJavaBridge.toV3Single())s2 =s3.to(RxJavaBridge.toV2Single())

Convert between Completables

via static methods

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.Completablec2 =RxJavaBridge.toV2Completable(io.reactivex.rxjava3.core.Completable)io.reactivex.rxjava3.core.Completablec3 =RxJavaBridge.toV3Completable(io.reactivex.Completable)

via CompletableConverter application

c3 =c2.as(RxJavaBridge.toV3Completable())c2 =c3.to(RxJavaBridge.toV2Completable())

Convert between Disposables

via static methods

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.disposables.Disposabled2 =RxJavaBridge.toV2Disposable(io.reactivex.rxjava3.disposables.Disposable)io.reactivex.rxjava3.disosables.Observabled3 =RxJavaBridge.toV3Disposable(io.reactivex.disposables.Disposable)

Convert between Schedulers

via static methods

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.Schedulersch2 =RxJavaBridge.toV2Scheduler(io.reactivex.rxjava3.core.Scheduler)io.reactivex.rxjava3.core.Schedulersch3 =RxJavaBridge.toV3Scheduler(io.reactivex.Scheduler)

use 3.x standard schedulers in 2.x

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.schedulers.Schedulers.shutdown();RxJavaBridge.startUsingV3Schedulers();// when doneRxJavaBridge.stopUsingV3Schedulers();io.reactivex.schedulers.Schedulers.start();

use 2.x standard schedulers in 3.x

importhu.akarnokd.rxjava3.bridge.RxJavaBridge;io.reactivex.rxjava3.schedulers.Schedulers.shutdown();RxJavaBridge.startUsingV2Schedulers();// when doneRxJavaBridge.stopUsingV2Schedulers();io.reactivex.rxjava3.schedulers.Schedulers.start();