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

package X;

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

/* renamed from: X.1Gt  reason: invalid class name and case insensitive filesystem */
public abstract class AbstractC30021Gt implements AbstractC22320ub {
    static {
        Covode.recordClassIndex(121739);
    }

    public static AbstractC30021Gt LIZ(long j, TimeUnit timeUnit) {
        return LIZ(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
    }

    public static AbstractC30021Gt LIZ(long j, TimeUnit timeUnit, AbstractC21720td r4) {
        C22050uA.LIZ((Object) timeUnit, "unit is null");
        C22050uA.LIZ((Object) r4, "scheduler is null");
        return C22330uc.LIZ(new C31841Nt(j, timeUnit, r4));
    }

    private AbstractC30021Gt LIZ(AbstractC21930ty<? super AbstractC21780tj> r9, AbstractC21930ty<? super Throwable> r10, AbstractC21880tt r11, AbstractC21880tt r12, AbstractC21880tt r13, AbstractC21880tt r14) {
        C22050uA.LIZ((Object) r9, "onSubscribe is null");
        C22050uA.LIZ((Object) r10, "onError is null");
        C22050uA.LIZ((Object) r11, "onComplete is null");
        C22050uA.LIZ((Object) r12, "onTerminate is null");
        C22050uA.LIZ((Object) r13, "onAfterTerminate is null");
        C22050uA.LIZ((Object) r14, "onDispose is null");
        return C22330uc.LIZ(new C31821Nr(this, r9, r10, r11, r12, r13, r14));
    }

    public static AbstractC30021Gt LIZ(Throwable th) {
        C22050uA.LIZ((Object) th, "error is null");
        return C22330uc.LIZ(new C31781Nn(th));
    }

    public static AbstractC30021Gt LIZ(Callable<? extends AbstractC22320ub> callable) {
        C22050uA.LIZ((Object) callable, "completableSupplier");
        return C22330uc.LIZ(new C31761Nl(callable));
    }

    private AbstractC30021Gt LIZIZ(long j, TimeUnit timeUnit, AbstractC21720td r10) {
        C22050uA.LIZ((Object) timeUnit, "unit is null");
        C22050uA.LIZ((Object) r10, "scheduler is null");
        return C22330uc.LIZ(new C31771Nm(this, j, timeUnit, r10));
    }

    public static AbstractC30021Gt LIZIZ(Callable<?> callable) {
        C22050uA.LIZ((Object) callable, "callable is null");
        return C22330uc.LIZ(new C31791No(callable));
    }

    public static NullPointerException LIZIZ(Throwable th) {
        NullPointerException nullPointerException = new NullPointerException("Actually not, but can't pass out an exception otherwise...");
        nullPointerException.initCause(th);
        return nullPointerException;
    }

    public final AbstractC21780tj LIZ(AbstractC21880tt r2, AbstractC21930ty<? super Throwable> r3) {
        C22050uA.LIZ((Object) r3, "onError is null");
        C22050uA.LIZ((Object) r2, "onComplete is null");
        AnonymousClass1HI r0 = new AnonymousClass1HI(r3, r2);
        LIZ((AbstractC21980u3) r0);
        return r0;
    }

    public final AbstractC30021Gt LIZ(AbstractC21720td r2) {
        C22050uA.LIZ((Object) r2, "scheduler is null");
        return C22330uc.LIZ(new C31801Np(this, r2));
    }

    public final AbstractC30021Gt LIZ(AbstractC21880tt r8) {
        AbstractC21930ty<? super AbstractC21780tj> r1 = C22040u9.LIZLLL;
        AbstractC21880tt r4 = C22040u9.LIZJ;
        return LIZ(r1, r1, r8, r4, r4, C22040u9.LIZJ);
    }

    public final AbstractC30021Gt LIZ(AbstractC21930ty<? super Throwable> r8) {
        AbstractC21930ty<? super AbstractC21780tj> r1 = C22040u9.LIZLLL;
        AbstractC21880tt r3 = C22040u9.LIZJ;
        AbstractC21880tt r5 = C22040u9.LIZJ;
        return LIZ(r1, r8, r3, r3, r5, r5);
    }

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

    @Override // X.AbstractC22320ub
    public final void LIZ(AbstractC21980u3 r3) {
        C22050uA.LIZ((Object) r3, "s is null");
        try {
            AbstractC21980u3 LIZ = C22330uc.LIZ(this, r3);
            C22050uA.LIZ((Object) LIZ, "The RxJavaPlugins.onSubscribe hook returned a null CompletableObserver. Please check the handler provided to RxJavaPlugins.setOnCompletableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
            LIZIZ(LIZ);
        } catch (NullPointerException e) {
            throw e;
        } catch (Throwable th) {
            C21830to.LIZ(th);
            C22330uc.LIZ(th);
            throw LIZIZ(th);
        }
    }

    public final AbstractC21780tj LIZIZ(AbstractC21880tt r2) {
        C22050uA.LIZ((Object) r2, "onComplete is null");
        AnonymousClass1HI r0 = new AnonymousClass1HI(r2);
        LIZ((AbstractC21980u3) r0);
        return r0;
    }

    public final AbstractC30021Gt LIZIZ(long j, TimeUnit timeUnit) {
        return LIZIZ(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
    }

    public final AbstractC30021Gt LIZIZ(AbstractC21720td r2) {
        C22050uA.LIZ((Object) r2, "scheduler is null");
        return C22330uc.LIZ(new C31831Ns(this, r2));
    }

    public abstract void LIZIZ(AbstractC21980u3 v);

    public final AbstractC21780tj dy_() {
        AnonymousClass1HK r0 = new AnonymousClass1HK();
        LIZ(r0);
        return r0;
    }
}