24 lines
977 B
Java
24 lines
977 B
Java
package com.ubt.jimu.base.mvp;
|
|
|
|
import io.reactivex.Observable;
|
|
import io.reactivex.ObservableSource;
|
|
import io.reactivex.ObservableTransformer;
|
|
import io.reactivex.android.schedulers.AndroidSchedulers;
|
|
import io.reactivex.schedulers.Schedulers;
|
|
import java.util.concurrent.TimeUnit;
|
|
|
|
/* loaded from: classes.dex */
|
|
public class RxHelper {
|
|
public static boolean DEVELOPMODE = true;
|
|
public static long RX_DURATION = 1000;
|
|
|
|
public static <T> ObservableTransformer<T, T> transformer(final boolean z) {
|
|
return new ObservableTransformer<T, T>() { // from class: com.ubt.jimu.base.mvp.RxHelper.1
|
|
@Override // io.reactivex.ObservableTransformer
|
|
public ObservableSource<T> apply(Observable<T> observable) {
|
|
return observable.debounce(RxHelper.RX_DURATION, TimeUnit.MILLISECONDS).subscribeOn(Schedulers.b()).unsubscribeOn(Schedulers.b()).observeOn(z ? AndroidSchedulers.a() : Schedulers.b());
|
|
}
|
|
};
|
|
}
|
|
}
|