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 <T> ObservableTransformer<T, T> schedulersTransformer() {
|
return upstream -> upstream.subscribeOn(Schedulers.io())
|
.observeOn(AndroidSchedulers.mainThread());
|
}
|
|
|
|
|
|
}
|
