package X;
import com.bytedance.covode.number.Covode;
import com.oplus.ocs.base.common.api.Api;
import java.util.Collection;
import java.util.List;
import java.util.NoSuchElementException;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;
/* renamed from: X.1Hj reason: invalid class name and case insensitive filesystem */
public abstract class AbstractC30181Hj<T> implements AbstractC22510uu<T> {
static {
Covode.recordClassIndex(122320);
}
public static AbstractC30181Hj<Long> LIZ(long j, long j2, long j3, TimeUnit timeUnit) {
return LIZ(j, j2, j3, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public static AbstractC30181Hj<Long> LIZ(long j, long j2, long j3, TimeUnit timeUnit, AbstractC21720td r18) {
if (j2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(j2)));
} else if (j2 == 0) {
return C22330uc.LIZ(AnonymousClass1OW.LIZ).LIZIZ(j3, timeUnit, r18);
} else {
long j4 = j + (j2 - 1);
if (j <= 0 || j4 >= 0) {
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) r18, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1OK(j, j4, Math.max(0L, j3), Math.max(0L, 1L), timeUnit, r18));
}
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
}
public static AbstractC30181Hj<Long> LIZ(long j, long j2, TimeUnit timeUnit) {
return LIZ(j, j2, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public static AbstractC30181Hj<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 AnonymousClass1OJ(Math.max(0L, j), Math.max(0L, j2), timeUnit, r8));
}
public static AbstractC30181Hj<Long> LIZ(long j, TimeUnit timeUnit) {
return LIZ(j, j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public static AbstractC30181Hj<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 AnonymousClass1OQ(Math.max(j, 0L), timeUnit, r6));
}
private <U extends Collection<? super T>> AbstractC30181Hj<U> LIZ(long j, TimeUnit timeUnit, AbstractC21720td r14, Callable<U> callable) {
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) r14, "scheduler is null");
C22050uA.LIZ((Object) callable, "bufferSupplier is null");
C22050uA.LIZ((int) Api.BaseClientBuilder.API_PRIORITY_OTHER, "count");
return C22330uc.LIZ(new AnonymousClass1WT(this, j, j, timeUnit, r14, callable, Api.BaseClientBuilder.API_PRIORITY_OTHER));
}
private AbstractC30181Hj<T> LIZ(AbstractC21720td r2, int i2) {
C22050uA.LIZ((Object) r2, "scheduler is null");
C22050uA.LIZ(i2, "bufferSize");
return C22330uc.LIZ(new AnonymousClass1WF(this, r2, i2));
}
private AbstractC30181Hj<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 C33991Wa(this, r7, r8, r9, r10));
}
private <R> AbstractC30181Hj<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC22510uu<? extends R>> r7, int i2, int i3) {
C22050uA.LIZ((Object) r7, "mapper is null");
C22050uA.LIZ(i2, "maxConcurrency");
C22050uA.LIZ(i3, "prefetch");
return C22330uc.LIZ(new AnonymousClass1WV(this, r7, EnumC22230uS.BOUNDARY, i2, i3));
}
public static <T, R> AbstractC30181Hj<R> LIZ(AbstractC21940tz<? super Object[], ? extends R> r2, int i2, AbstractC22510uu<? extends T>... r4) {
if (r4.length == 0) {
return C22330uc.LIZ(AnonymousClass1OW.LIZ);
}
C22050uA.LIZ((Object) r2, "zipper is null");
C22050uA.LIZ(i2, "bufferSize");
return C22330uc.LIZ(new AnonymousClass1OS(r4, null, r2, i2));
}
private <K, V> AbstractC30181Hj<AbstractC183887Kn<K, V>> LIZ(AbstractC21940tz<? super T, ? extends K> r2, AbstractC21940tz<? super T, ? extends V> r3, int i2) {
C22050uA.LIZ((Object) r2, "keySelector is null");
C22050uA.LIZ((Object) r3, "valueSelector is null");
C22050uA.LIZ(i2, "bufferSize");
return C22330uc.LIZ(new AnonymousClass1WC(this, r2, r3, i2));
}
private <R> AbstractC30181Hj<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC22510uu<? extends R>> r7, boolean z, int i2, int i3) {
C22050uA.LIZ((Object) r7, "mapper is null");
C22050uA.LIZ(i2, "maxConcurrency");
C22050uA.LIZ(i3, "bufferSize");
if (!(this instanceof AbstractCallableC22080uD)) {
return C22330uc.LIZ(new C34021Wd(this, r7, z, i2, i3));
}
Object call = ((AbstractCallableC22080uD) this).call();
return call == null ? C22330uc.LIZ(AnonymousClass1OW.LIZ) : C22110uG.LIZ(call, r7);
}
public static <T> AbstractC30181Hj<T> LIZ(AbstractC22500ut<T> r1) {
C22050uA.LIZ((Object) r1, "source is null");
return C22330uc.LIZ(new AnonymousClass1OT(r1));
}
public static <T> AbstractC30181Hj<T> LIZ(AbstractC22510uu<? extends T> r4, AbstractC22510uu<? extends T> r5) {
C22050uA.LIZ((Object) r4, "source1 is null");
C22050uA.LIZ((Object) r5, "source2 is null");
return LIZ((Object[]) new AbstractC22510uu[]{r4, r5}).LIZ((AbstractC21940tz) C22040u9.LIZ, false, 2);
}
public static <T1, T2, R> AbstractC30181Hj<R> LIZ(AbstractC22510uu<? extends T1> r4, AbstractC22510uu<? extends T2> r5, AbstractC21900tv<? super T1, ? super T2, ? extends R> r6) {
C22050uA.LIZ((Object) r4, "source1 is null");
C22050uA.LIZ((Object) r5, "source2 is null");
return LIZ(C22040u9.LIZ((AbstractC21900tv) r6), AbstractC30141Hf.LIZ, r4, r5);
}
public static <T> AbstractC30181Hj<T> LIZ(AbstractC22510uu<? extends T> r4, AbstractC22510uu<? extends T> r5, AbstractC22510uu<? extends T> r6) {
C22050uA.LIZ((Object) r4, "source1 is null");
C22050uA.LIZ((Object) r5, "source2 is null");
C22050uA.LIZ((Object) r6, "source3 is null");
return LIZ((Object[]) new AbstractC22510uu[]{r4, r5, r6}).LIZ((AbstractC21940tz) C22040u9.LIZ, false, 3);
}
public static <T1, T2, T3, R> AbstractC30181Hj<R> LIZ(AbstractC22510uu<? extends T1> r4, AbstractC22510uu<? extends T2> r5, AbstractC22510uu<? extends T3> r6, AbstractC21950u0<? super T1, ? super T2, ? super T3, ? extends R> r7) {
C22050uA.LIZ((Object) r4, "source1 is null");
C22050uA.LIZ((Object) r5, "source2 is null");
C22050uA.LIZ((Object) r6, "source3 is null");
return LIZ(C22040u9.LIZ((AbstractC21950u0) r7), AbstractC30141Hf.LIZ, r4, r5, r6);
}
public static <T> AbstractC30181Hj<T> LIZ(Iterable<? extends AbstractC22510uu<? extends T>> iterable) {
int i2 = AbstractC30141Hf.LIZ;
return LIZ(iterable, i2, i2);
}
public static <T> AbstractC30181Hj<T> LIZ(Iterable<? extends AbstractC22510uu<? extends T>> iterable, int i2, int i3) {
return LIZIZ((Iterable) iterable).LIZ(C22040u9.LIZ, i2, i3);
}
public static <T, R> AbstractC30181Hj<R> LIZ(Iterable<? extends AbstractC22510uu<? extends T>> iterable, AbstractC21940tz<? super Object[], ? extends R> r4) {
C22050uA.LIZ((Object) r4, "zipper is null");
C22050uA.LIZ((Object) iterable, "sources is null");
return C22330uc.LIZ(new AnonymousClass1OS(null, iterable, r4, AbstractC30141Hf.LIZ));
}
public static <T> AbstractC30181Hj<T> LIZ(Throwable th) {
C22050uA.LIZ((Object) th, "e is null");
return LIZIZ((Callable<? extends Throwable>) C22040u9.LIZ(th));
}
public static <T> AbstractC30181Hj<T> LIZ(Callable<? extends AbstractC22510uu<? extends T>> callable) {
C22050uA.LIZ((Object) callable, "supplier is null");
return C22330uc.LIZ(new AnonymousClass1OU(callable));
}
public static <T> AbstractC30181Hj<T> LIZ(Future<? extends T> future) {
C22050uA.LIZ((Object) future, "future is null");
return C22330uc.LIZ(new AnonymousClass1OF(future));
}
public static <T> AbstractC30181Hj<T> LIZ(AbstractC22510uu<? extends T>... r5) {
return C22330uc.LIZ(new AnonymousClass1WU(LIZ((Object[]) r5), C22040u9.LIZ, AbstractC30141Hf.LIZ, EnumC22230uS.BOUNDARY));
}
public static <T> AbstractC30181Hj<T> LIZ(T... tArr) {
C22050uA.LIZ((Object) tArr, "items is null");
return tArr.length == 0 ? C22330uc.LIZ(AnonymousClass1OW.LIZ) : tArr.length == 1 ? LIZIZ((Object) tArr[0]) : C22330uc.LIZ(new AnonymousClass1OD(tArr));
}
public static AbstractC30181Hj<Long> LIZIZ(long j, TimeUnit timeUnit) {
return LIZ(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
/* JADX DEBUG: Type inference failed for r0v2. Raw type applied. Possible types: X.1Hj<R>, X.1Hj<U> */
private <U> AbstractC30181Hj<U> LIZIZ(Class<U> cls) {
C22050uA.LIZ((Object) cls, "clazz is null");
return (AbstractC30181Hj<R>) LIZLLL(new AnonymousClass1H1(cls));
}
public static <T> AbstractC30181Hj<T> LIZIZ(Iterable<? extends T> iterable) {
C22050uA.LIZ((Object) iterable, "source is null");
return C22330uc.LIZ(new AnonymousClass1OG(iterable));
}
public static <T> AbstractC30181Hj<T> LIZIZ(T t) {
C22050uA.LIZ((Object) t, "The item is null");
return C22330uc.LIZ((AbstractC30181Hj) new AnonymousClass1OL(t));
}
public static <T> AbstractC30181Hj<T> LIZIZ(Callable<? extends Throwable> callable) {
C22050uA.LIZ((Object) callable, "errorSupplier is null");
return C22330uc.LIZ(new AnonymousClass1OX(callable));
}
/* JADX DEBUG: Type inference failed for r0v1. Raw type applied. Possible types: X.1Hj<U extends java.util.Collection<? super T>>, X.1Hj<java.util.List<T>> */
private AbstractC30181Hj<List<T>> LIZJ(long j, TimeUnit timeUnit, AbstractC21720td r10) {
return (AbstractC30181Hj<U>) LIZ(j, timeUnit, r10, EnumC30131He.asCallable());
}
public static <T> AbstractC30181Hj<T> LIZJ(Iterable<? extends AbstractC22510uu<? extends T>> iterable) {
return LIZIZ((Iterable) iterable).LIZ((AbstractC21940tz) C22040u9.LIZ, false);
}
public static <T> AbstractC30181Hj<T> LIZJ(Callable<? extends T> callable) {
C22050uA.LIZ((Object) callable, "supplier is null");
return C22330uc.LIZ((AbstractC30181Hj) new AnonymousClass1OE(callable));
}
private AbstractC30181Hj<T> LIZLLL(long j, TimeUnit timeUnit, AbstractC21720td r10) {
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) r10, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1WW(this, j, timeUnit, r10));
}
public static <T> AbstractC30181Hj<T> LIZLLL(AbstractC22510uu<T> r1) {
C22050uA.LIZ((Object) r1, "source is null");
return r1 instanceof AbstractC30181Hj ? C22330uc.LIZ((AbstractC30181Hj) r1) : C22330uc.LIZ(new AnonymousClass1OH(r1));
}
private AbstractC30181Hj<T> LJ(long j, TimeUnit timeUnit, AbstractC21720td r10) {
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) r10, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1WX(this, j, timeUnit, r10));
}
private AbstractC30181Hj<T> LJFF(long j, TimeUnit timeUnit, AbstractC21720td r10) {
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) r10, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1WQ(this, j, timeUnit, r10));
}
public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r3, AbstractC21930ty<? super Throwable> r4) {
return LIZ(r3, r4, C22040u9.LIZJ, C22040u9.LIZLLL);
}
public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r2, AbstractC21930ty<? super Throwable> r3, AbstractC21880tt r4) {
return LIZ(r2, r3, r4, C22040u9.LIZLLL);
}
public final AbstractC21780tj LIZ(AbstractC21930ty<? super T> r2, AbstractC21930ty<? super Throwable> r3, AbstractC21880tt r4, AbstractC21930ty<? super AbstractC21780tj> 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");
AnonymousClass1HL r0 = new AnonymousClass1HL(r2, r3, r4, r5);
LIZIZ((AbstractC22530uw) r0);
return r0;
}
public final AbstractC30141Hf<T> LIZ(EnumC21700tb r4) {
AnonymousClass1O0 r2 = new AnonymousClass1O0(this);
int i2 = C22480ur.LIZ[r4.ordinal()];
return i2 != 1 ? i2 != 2 ? i2 != 3 ? i2 != 4 ? r2.LIZ() : C22330uc.LIZ(new C33961Vx(r2)) : r2 : r2.LIZJ() : r2.LIZIZ();
}
public final AbstractC30181Hj<T> LIZ(long j) {
return LIZ(j, C22040u9.LJII);
}
public final AbstractC30181Hj<T> LIZ(long j, AbstractC21970u2<? super Throwable> r6) {
if (j >= 0) {
C22050uA.LIZ((Object) r6, "predicate is null");
return C22330uc.LIZ(new AnonymousClass1WJ(this, j, r6));
}
throw new IllegalArgumentException("times >= 0 required but it was ".concat(String.valueOf(j)));
}
public final AbstractC30181Hj<T> LIZ(long j, TimeUnit timeUnit, AbstractC22510uu<? extends T> r11, AbstractC21720td r12) {
C22050uA.LIZ((Object) timeUnit, "timeUnit is null");
C22050uA.LIZ((Object) r12, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1WR(this, j, timeUnit, r12, r11));
}
public final AbstractC30181Hj<T> LIZ(AbstractC21720td r2) {
return LIZ(r2, AbstractC30141Hf.LIZ);
}
public final AbstractC30181Hj<T> LIZ(AbstractC21880tt r2) {
C22050uA.LIZ((Object) r2, "onFinally is null");
return C22330uc.LIZ(new AnonymousClass1WZ(this, r2));
}
public final AbstractC30181Hj<T> LIZ(AbstractC21910tw<? super T, ? super T> r3) {
C22050uA.LIZ((Object) r3, "comparer is null");
return C22330uc.LIZ(new AnonymousClass1WY(this, C22040u9.LIZ, r3));
}
public final AbstractC30181Hj<T> LIZ(AbstractC21930ty<? super Throwable> r3) {
AbstractC21930ty<? super T> r1 = C22040u9.LIZLLL;
AbstractC21880tt r0 = C22040u9.LIZJ;
return LIZ(r1, r3, r0, r0);
}
public final AbstractC30181Hj<T> LIZ(AbstractC21930ty<? super AbstractC21780tj> r2, AbstractC21880tt r3) {
C22050uA.LIZ((Object) r2, "onSubscribe is null");
C22050uA.LIZ((Object) r3, "onDispose is null");
return C22330uc.LIZ(new C34001Wb(this, r2, r3));
}
public final <K> AbstractC30181Hj<T> LIZ(AbstractC21940tz<? super T, K> r3) {
C22050uA.LIZ((Object) r3, "keySelector is null");
return C22330uc.LIZ(new AnonymousClass1WY(this, r3, C22050uA.LIZ));
}
public final <R> AbstractC30181Hj<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC22510uu<? extends R>> r2, boolean z) {
return LIZ(r2, z, (int) Api.BaseClientBuilder.API_PRIORITY_OTHER);
}
public final <R> AbstractC30181Hj<R> LIZ(AbstractC21940tz<? super T, ? extends AbstractC22510uu<? extends R>> r2, boolean z, int i2) {
return LIZ(r2, z, i2, AbstractC30141Hf.LIZ);
}
public final AbstractC30181Hj<T> LIZ(AbstractC21970u2<? super T> r2) {
C22050uA.LIZ((Object) r2, "predicate is null");
return C22330uc.LIZ(new C34011Wc(this, r2));
}
public final AbstractC30181Hj<T> LIZ(AbstractC22510uu<? extends T> r2) {
C22050uA.LIZ((Object) r2, "next is null");
return LJ(C22040u9.LIZIZ(r2));
}
public final <U, R> AbstractC30181Hj<R> LIZ(AbstractC22510uu<? extends U> r2, AbstractC21900tv<? super T, ? super U, ? extends R> r3) {
C22050uA.LIZ((Object) r2, "other is null");
C22050uA.LIZ((Object) r3, "combiner is null");
return C22330uc.LIZ(new AnonymousClass1WS(this, r3, r2));
}
public final <R> AbstractC30181Hj<R> LIZ(AbstractC22520uv<? super T, ? extends R> r2) {
return LIZLLL(((AbstractC22520uv) C22050uA.LIZ((Object) r2, "composer is null")).LIZ(this));
}
public final <U> AbstractC30181Hj<U> LIZ(Class<U> cls) {
C22050uA.LIZ((Object) cls, "clazz is null");
return LIZ(C22040u9.LIZ((Class) cls)).LIZIZ((Class) cls);
}
public final T LIZ() {
C31751Nk r0 = new C31751Nk();
LIZIZ((AbstractC22530uw) r0);
T t = (T) r0.LIZ();
if (t != null) {
return t;
}
throw new NoSuchElementException();
}
public final <R> R LIZ(AbstractC22490us<T, ? extends R> r2) {
return (R) ((AbstractC22490us) C22050uA.LIZ((Object) r2, "converter is null")).LIZ(this);
}
public abstract void LIZ(AbstractC22530uw<? super T> v);
public final AbstractC29991Gq<T> LIZIZ() {
return C22330uc.LIZ(new AnonymousClass1OV(this));
}
public final AbstractC30181Hj<T> LIZIZ(long j) {
if (j >= 0) {
return C22330uc.LIZ(new AnonymousClass1WP(this, j));
}
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(j)));
}
public final AbstractC30181Hj<T> LIZIZ(long j, TimeUnit timeUnit, AbstractC21720td r5) {
return LJ(j, timeUnit, r5);
}
public final AbstractC30181Hj<T> LIZIZ(AbstractC21720td r2) {
C22050uA.LIZ((Object) r2, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1WN(this, r2));
}
/* JADX DEBUG: Multi-variable search result rejected for r2v0, resolved type: X.1Hj<T> */
/* JADX WARN: Multi-variable type inference failed */
public final AbstractC30181Hj<T> LIZIZ(AbstractC21880tt r3) {
AbstractC21930ty<Object> r1 = C22040u9.LIZLLL;
return LIZ(r1, r1, r3, C22040u9.LIZJ);
}
public final AbstractC30181Hj<T> LIZIZ(AbstractC21930ty<? super T> r3) {
AbstractC21930ty<? super Throwable> r1 = C22040u9.LIZLLL;
AbstractC21880tt r0 = C22040u9.LIZJ;
return LIZ(r3, r1, r0, r0);
}
public final <U> AbstractC30181Hj<U> LIZIZ(AbstractC21940tz<? super T, ? extends Iterable<? extends U>> r2) {
C22050uA.LIZ((Object) r2, "mapper is null");
return C22330uc.LIZ(new AnonymousClass1WB(this, r2));
}
public final AbstractC30181Hj<T> LIZIZ(AbstractC22510uu<? extends T> r4) {
C22050uA.LIZ((Object) r4, "next is null");
return C22330uc.LIZ(new AnonymousClass1WG(this, C22040u9.LIZIZ(r4), true));
}
public final <U, R> AbstractC30181Hj<R> LIZIZ(AbstractC22510uu<? extends U> r2, AbstractC21900tv<? super T, ? super U, ? extends R> r3) {
C22050uA.LIZ((Object) r2, "other is null");
return LIZ(this, r2, r3);
}
@Override // X.AbstractC22510uu
public final void LIZIZ(AbstractC22530uw<? super T> r4) {
C22050uA.LIZ((Object) r4, "observer is null");
try {
AbstractC22530uw<? super T> LIZ = C22330uc.LIZ(this, r4);
C22050uA.LIZ((Object) LIZ, "The RxJavaPlugins.onSubscribe hook returned a null Observer. Please change the handler provided to RxJavaPlugins.setOnObservableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
LIZ(LIZ);
} 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 <E extends AbstractC22530uw<? super T>> E LIZJ(E e) {
LIZIZ((AbstractC22530uw) e);
return e;
}
public final AbstractC30181Hj<T> LIZJ() {
return C22330uc.LIZ(new AnonymousClass1WD(this));
}
public final AbstractC30181Hj<List<T>> LIZJ(long j, TimeUnit timeUnit) {
return LIZJ(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public final AbstractC30181Hj<T> LIZJ(AbstractC21930ty<? super AbstractC21780tj> r2) {
return LIZ(r2, C22040u9.LIZJ);
}
/* JADX DEBUG: Type inference failed for r0v1. Raw type applied. Possible types: X.1Hj<X.7Kn<K, V>>, X.1Hj<X.7Kn<K, T>> */
public final <K> AbstractC30181Hj<AbstractC183887Kn<K, T>> LIZJ(AbstractC21940tz<? super T, ? extends K> r3) {
return (AbstractC30181Hj<AbstractC183887Kn<K, V>>) LIZ(r3, C22040u9.LIZ, AbstractC30141Hf.LIZ);
}
public final AbstractC30181Hj<T> LIZJ(AbstractC22510uu<? extends T> r2) {
C22050uA.LIZ((Object) r2, "other is null");
return C22330uc.LIZ(new AnonymousClass1WO(this, r2));
}
public final AbstractC30181Hj<T> LIZJ(T t) {
C22050uA.LIZ((Object) t, "item is null");
return LIZ(LIZIZ((Object) t), this);
}
public final AbstractC21780tj LIZLLL(AbstractC21930ty<? super T> r4) {
return LIZ(r4, C22040u9.LJFF, C22040u9.LIZJ, C22040u9.LIZLLL);
}
public final AbstractC30021Gt LIZLLL() {
return C22330uc.LIZ(new AnonymousClass1OI(this));
}
public final AbstractC30181Hj<T> LIZLLL(long j, TimeUnit timeUnit) {
return LIZLLL(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public final <R> AbstractC30181Hj<R> LIZLLL(AbstractC21940tz<? super T, ? extends R> r2) {
C22050uA.LIZ((Object) r2, "mapper is null");
return C22330uc.LIZ(new AnonymousClass1WE(this, r2));
}
public final AbstractC30181Hj<T> LJ(long j, TimeUnit timeUnit) {
return LJ(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public final AbstractC30181Hj<T> LJ(AbstractC21940tz<? super Throwable, ? extends AbstractC22510uu<? extends T>> r3) {
C22050uA.LIZ((Object) r3, "resumeFunction is null");
return C22330uc.LIZ(new AnonymousClass1WG(this, r3, false));
}
public final AnonymousClass1P3<T> LJ() {
AtomicReference atomicReference = new AtomicReference();
return C22330uc.LIZ((AnonymousClass1P3) new AnonymousClass1WI(new AnonymousClass1HQ(atomicReference), this, atomicReference));
}
public final AbstractC30171Hi<T> LJFF() {
return C22330uc.LIZ(new AnonymousClass1OO(this));
}
public final AbstractC30181Hj<T> LJFF(long j, TimeUnit timeUnit) {
AbstractC21720td LIZ = C22330uc.LIZ(C22430um.LIZIZ);
C22050uA.LIZ((Object) timeUnit, "unit is null");
C22050uA.LIZ((Object) LIZ, "scheduler is null");
return C22330uc.LIZ(new AnonymousClass1WL(this, j, timeUnit, LIZ));
}
public final AbstractC30181Hj<T> LJFF(AbstractC21940tz<? super Throwable, ? extends T> r2) {
C22050uA.LIZ((Object) r2, "valueSupplier is null");
return C22330uc.LIZ(new AnonymousClass1WH(this, r2));
}
public final AbstractC29991Gq<T> LJI() {
return C22330uc.LIZ(new AnonymousClass1OP(this));
}
public final AbstractC30181Hj<T> LJI(long j, TimeUnit timeUnit) {
return LJFF(j, timeUnit, C22330uc.LIZ(C22430um.LIZIZ));
}
public final AbstractC30181Hj<T> LJI(AbstractC21940tz<? super AbstractC30181Hj<Throwable>, ? extends AbstractC22510uu<?>> r2) {
C22050uA.LIZ((Object) r2, "handler is null");
return C22330uc.LIZ(new AnonymousClass1WK(this, r2));
}
public final AbstractC30181Hj<T> LJII() {
return C22330uc.LIZ(new AnonymousClass1WM(this));
}
public final AbstractC30181Hj<T> LJII(long j, TimeUnit timeUnit) {
return LIZ(j, timeUnit, (AbstractC22510uu) null, C22330uc.LIZ(C22430um.LIZIZ));
}
public final AbstractC21780tj LJIIIIZZ() {
return LIZ(C22040u9.LIZLLL, C22040u9.LJFF, C22040u9.LIZJ, C22040u9.LIZLLL);
}
public final AbstractC29991Gq<List<T>> LJIIIZ() {
C22050uA.LIZ(16, "capacityHint");
return C22330uc.LIZ(new AnonymousClass1OR(this));
}
}