TikTok.apk(点击下载) / AbstractC30171Hi.java

package X;

import com.bytedance.covode.number.Covode;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;

/* renamed from: X.1Hi  reason: invalid class name and case insensitive filesystem */
public abstract class AbstractC30171Hi<T> implements AbstractC22470uq<T> {
    static {
        Covode.recordClassIndex(122314);
    }

    public static AbstractC30171Hi<Long> LIZ(long j, TimeUnit timeUnit, AbstractC21720td r6) {
        C22050uA.LIZ((Object) timeUnit, "unit is null");
        C22050uA.LIZ((Object) r6, "scheduler is null");
        return C22330uc.LIZ(new AnonymousClass1O9(Math.max(0L, j), timeUnit, r6));
    }

    public static <T> AbstractC30171Hi<T> LIZ(AbstractC22460up<T> r1) {
        C22050uA.LIZ((Object) r1, "onSubscribe is null");
        return C22330uc.LIZ(new AnonymousClass1O4(r1));
    }

    private <U> AbstractC30171Hi<T> LIZ(AbstractC22470uq<U> r2) {
        C22050uA.LIZ((Object) r2, "timeoutIndicator is null");
        return C22330uc.LIZ(new AnonymousClass1WA(this, r2));
    }

    public static <T> AbstractC30171Hi<T> LIZ(T t) {
        C22050uA.LIZ((Object) t, "item is null");
        return C22330uc.LIZ((AbstractC30171Hi) new AnonymousClass1O8(t));
    }

    public static <T> AbstractC30171Hi<T> LIZ(Callable<? extends T> callable) {
        C22050uA.LIZ((Object) callable, "callable is null");
        return C22330uc.LIZ((AbstractC30171Hi) new AnonymousClass1O6(callable));
    }

    private AbstractC30171Hi<T> LIZIZ(long j, TimeUnit timeUnit, AbstractC21720td r5) {
        return LIZ((AbstractC22470uq) LIZ(j, timeUnit, r5));
    }

    private <E extends AbstractC22450uo<? super T>> E LIZJ(E e) {
        LIZ((AbstractC22450uo) e);
        return e;
    }

    private AbstractC30141Hf<T> LIZLLL() {
        return this instanceof AbstractC22060uB ? ((AbstractC22060uB) this).LIZ() : C22330uc.LIZ(new AnonymousClass1OA(this));
    }

