基本功能完成

Linjiajia

2023-07-25 82e57df230ecb744af6c8865f80870ba03c86d89

 app_base/src/main/java/com/android/app_base/utils/RxUtils.java

@@ -1,15 +1,17 @@
package com.android.app_base.utils;

import io.reactivex.FlowableTransformer;
import io.reactivex.Observable;
import io.reactivex.ObservableSource;
import io.reactivex.ObservableTransformer;
import io.reactivex.Scheduler;
import io.reactivex.android.schedulers.AndroidSchedulers;
import io.reactivex.schedulers.Schedulers;

/**
* @author Ljj
* @date 2023.03.24. 17:42
* @desc
* @desc RxJava工具类
*/public class RxUtils {

    public static <T> ObservableTransformer<T, T> schedulersTransformer() {
@@ -17,7 +19,20 @@
                .observeOn(AndroidSchedulers.mainThread());
    }

    public static <T> ObservableTransformer<T, T> io() {
        return upstream -> upstream.subscribeOn(Schedulers.io());
    }

    private static <T> FlowableTransformer<T, T> schedulerTransformerF(Scheduler scheduler) {
        return flowable ->
                flowable
                        .subscribeOn(scheduler)
                        .observeOn(AndroidSchedulers.mainThread(), true);
    }

    public static <T> FlowableTransformer<T, T> ioF() {
        return schedulerTransformerF(Schedulers.io());
    }