package X;
import com.bytedance.covode.number.Covode;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
/* renamed from: X.1Gq reason: invalid class name and case insensitive filesystem */
public abstract class AbstractC29991Gq<T> implements AbstractC21760th<T> {
static {
Covode.recordClassIndex(121732);
}
public static <T> AbstractC29991Gq<T> LIZ(AbstractC21750tg<T> r1) {
C22050uA.LIZ((Object) r1, "source is null");
return C22330uc.LIZ(new AnonymousClass1OY(r1));
}
public static <T> AbstractC29991Gq<T> LIZ(AbstractC21760th<T> r1) {
C22050uA.LIZ((Object) r1, "source is null");
return r1 instanceof AbstractC29991Gq ? C22330uc.LIZ((AbstractC29991Gq) r1) : C22330uc.LIZ(new C31991Oi(r1));
}
public static <T1, T2, R> AbstractC29991Gq<R> LIZ(AbstractC21760th<? extends T1> r3, AbstractC21760th<? extends T2> r4, AbstractC21900tv<? super T1, ? super T2, ? extends R> r5) {
C22050uA.LIZ((Object) r3, "source1 is null");
C22050uA.LIZ((Object) r4, "source2 is null");
return LIZ(C22040u9.LIZ((AbstractC21900tv) r5), r3, r4);
}
public static <T, R> AbstractC29991Gq<R> LIZ(AbstractC21940tz<? super Object[], ? extends R> r1, AbstractC21760th<? extends T>... r2) {
C22050uA.LIZ((Object) r1, "zipper is null");
C22050uA.LIZ((Object) r2, "sources is null");
return C22330uc.LIZ(new C32101Ot(r2, r1));
}
public static <T> AbstractC29991Gq<T> LIZ(AbstractC22510uu<? extends T> r1) {
C22050uA.LIZ((Object) r1, "observableSource is null");
return C22330uc.LIZ(new AnonymousClass1OP(r1));
}
public static <T> AbstractC29991Gq<T> LIZ(AbstractC30141Hf<T> r1) {
return C22330uc.LIZ(new C31871Nw(r1));
}
public static <T> AbstractC29991Gq<T> LIZ(T t) {
C22050uA.LIZ((Object) t, "value is null");
return C22330uc.LIZ(new C32011Ok(t));
}
public static <T> AbstractC29991Gq<T> LIZ(Throwable th) {
C22050uA.LIZ((Object) th, "error is null");
return LIZIZ((Callable<? extends Throwable>) C22040u9.LIZ(th));
}
public static <T> AbstractC29991Gq<T> LIZ(Callable<? extends T> callable) {
C22050uA.LIZ((Object) callable, "callable is null");
return C22330uc.LIZ(new C31981Oh(callable));
}
public static <T> AbstractC29991Gq<T> LIZIZ(Callable<? extends Throwable> callable) {
C22050uA.LIZ((Object) callable, "errorSupplier is null");
return C22330uc.LIZ(new C31961Of(callable));
}
private AbstractC30141Hf<T> LJ() {
return this instanceof AbstractC22060uB ? ((AbstractC22060uB) this).LIZ() : C22330uc.LIZ(new C32081Or(this));
}
public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r2, AbstractC21930ty<? super Throwable> r3) {
C22050uA.LIZ((Object) r2, "onSuccess is null");
C22050uA.LIZ((Object) r3, "onError is null");
AnonymousClass1HJ r0 = new AnonymousClass1HJ(r2, r3);
a_(r0);
return r0;
}
public final AbstractC29991Gq<T> LIZ(long j, TimeUnit timeUnit) {
return LIZ(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ), null);
}
public final AbstractC29991Gq<T> LIZ(long j, TimeUnit timeUnit, AbstractC21720td r11, AbstractC21760th<? extends T> r12) {
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) r11, "scheduler is null");
return C22330uc.LIZ(new C32071Oq(this, j, timeUnit, r11, r12));
}
public final AbstractC29991Gq<T> LIZ(AbstractC21720td r2) {
C22050uA.LIZ((Object) r2, "scheduler is null");
return C22330uc.LIZ(new C32031Om(this, r2));
}
public final <R> AbstractC29991Gq<R> LIZ(AbstractC21770ti<? super T, ? extends R> r2) {
return LIZ(((AbstractC21770ti) C22050uA.LIZ((Object) r2, "transformer is null")).LIZ(this));
}
public final AbstractC29991Gq<T> LIZ(AbstractC21880tt r2) {
C22050uA.LIZ((Object) r2, "onFinally is null");
return C22330uc.LIZ(new AnonymousClass1OZ(this, r2));
}
public final AbstractC29991Gq<T> LIZ(AbstractC21890tu<? super T, ? super Throwable> r2) {
C22050uA.LIZ((Object) r2, "onEvent is null");
return C22330uc.LIZ(new C31931Oc(this, r2));
}
public final AbstractC29991Gq<T> LIZ(AbstractC21930ty<? super AbstractC21780tj> r2) {
C22050uA.LIZ((Object) r2, "onSubscribe is null");
return C22330uc.LIZ(new C31941Od(this, r2));
}
public final <R> AbstractC29991Gq<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC21760th<? extends R>> r2) {
C22050uA.LIZ((Object) r2, "mapper is null");
return C22330uc.LIZ(new C31971Og(this, r2));
}
public final <R> R LIZ(AbstractC21730te<T, ? extends R> r2) {
return (R) ((AbstractC21730te) C22050uA.LIZ((Object) r2, "converter is null")).LIZ(this);
}
public abstract void LIZ(AbstractC21740tf<? super T> v);
public final AbstractC21780tj LIZIZ(AbstractC21890tu<? super T, ? super Throwable> r2) {
C22050uA.LIZ((Object) r2, "onCallback is null");
AnonymousClass1HF r0 = new AnonymousClass1HF(r2);
a_(r0);
return r0;
}
public final AbstractC29991Gq<T> LIZIZ() {
return LIZ((AbstractC30141Hf) LJ().LIZLLL());
}
public final AbstractC29991Gq<T> LIZIZ(AbstractC21720td r2) {
C22050uA.LIZ((Object) r2, "scheduler is null");
return C22330uc.LIZ(new C32061Op(this, r2));
}
public final AbstractC29991Gq<T> LIZIZ(AbstractC21880tt r2) {
C22050uA.LIZ((Object) r2, "onDispose is null");
return C22330uc.LIZ(new C31911Oa(this, r2));
}
public final AbstractC29991Gq<T> LIZIZ(AbstractC21930ty<? super T> r2) {
C22050uA.LIZ((Object) r2, "onSuccess is null");
return C22330uc.LIZ(new C31951Oe(this, r2));
}
public final AbstractC29991Gq<T> LIZIZ(T t) {
C22050uA.LIZ((Object) t, "value is null");
return C22330uc.LIZ(new C32041On(this, t));
}
public final <R> AbstractC30181Hj<R> LIZIZ(AbstractC21940tz<? super T, ? extends AbstractC22510uu<? extends R>> r2) {
C22050uA.LIZ((Object) r2, "mapper is null");
return C22330uc.LIZ(new AnonymousClass1OB(this, r2));
}
public final AbstractC21780tj LIZJ() {
return LIZ(C22040u9.LIZLLL, C22040u9.LJFF);
}
public final AbstractC29991Gq<T> LIZJ(AbstractC21930ty<? super Throwable> r2) {
C22050uA.LIZ((Object) r2, "onError is null");
return C22330uc.LIZ(new C31921Ob(this, r2));
}
public final <R> AbstractC29991Gq<R> LIZJ(AbstractC21940tz<? super T, ? extends R> r2) {
C22050uA.LIZ((Object) r2, "mapper is null");
return C22330uc.LIZ(new C32021Ol(this, r2));
}
public final AbstractC21780tj LIZLLL(AbstractC21930ty<? super T> r2) {
return LIZ(r2, C22040u9.LJFF);
}
public final AbstractC29991Gq<T> LIZLLL(AbstractC21940tz<? super Throwable, ? extends AbstractC21760th<? extends T>> r2) {
C22050uA.LIZ((Object) r2, "resumeFunctionInCaseOfError is null");
return C22330uc.LIZ(new C32051Oo(this, r2));
}
public final AbstractC30181Hj<T> LIZLLL() {
return this instanceof AbstractC22070uC ? ((AbstractC22070uC) this).LIZ() : C22330uc.LIZ(new C32091Os(this));
}
@Override // X.AbstractC21760th
public final void a_(AbstractC21740tf<? super T> r4) {
C22050uA.LIZ((Object) r4, "subscriber is null");
AbstractC21740tf<? super T> LIZ = C22330uc.LIZ(this, r4);
C22050uA.LIZ((Object) LIZ, "The RxJavaPlugins.onSubscribe hook returned a null SingleObserver. Please check the handler provided to RxJavaPlugins.setOnSingleSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
try {
LIZ((AbstractC21740tf) 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 AbstractC29991Gq<T> dx_() {
return C22330uc.LIZ(new C32001Oj(this));
}
}