JarCastingRxJavaAndroidInterop
Interop library for exposing Android's main thread and loopers as RxJava 3 Schedulers directly.
Ported from https://github.com/ReactiveX/RxAndroid
RxJava 3:
dependencies {
implementation "com.github.akarnokd:rxjava3-android-interop:3.0.0-RC6"
}
Usage
import hu.akarnokd.rxjava3.android.*;
import io.reactivex.rxjava3.core.*;
Flowable.intervalRange(1, 10, 1, 1, TimeUnit.SECONDS, AndroidInteropSchedulers.mainThread())
.subscribe(System.out::println);
plugins for overrides
import hu.akarnokd.rxjava3.android.*;
AndroidInteropPlugins.setMainThreadSchedulerHandler(scheduler -> scheduler);