RxJava2Interop
Library to convert between RxJava 1.x and 2.x reactive types.
Releases
gradle
dependencies {
compile "com.github.akarnokd:rxjava2-interop:0.1.0"
}
Maven search:
Usage
import static hu.akarnokd.rxjava.interop.RxJavaInterop.*;
// convert from 1.x to 2.x
io.reactivex.Flowable f2 = RxJavaInterop.toV2Flowable(rx.Observable);
io.reactivex.Observable o2 = RxJavaInterop.toV2Observabe(rx.Observable);
io.reactive.Single s2 = RxJavaInterop.toV2Single(rx.Single);
io.reactivex.Completable c2 = RxJavaInterop.toV2Completable(rx.Completable);
// convert from 2.x to 1.x
rx.Observable o1 = RxJavaInterop.toV1Observable(Publisher);
rx.Observable q1 = RxJavaInterop.toV1Observable(ObservableSource, BackpressureStrategy);
rx.Single s1 = RxJavaInterop.toV1Single(SingleSource);
rx.Completable c1 = RxJavaInterop.toV1Completable(CompletableSource);