功能全部完成

Linjiajia

2023-08-27 1df231fd6aafa221aef3532d069c7e27d4331be7

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
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 RxJava工具类
*/public class RxUtils {
 
    public static <T> ObservableTransformer<T, T> schedulersTransformer() {
        return upstream -> upstream.subscribeOn(Schedulers.io())
                .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());
    }
 
 
 
}