package com.android.app_base.utils; import io.reactivex.Observable; import io.reactivex.ObservableSource; import io.reactivex.ObservableTransformer; import io.reactivex.android.schedulers.AndroidSchedulers; import io.reactivex.schedulers.Schedulers; /** * @author Ljj * @date 2023.03.24. 17:42 * @desc */public class RxUtils { public static ObservableTransformer schedulersTransformer() { return upstream -> upstream.subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()); } }