    public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r2, AbstractC21930ty<? super Throwable> r3) {
        return LIZ(r2, r3, C22040u9.LIZJ);
    }

    public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r2, AbstractC21930ty<? super Throwable> r3, AbstractC21880tt r4) {
        C22050uA.LIZ((Object) r2, "onSuccess is null");
        C22050uA.LIZ((Object) r3, "onError is null");
        C22050uA.LIZ((Object) r4, "onComplete is null");
        return (AbstractC21780tj) LIZJ(new AnonymousClass1HN(r2, r3, r4));
    }

    public final AbstractC30171Hi<T> LIZ(long j, TimeUnit timeUnit) {
        return LIZIZ(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
    }

    public final AbstractC30171Hi<T> LIZ(AbstractC21720td r2) {
        C22050uA.LIZ((Object) r2, "scheduler is null");
        return C22330uc.LIZ(new AnonymousClass1W5(this, r2));
    }

    public final AbstractC30171Hi<T> LIZ(AbstractC21880tt r2) {
        C22050uA.LIZ((Object) r2, "onFinally is null");
        return C22330uc.LIZ(new AnonymousClass1W1(this, r2));
    }

    public final AbstractC30171Hi<T> LIZ(AbstractC21930ty<? super T> r2) {
        C22050uA.LIZ((Object) r2, "doAfterSuccess is null");
        return C22330uc.LIZ(new AnonymousClass1W0(this, r2));
    }

    public final <R> AbstractC30171Hi<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC22470uq<? extends R>> r2) {
        C22050uA.LIZ((Object) r2, "mapper is null");
        return C22330uc.LIZ(new AnonymousClass1W3(this, r2));
    }

    public final AbstractC30171Hi<T> LIZ(AbstractC21970u2<? super T> r2) {
        C22050uA.LIZ((Object) r2, "predicate is null");
        return C22330uc.LIZ(new AnonymousClass1W2(this, r2));
    }

    @Override // X.AbstractC22470uq
    public final void LIZ(AbstractC22450uo<? super T> r4) {
        C22050uA.LIZ((Object) r4, "observer is null");
        AbstractC22450uo<? super T> LIZ = C22330uc.LIZ(this, r4);
        C22050uA.LIZ((Object) LIZ, "The RxJavaPlugins.onSubscribe hook returned a null MaybeObserver. Please check the handler provided to RxJavaPlugins.setOnMaybeSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
        try {
            LIZIZ(LIZ);
        } catch (NullPointerException e) {
            throw e;
        } catch (Throwable th) {
            C21830to.LIZ(th);
            NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final AbstractC30021Gt LIZIZ() {
        return C22330uc.LIZ(new AnonymousClass1O7(this));
    }

    public final AbstractC30021Gt LIZIZ(AbstractC21940tz<? super T, ? extends AbstractC22320ub> r2) {
        C22050uA.LIZ((Object) r2, "mapper is null");
        return C22330uc.LIZ(new AnonymousClass1O5(this, r2));
    }

    public final AbstractC30171Hi<T> LIZIZ(AbstractC21720td r2) {
        C22050uA.LIZ((Object) r2, "scheduler is null");
        return C22330uc.LIZ(new AnonymousClass1W9(this, r2));
    }

    public final AbstractC30171Hi<T> LIZIZ(AbstractC21880tt r10) {
        AbstractC21930ty<Object> r3 = C22040u9.LIZLLL;
        AbstractC21880tt r7 = C22040u9.LIZJ;
        return C22330uc.LIZ(new AnonymousClass1W8(this, r3, r3, C22040u9.LIZLLL, (AbstractC21880tt) C22050uA.LIZ((Object) r10, "onComplete is null"), r7, r7));
    }

    public final AbstractC30171Hi<T> LIZIZ(AbstractC21930ty<? super Throwable> r10) {
        AbstractC21930ty<Object> r3 = C22040u9.LIZLLL;
        AbstractC21880tt r6 = C22040u9.LIZJ;
        return C22330uc.LIZ(new AnonymousClass1W8(this, r3, r3, (AbstractC21930ty) C22050uA.LIZ((Object) r10, "onError is null"), r6, r6, C22040u9.LIZJ));
    }

    public final AbstractC30171Hi<T> LIZIZ(AbstractC21970u2<? super Throwable> r2) {
        C22050uA.LIZ((Object) r2, "predicate is null");
        return C22330uc.LIZ(new AnonymousClass1W6(this, r2));
    }

    public abstract void LIZIZ(AbstractC22450uo<? super T> v);

    public final AbstractC21780tj LIZJ() {
        return LIZ(C22040u9.LIZLLL, C22040u9.LJFF, C22040u9.LIZJ);
    }

    public final AbstractC30171Hi<T> LIZJ(AbstractC21930ty<? super AbstractC21780tj> r10) {
        AbstractC21930ty<Object> r4 = C22040u9.LIZLLL;
        AbstractC21880tt r6 = C22040u9.LIZJ;
        return C22330uc.LIZ(new AnonymousClass1W8(this, (AbstractC21930ty) C22050uA.LIZ((Object) r10, "onSubscribe is null"), r4, r4, r6, r6, C22040u9.LIZJ));
    }

    public final <R> AbstractC30171Hi<R> LIZJ(AbstractC21940tz<? super T, ? extends R> r2) {
        C22050uA.LIZ((Object) r2, "mapper is null");
        return C22330uc.LIZ(new AnonymousClass1W4(this, r2));
    }

    public AbstractC30171Hi<T> LIZJ(AbstractC21970u2<? super Throwable> r4) {
        return LIZLLL().LIZ(2, r4).LJ();
    }

    public final AbstractC30171Hi<T> LIZLLL(AbstractC21930ty<? super T> r10) {
        AbstractC21930ty<Object> r5 = C22040u9.LIZLLL;
        AbstractC21880tt r6 = C22040u9.LIZJ;
        return C22330uc.LIZ(new AnonymousClass1W8(this, C22040u9.LIZLLL, (AbstractC21930ty) C22050uA.LIZ((Object) r10, "onSubscribe is null"), r5, r6, r6, C22040u9.LIZJ));
    }

    public final AbstractC30171Hi<T> LIZLLL(AbstractC21940tz<? super Throwable, ? extends T> r2) {
        C22050uA.LIZ((Object) r2, "valueSupplier is null");
        return C22330uc.LIZ(new AnonymousClass1W7(this, r2));
    }

    public final AbstractC21780tj LJ(AbstractC21930ty<? super T> r3) {
        return LIZ(r3, C22040u9.LJFF, C22040u9.LIZJ);
    }

    public final T dw_() {
        AnonymousClass1HH r0 = new AnonymousClass1HH();
        LIZ((AbstractC22450uo) r0);
        return (T) r0.LIZ();
    }
}