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());
            }
        };
    }
}