package X;
import com.bytedance.covode.number.Covode;
import com.swift.sandhook.utils.FileUtils;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
/* renamed from: X.1Hf reason: invalid class name and case insensitive filesystem */
public abstract class AbstractC30141Hf<T> implements AbstractC24820yd<T> {
public static final int LIZ = Math.max(1, Integer.getInteger("rx2.buffer-size", (int) FileUtils.FileMode.MODE_IWUSR).intValue());
static {
Covode.recordClassIndex(122267);
}
public static AbstractC30141Hf<Long> LIZ(long j, long j2, TimeUnit timeUnit, AbstractC21720td r8) {
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) r8, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1O1(Math.max(0L, j), Math.max(0L, j2), timeUnit, r8));
}
private AbstractC30141Hf<T> LIZ(AbstractC21720td r2, int i2) {
C22050uA.LIZ((Object) r2, "scheduler is null");
C22050uA.LIZ(i2, "bufferSize");
return C22330uc.LIZ(new C33931Vu(this, r2, i2));
}
private AbstractC30141Hf<T> LIZ(AbstractC21720td r2, boolean z) {
C22050uA.LIZ((Object) r2, "scheduler is null");
return C22330uc.LIZ(new C33881Vp(this, r2, z));
}
private <R> AbstractC30141Hf<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC24820yd<? extends R>> r2, int i2, int i3) {
C22050uA.LIZ((Object) r2, "mapper is null");
C22050uA.LIZ(i2, "maxConcurrency");
C22050uA.LIZ(i3, "bufferSize");
if (!(this instanceof AbstractCallableC22080uD)) {
return C22330uc.LIZ(new C33911Vs(this, r2, i2, i3));
}
Object call = ((AbstractCallableC22080uD) this).call();
return call == null ? C22330uc.LIZ(C31891Ny.LIZIZ) : C22100uF.LIZ(call, r2);
}
public static <T> AbstractC30141Hf<T> LIZ(AbstractC22440un<T> r1, EnumC21700tb r2) {
C22050uA.LIZ((Object) r1, "source is null");
C22050uA.LIZ((Object) r2, "mode is null");
return C22330uc.LIZ(new C31881Nx(r1, r2));
}
public static <T> AbstractC30141Hf<T> LIZ(T t) {
C22050uA.LIZ((Object) t, "item is null");
return C22330uc.LIZ((AbstractC30141Hf) new AnonymousClass1O2(t));
}
public static <T> AbstractC30141Hf<T> LIZ(Callable<? extends T> callable) {
C22050uA.LIZ((Object) callable, "supplier is null");
return C22330uc.LIZ((AbstractC30141Hf) new CallableC31901Nz(callable));
}
public static AbstractC30141Hf<Long> LIZ(TimeUnit timeUnit) {
return LIZ(40, 40, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r3, AbstractC21930ty<? super Throwable> r4) {
return LIZ(r3, r4, C22040u9.LIZJ, AnonymousClass1HM.INSTANCE);
}
public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r2, AbstractC21930ty<? super Throwable> r3, AbstractC21880tt r4) {
return LIZ(r2, r3, r4, AnonymousClass1HM.INSTANCE);
}
public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r2, AbstractC21930ty<? super Throwable> r3, AbstractC21880tt r4, AbstractC21930ty<? super AbstractC24840yf> r5) {
C22050uA.LIZ((Object) r2, "onNext is null");
C22050uA.LIZ((Object) r3, "onError is null");
C22050uA.LIZ((Object) r4, "onComplete is null");
C22050uA.LIZ((Object) r5, "onSubscribe is null");
AnonymousClass1P1 r0 = new AnonymousClass1P1(r2, r3, r4, r5);
LIZ((AbstractC30161Hh) r0);
return r0;
}
public final AbstractC30141Hf<T> LIZ() {
int i2 = LIZ;
C22050uA.LIZ(i2, "bufferSize");
return C22330uc.LIZ(new C33941Vv(this, i2, C22040u9.LIZJ));
}
public final AbstractC30141Hf<T> LIZ(long j, AbstractC21970u2<? super Throwable> r6) {
if (j >= 0) {
C22050uA.LIZ((Object) r6, "predicate is null");
return C22330uc.LIZ(new C33981Vz(this, j, r6));
}
throw new IllegalArgumentException("times >= 0 required but it was ".concat(String.valueOf(j)));
}
public final AbstractC30141Hf<T> LIZ(AbstractC21720td r2) {
return LIZ(r2, LIZ);
}
public final AbstractC30141Hf<T> LIZ(AbstractC21930ty<? super T> r3) {
AbstractC21930ty<? super Throwable> r1 = C22040u9.LIZLLL;
AbstractC21880tt r0 = C22040u9.LIZJ;
return LIZ(r3, r1, r0, r0);
}
public final AbstractC30141Hf<T> LIZ(AbstractC21930ty<? super T> r7, AbstractC21930ty<? super Throwable> r8, AbstractC21880tt r9, AbstractC21880tt r10) {
C22050uA.LIZ((Object) r7, "onNext is null");
C22050uA.LIZ((Object) r8, "onError is null");
C22050uA.LIZ((Object) r9, "onComplete is null");
C22050uA.LIZ((Object) r10, "onAfterTerminate is null");
return C22330uc.LIZ(new C33891Vq(this, r7, r8, r9, r10));
}
public final <R> AbstractC30141Hf<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC24820yd<? extends R>> r2) {
int i2 = LIZ;
return LIZ(r2, i2, i2);
}
public final AbstractC30141Hf<T> LIZ(AbstractC21970u2<? super T> r2) {
C22050uA.LIZ((Object) r2, "predicate is null");
return C22330uc.LIZ(new C33901Vr(this, r2));
}
public final <R> R LIZ(AbstractC22340ud<T, ? extends R> r2) {
return (R) ((AbstractC22340ud) C22050uA.LIZ((Object) r2, "converter is null")).LIZ(this);
}
public abstract void LIZ(AbstractC24830ye<? super T> v);
public final void LIZ(AbstractC30161Hh<? super T> r4) {
C22050uA.LIZ((Object) r4, "s is null");
try {
AbstractC24830ye<? super T> LIZ2 = C22330uc.LIZ(this, r4);
C22050uA.LIZ((Object) LIZ2, "The RxJavaPlugins.onSubscribe hook returned a null FlowableSubscriber. Please check the handler provided to RxJavaPlugins.setOnFlowableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
LIZ((AbstractC24830ye) LIZ2);
} catch (NullPointerException e) {
throw e;
} catch (Throwable th) {
C21830to.LIZ(th);
C22330uc.LIZ(th);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
public final AbstractC21780tj LIZIZ(AbstractC21930ty<? super T> r4) {
return LIZ(r4, C22040u9.LJFF, C22040u9.LIZJ, AnonymousClass1HM.INSTANCE);
}
public final AbstractC30141Hf<T> LIZIZ() {
return C22330uc.LIZ((AbstractC30141Hf) new C33951Vw(this));
}
public final AbstractC30141Hf<T> LIZIZ(AbstractC21720td r2) {
C22050uA.LIZ((Object) r2, "scheduler is null");
return LIZ(r2, !(this instanceof C31881Nx));
}
public final <R> AbstractC30141Hf<R> LIZIZ(AbstractC21940tz<? super T, ? extends R> r2) {
C22050uA.LIZ((Object) r2, "mapper is null");
return C22330uc.LIZ(new C33921Vt(this, r2));
}
public final AbstractC30141Hf<T> LIZJ() {
return C22330uc.LIZ(new C33971Vy(this));
}
public final AbstractC30141Hf<T> LIZLLL() {
return LIZ(1, C22040u9.LJII);
}
public final AbstractC30171Hi<T> LJ() {
return C22330uc.LIZ(new C31861Nv(this));
}
@Override // X.AbstractC24820yd
public final void a_(AbstractC24830ye<? super T> r2) {
if (r2 instanceof AbstractC30161Hh) {
LIZ((AbstractC30161Hh) ((AbstractC30161Hh) r2));
return;
}
C22050uA.LIZ((Object) r2, "s is null");
LIZ((AbstractC30161Hh) new AnonymousClass1P2(r2));
}
}