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 ); /