package vs;
import c00.c;
import dt.g;
import dt.i;
import dt.k;
import dt.m;
import dt.n;
import dt.o;
import dt.r;
import java.util.Collection;
import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.NoSuchElementException;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import jt.a0;
import jt.a2;
import jt.a3;
import jt.a4;
import jt.a5;
import jt.b0;
import jt.b1;
import jt.b2;
import jt.b4;
import jt.b5;
import jt.c0;
import jt.c1;
import jt.c2;
import jt.c3;
import jt.c4;
import jt.c5;
import jt.d3;
import jt.d4;
import jt.e0;
import jt.e1;
import jt.e2;
import jt.e3;
import jt.e4;
import jt.f0;
import jt.f1;
import jt.f2;
import jt.f3;
import jt.f4;
import jt.g0;
import jt.g1;
import jt.g2;
import jt.g3;
import jt.h0;
import jt.h1;
import jt.h2;
import jt.h3;
import jt.h4;
import jt.i0;
import jt.i1;
import jt.i2;
import jt.i3;
import jt.i4;
import jt.j0;
import jt.j1;
import jt.j2;
import jt.j3;
import jt.j4;
import jt.k0;
import jt.k2;
import jt.k3;
import jt.k4;
import jt.l0;
import jt.l1;
import jt.l2;
import jt.l3;
import jt.l4;
import jt.m0;
import jt.m1;
import jt.m2;
import jt.m3;
import jt.m4;
import jt.n0;
import jt.n1;
import jt.n3;
import jt.n4;
import jt.o0;
import jt.o1;
import jt.o2;
import jt.o4;
import jt.p;
import jt.p0;
import jt.p1;
import jt.p2;
import jt.p3;
import jt.p4;
import jt.q;
import jt.q0;
import jt.q1;
import jt.q2;
import jt.q3;
import jt.r0;
import jt.r1;
import jt.r2;
import jt.r4;
import jt.s0;
import jt.s1;
import jt.s3;
import jt.s4;
import jt.t;
import jt.t1;
import jt.t3;
import jt.t4;
import jt.u;
import jt.u0;
import jt.u1;
import jt.u2;
import jt.u3;
import jt.u4;
import jt.v;
import jt.v0;
import jt.v1;
import jt.v2;
import jt.v3;
import jt.v4;
import jt.w;
import jt.w0;
import jt.w1;
import jt.w2;
import jt.w3;
import jt.w4;
import jt.x;
import jt.x0;
import jt.x1;
import jt.x3;
import jt.x4;
import jt.y;
import jt.y0;
import jt.y1;
import jt.y2;
import jt.y3;
import jt.y4;
import jt.z0;
import jt.z1;
import jt.z2;
import jt.z3;
import jt.z4;
import st.j;
import zs.a;
import zs.b;
import zs.d;
import zs.e;
import zs.f;
import zs.h;
/* compiled from: Flowable */
public abstract class l<T> implements c<T> {
/* renamed from: a reason: collision with root package name */
public static final int f146401a = Math.max(1, Integer.getInteger("rx2.buffer-size", 128).intValue());
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> A0(c<? extends T> cVar, c<? extends T> cVar2) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return E0(cVar, cVar2);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> A3(T t10, T t11, T t12, T t13, T t14, T t15) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
ft.b.g(t13, "item4 is null");
ft.b.g(t14, "item5 is null");
ft.b.g(t15, "item6 is null");
return R2(t10, t11, t12, t13, t14, t15);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> A6(c<? extends c<? extends T>> cVar) {
return Y2(cVar).p6(ft.a.k());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, R> l<R> A8(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, dt.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
return G8(ft.a.y(hVar), false, Y(), cVar, cVar2, cVar3);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> B0(c<? extends T> cVar, c<? extends T> cVar2, c<? extends T> cVar3) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
return E0(cVar, cVar2, cVar3);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public static <T> l<T> B1(Callable<? extends c<? extends T>> callable) {
ft.b.g(callable, "supplier is null");
return wt.a.R(new i0(callable));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> B3(T t10, T t11, T t12, T t13, T t14, T t15, T t16) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
ft.b.g(t13, "item4 is null");
ft.b.g(t14, "item5 is null");
ft.b.g(t15, "item6 is null");
ft.b.g(t16, "item7 is null");
return R2(t10, t11, t12, t13, t14, t15, t16);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> B6(c<? extends c<? extends T>> cVar, int i10) {
return Y2(cVar).q6(ft.a.k(), i10);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, R> l<R> B8(c<? extends T1> cVar, c<? extends T2> cVar2, dt.c<? super T1, ? super T2, ? extends R> cVar3) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return G8(ft.a.x(cVar3), false, Y(), cVar, cVar2);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> C0(c<? extends T> cVar, c<? extends T> cVar2, c<? extends T> cVar3, c<? extends T> cVar4) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
return E0(cVar, cVar2, cVar3, cVar4);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> C3(T t10, T t11, T t12, T t13, T t14, T t15, T t16, T t17) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
ft.b.g(t13, "item4 is null");
ft.b.g(t14, "item5 is null");
ft.b.g(t15, "item6 is null");
ft.b.g(t16, "item7 is null");
ft.b.g(t17, "item8 is null");
return R2(t10, t11, t12, t13, t14, t15, t16, t17);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> C6(c<? extends c<? extends T>> cVar) {
return D6(cVar, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, R> l<R> C8(c<? extends T1> cVar, c<? extends T2> cVar2, dt.c<? super T1, ? super T2, ? extends R> cVar3, boolean z10) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return G8(ft.a.x(cVar3), z10, Y(), cVar, cVar2);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> D0(Iterable<? extends c<? extends T>> iterable) {
ft.b.g(iterable, "sources is null");
return X2(iterable).Z0(ft.a.k(), 2, false);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> D3(T t10, T t11, T t12, T t13, T t14, T t15, T t16, T t17, T t18) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
ft.b.g(t13, "item4 is null");
ft.b.g(t14, "item5 is null");
ft.b.g(t15, "item6 is null");
ft.b.g(t16, "item7 is null");
ft.b.g(t17, "item8 is null");
ft.b.g(t18, "item9 is null");
return R2(t10, t11, t12, t13, t14, t15, t16, t17, t18);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> D6(c<? extends c<? extends T>> cVar, int i10) {
return Y2(cVar).v6(ft.a.k(), i10);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, R> l<R> D8(c<? extends T1> cVar, c<? extends T2> cVar2, dt.c<? super T1, ? super T2, ? extends R> cVar3, boolean z10, int i10) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return G8(ft.a.x(cVar3), z10, i10, cVar, cVar2);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> E0(c<? extends T>... cVarArr) {
if (cVarArr.length == 0) {
return k2();
}
if (cVarArr.length == 1) {
return Y2(cVarArr[0]);
}
return wt.a.R(new v(cVarArr, false));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> E3(T t10, T t11, T t12, T t13, T t14, T t15, T t16, T t17, T t18, T t19) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
ft.b.g(t13, "item4 is null");
ft.b.g(t14, "item5 is null");
ft.b.g(t15, "item6 is null");
ft.b.g(t16, "item7 is null");
ft.b.g(t17, "item8 is null");
ft.b.g(t18, "item9 is null");
ft.b.g(t19, "item10 is null");
return R2(t10, t11, t12, t13, t14, t15, t16, t17, t18, t19);
}
@h("none")
@d
@b(a.FULL)
public static <T> k0<Boolean> E5(c<? extends T> cVar, c<? extends T> cVar2) {
return H5(cVar, cVar2, ft.b.d(), Y());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, R> l<R> E8(c<? extends c<? extends T>> cVar, o<? super Object[], ? extends R> oVar) {
ft.b.g(oVar, "zipper is null");
return Y2(cVar).C7().e0(s1.n(oVar));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> F0(c<? extends T>... cVarArr) {
if (cVarArr.length == 0) {
return k2();
}
if (cVarArr.length == 1) {
return Y2(cVarArr[0]);
}
return wt.a.R(new v(cVarArr, true));
}
@h("none")
@d
@b(a.FULL)
public static <T> k0<Boolean> F5(c<? extends T> cVar, c<? extends T> cVar2, int i10) {
return H5(cVar, cVar2, ft.b.d(), i10);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, R> l<R> F8(Iterable<? extends c<? extends T>> iterable, o<? super Object[], ? extends R> oVar) {
ft.b.g(oVar, "zipper is null");
ft.b.g(iterable, "sources is null");
return wt.a.R(new b5(null, iterable, oVar, Y(), false));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> G0(int i10, int i11, c<? extends T>... cVarArr) {
ft.b.g(cVarArr, "sources is null");
ft.b.h(i10, "maxConcurrency");
ft.b.h(i11, "prefetch");
return wt.a.R(new x(new g1(cVarArr), ft.a.k(), i10, i11, j.IMMEDIATE));
}
@h("none")
@d
@b(a.FULL)
public static <T> k0<Boolean> G5(c<? extends T> cVar, c<? extends T> cVar2, dt.d<? super T, ? super T> dVar) {
return H5(cVar, cVar2, dVar, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, R> l<R> G8(o<? super Object[], ? extends R> oVar, boolean z10, int i10, c<? extends T>... cVarArr) {
if (cVarArr.length == 0) {
return k2();
}
ft.b.g(oVar, "zipper is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new b5(cVarArr, null, oVar, i10, z10));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> H0(c<? extends T>... cVarArr) {
return G0(Y(), Y(), cVarArr);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> k0<Boolean> H5(c<? extends T> cVar, c<? extends T> cVar2, dt.d<? super T, ? super T> dVar, int i10) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(dVar, "isEqual is null");
ft.b.h(i10, "bufferSize");
return wt.a.U(new p3(cVar, cVar2, dVar, i10));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, R> l<R> H8(Iterable<? extends c<? extends T>> iterable, o<? super Object[], ? extends R> oVar, boolean z10, int i10) {
ft.b.g(oVar, "zipper is null");
ft.b.g(iterable, "sources is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new b5(null, iterable, oVar, i10, z10));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> I0(int i10, int i11, c<? extends T>... cVarArr) {
return R2(cVarArr).c1(ft.a.k(), i10, i11, true);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> J0(c<? extends T>... cVarArr) {
return I0(Y(), Y(), cVarArr);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> K0(c<? extends c<? extends T>> cVar) {
return L0(cVar, Y(), true);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> L0(c<? extends c<? extends T>> cVar, int i10, boolean z10) {
return Y2(cVar).Z0(ft.a.k(), i10, z10);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> M0(Iterable<? extends c<? extends T>> iterable) {
ft.b.g(iterable, "sources is null");
return X2(iterable).Y0(ft.a.k());
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> M3(c<? extends c<? extends T>> cVar) {
return N3(cVar, Y());
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> N0(c<? extends c<? extends T>> cVar) {
return O0(cVar, Y(), Y());
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> N3(c<? extends c<? extends T>> cVar, int i10) {
return Y2(cVar).s2(ft.a.k(), i10);
}
@h("none")
@d
@b(a.FULL)
public static l<Integer> N4(int i10, int i11) {
if (i11 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + i11);
} else if (i11 == 0) {
return k2();
} else {
if (i11 == 1) {
return v3(Integer.valueOf(i10));
}
if (((long) i10) + ((long) (i11 - 1)) <= 2147483647L) {
return wt.a.R(new v2(i10, i11));
}
throw new IllegalArgumentException("Integer overflow");
}
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> O0(c<? extends c<? extends T>> cVar, int i10, int i11) {
ft.b.g(cVar, "sources is null");
ft.b.h(i10, "maxConcurrency");
ft.b.h(i11, "prefetch");
return wt.a.R(new y(cVar, ft.a.k(), i10, i11, j.IMMEDIATE));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> O3(c<? extends T> cVar, c<? extends T> cVar2) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return R2(cVar, cVar2).B2(ft.a.k(), false, 2);
}
@h("none")
@d
@b(a.FULL)
public static l<Long> O4(long j10, long j11) {
int i10 = (j11 > 0 ? 1 : (j11 == 0 ? 0 : -1));
if (i10 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + j11);
} else if (i10 == 0) {
return k2();
} else {
if (j11 == 1) {
return v3(Long.valueOf(j10));
}
long j12 = (j11 - 1) + j10;
if (j10 <= 0 || j12 >= 0) {
return wt.a.R(new w2(j10, j11));
}
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> P0(Iterable<? extends c<? extends T>> iterable) {
return Q0(iterable, Y(), Y());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> P3(c<? extends T> cVar, c<? extends T> cVar2, c<? extends T> cVar3) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
return R2(cVar, cVar2, cVar3).B2(ft.a.k(), false, 3);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> Q0(Iterable<? extends c<? extends T>> iterable, int i10, int i11) {
ft.b.g(iterable, "sources is null");
ft.b.h(i10, "maxConcurrency");
ft.b.h(i11, "prefetch");
return wt.a.R(new x(new j1(iterable), ft.a.k(), i10, i11, j.IMMEDIATE));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> Q3(c<? extends T> cVar, c<? extends T> cVar2, c<? extends T> cVar3, c<? extends T> cVar4) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
return R2(cVar, cVar2, cVar3, cVar4).B2(ft.a.k(), false, 4);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> R2(T... tArr) {
ft.b.g(tArr, "items is null");
if (tArr.length == 0) {
return k2();
}
if (tArr.length == 1) {
return v3(tArr[0]);
}
return wt.a.R(new g1(tArr));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> R3(Iterable<? extends c<? extends T>> iterable) {
return X2(iterable).r2(ft.a.k());
}
@h("none")
@f
@d
@b(a.NONE)
public static <T> l<T> R7(c<T> cVar) {
ft.b.g(cVar, "onSubscribe is null");
if (!(cVar instanceof l)) {
return wt.a.R(new l1(cVar));
}
throw new IllegalArgumentException("unsafeCreate(Flowable) should be upgraded");
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> S2(Callable<? extends T> callable) {
ft.b.g(callable, "supplier is null");
return wt.a.R(new h1(callable));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> S3(Iterable<? extends c<? extends T>> iterable, int i10) {
return X2(iterable).s2(ft.a.k(), i10);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> T2(Future<? extends T> future) {
ft.b.g(future, "future is null");
return wt.a.R(new i1(future, 0, null));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> T3(Iterable<? extends c<? extends T>> iterable, int i10, int i11) {
return X2(iterable).C2(ft.a.k(), false, i10, i11);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public static <T, D> l<T> T7(Callable<? extends D> callable, o<? super D, ? extends c<? extends T>> oVar, g<? super D> gVar) {
return U7(callable, oVar, gVar, true);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> U2(Future<? extends T> future, long j10, TimeUnit timeUnit) {
ft.b.g(future, "future is null");
ft.b.g(timeUnit, "unit is null");
return wt.a.R(new i1(future, j10, timeUnit));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> U3(int i10, int i11, c<? extends T>... cVarArr) {
return R2(cVarArr).C2(ft.a.k(), false, i10, i11);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public static <T, D> l<T> U7(Callable<? extends D> callable, o<? super D, ? extends c<? extends T>> oVar, g<? super D> gVar, boolean z10) {
ft.b.g(callable, "resourceSupplier is null");
ft.b.g(oVar, "sourceSupplier is null");
ft.b.g(gVar, "resourceDisposer is null");
return wt.a.R(new t4(callable, oVar, gVar, z10));
}
@h(h.P)
@f
@d
@b(a.FULL)
public static <T> l<T> V2(Future<? extends T> future, long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return U2(future, j10, timeUnit).l6(j0Var);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> V3(c<? extends T>... cVarArr) {
return R2(cVarArr).s2(ft.a.k(), cVarArr.length);
}
@h(h.P)
@f
@d
@b(a.FULL)
public static <T> l<T> W2(Future<? extends T> future, j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return T2(future).l6(j0Var);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> W3(int i10, int i11, c<? extends T>... cVarArr) {
return R2(cVarArr).C2(ft.a.k(), true, i10, i11);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> X2(Iterable<? extends T> iterable) {
ft.b.g(iterable, "source is null");
return wt.a.R(new j1(iterable));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> X3(c<? extends T>... cVarArr) {
return R2(cVarArr).B2(ft.a.k(), true, cVarArr.length);
}
public static int Y() {
return f146401a;
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public static <T> l<T> Y2(c<? extends T> cVar) {
if (cVar instanceof l) {
return wt.a.R((l) cVar);
}
ft.b.g(cVar, "source is null");
return wt.a.R(new l1(cVar));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> Y3(c<? extends c<? extends T>> cVar) {
return Z3(cVar, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> Z2(g<k<T>> gVar) {
ft.b.g(gVar, "generator is null");
return d3(ft.a.u(), s1.j(gVar), ft.a.h());
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> Z3(c<? extends c<? extends T>> cVar, int i10) {
return Y2(cVar).B2(ft.a.k(), true, i10);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, S> l<T> a3(Callable<S> callable, dt.b<S, k<T>> bVar) {
ft.b.g(bVar, "generator is null");
return d3(callable, s1.i(bVar), ft.a.h());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> a4(c<? extends T> cVar, c<? extends T> cVar2) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return R2(cVar, cVar2).B2(ft.a.k(), true, 2);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, S> l<T> b3(Callable<S> callable, dt.b<S, k<T>> bVar, g<? super S> gVar) {
ft.b.g(bVar, "generator is null");
return d3(callable, s1.i(bVar), gVar);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> b4(c<? extends T> cVar, c<? extends T> cVar2, c<? extends T> cVar3) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
return R2(cVar, cVar2, cVar3).B2(ft.a.k(), true, 3);
}
@h("none")
@d
@b(a.FULL)
public static <T, S> l<T> c3(Callable<S> callable, dt.c<S, k<T>, S> cVar) {
return d3(callable, cVar, ft.a.h());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> c4(c<? extends T> cVar, c<? extends T> cVar2, c<? extends T> cVar3, c<? extends T> cVar4) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
return R2(cVar, cVar2, cVar3, cVar4).B2(ft.a.k(), true, 4);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, S> l<T> d3(Callable<S> callable, dt.c<S, k<T>, S> cVar, g<? super S> gVar) {
ft.b.g(callable, "initialState is null");
ft.b.g(cVar, "generator is null");
ft.b.g(gVar, "disposeState is null");
return wt.a.R(new m1(callable, cVar, gVar));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> d4(Iterable<? extends c<? extends T>> iterable) {
return X2(iterable).A2(ft.a.k(), true);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> l<R> e0(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, c<? extends T7> cVar7, c<? extends T8> cVar8, c<? extends T9> cVar9, n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
ft.b.g(cVar7, "source7 is null");
ft.b.g(cVar8, "source8 is null");
ft.b.g(cVar9, "source9 is null");
return m0(ft.a.E(nVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8, cVar9);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> e4(Iterable<? extends c<? extends T>> iterable, int i10) {
return X2(iterable).B2(ft.a.k(), true, i10);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public static <T> l<T> f(Iterable<? extends c<? extends T>> iterable) {
ft.b.g(iterable, "sources is null");
return wt.a.R(new jt.h(null, iterable));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> l<R> f0(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, c<? extends T7> cVar7, c<? extends T8> cVar8, m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
ft.b.g(cVar7, "source7 is null");
ft.b.g(cVar8, "source8 is null");
return m0(ft.a.D(mVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> f4(Iterable<? extends c<? extends T>> iterable, int i10, int i11) {
return X2(iterable).C2(ft.a.k(), true, i10, i11);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public static <T> l<T> g(c<? extends T>... cVarArr) {
ft.b.g(cVarArr, "sources is null");
int length = cVarArr.length;
if (length == 0) {
return k2();
}
if (length == 1) {
return Y2(cVarArr[0]);
}
return wt.a.R(new jt.h(cVarArr, null));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, R> l<R> g0(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, c<? extends T7> cVar7, dt.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
ft.b.g(cVar7, "source7 is null");
return m0(ft.a.C(lVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, R> l<R> h0(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
return m0(ft.a.B(kVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, R> l<R> i0(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, dt.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
return m0(ft.a.A(jVar), cVar, cVar2, cVar3, cVar4, cVar5);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, R> l<R> j0(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
return m0(ft.a.z(iVar), cVar, cVar2, cVar3, cVar4);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, R> l<R> k0(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, dt.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
return m0(ft.a.y(hVar), cVar, cVar2, cVar3);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public static <T> l<T> k2() {
return wt.a.R(w0.f78371b);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public static <T> l<T> k4() {
return wt.a.R(i2.f77460b);
}
@h("none")
@d
@b(a.FULL)
public static <T1, T2, R> l<R> l0(c<? extends T1> cVar, c<? extends T2> cVar2, dt.c<? super T1, ? super T2, ? extends R> cVar3) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return m0(ft.a.x(cVar3), cVar, cVar2);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public static <T> l<T> l2(Throwable th2) {
ft.b.g(th2, "throwable is null");
return m2(ft.a.m(th2));
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> m0(o<? super Object[], ? extends R> oVar, c<? extends T>... cVarArr) {
return q0(cVarArr, oVar, Y());
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public static <T> l<T> m2(Callable<? extends Throwable> callable) {
ft.b.g(callable, "supplier is null");
return wt.a.R(new x0(callable));
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> n0(Iterable<? extends c<? extends T>> iterable, o<? super Object[], ? extends R> oVar) {
return o0(iterable, oVar, Y());
}
@h(h.Q)
@d
@b(a.ERROR)
public static l<Long> n3(long j10, long j11, TimeUnit timeUnit) {
return o3(j10, j11, timeUnit, yt.b.a());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, R> l<R> o0(Iterable<? extends c<? extends T>> iterable, o<? super Object[], ? extends R> oVar, int i10) {
ft.b.g(iterable, "sources is null");
ft.b.g(oVar, "combiner is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new u((Iterable) iterable, (o) oVar, i10, false));
}
@h(h.P)
@f
@d
@b(a.ERROR)
public static l<Long> o3(long j10, long j11, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new t1(Math.max(0L, j10), Math.max(0L, j11), timeUnit, j0Var));
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> p0(c<? extends T>[] cVarArr, o<? super Object[], ? extends R> oVar) {
return q0(cVarArr, oVar, Y());
}
@h(h.Q)
@d
@b(a.ERROR)
public static l<Long> p3(long j10, TimeUnit timeUnit) {
return o3(j10, j10, timeUnit, yt.b.a());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, R> l<R> q0(c<? extends T>[] cVarArr, o<? super Object[], ? extends R> oVar, int i10) {
ft.b.g(cVarArr, "sources is null");
if (cVarArr.length == 0) {
return k2();
}
ft.b.g(oVar, "combiner is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new u((c[]) cVarArr, (o) oVar, i10, false));
}
@h(h.P)
@d
@b(a.ERROR)
public static l<Long> q3(long j10, TimeUnit timeUnit, j0 j0Var) {
return o3(j10, j10, timeUnit, j0Var);
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> r0(o<? super Object[], ? extends R> oVar, int i10, c<? extends T>... cVarArr) {
return w0(cVarArr, oVar, i10);
}
@h(h.Q)
@d
@b(a.ERROR)
public static l<Long> r3(long j10, long j11, long j12, long j13, TimeUnit timeUnit) {
return s3(j10, j11, j12, j13, timeUnit, yt.b.a());
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> s0(o<? super Object[], ? extends R> oVar, c<? extends T>... cVarArr) {
return w0(cVarArr, oVar, Y());
}
@h(h.P)
@f
@d
@b(a.ERROR)
public static l<Long> s3(long j10, long j11, long j12, long j13, TimeUnit timeUnit, j0 j0Var) {
int i10 = (j11 > 0 ? 1 : (j11 == 0 ? 0 : -1));
if (i10 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + j11);
} else if (i10 == 0) {
return k2().D1(j12, timeUnit, j0Var);
} else {
long j14 = j10 + (j11 - 1);
if (j10 <= 0 || j14 >= 0) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new u1(j10, j14, Math.max(0L, j12), Math.max(0L, j13), timeUnit, j0Var));
}
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> t0(Iterable<? extends c<? extends T>> iterable, o<? super Object[], ? extends R> oVar) {
return u0(iterable, oVar, Y());
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> u0(Iterable<? extends c<? extends T>> iterable, o<? super Object[], ? extends R> oVar, int i10) {
ft.b.g(iterable, "sources is null");
ft.b.g(oVar, "combiner is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new u((Iterable) iterable, (o) oVar, i10, true));
}
@h(h.Q)
@d
@b(a.ERROR)
public static l<Long> u7(long j10, TimeUnit timeUnit) {
return v7(j10, timeUnit, yt.b.a());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> l<R> u8(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, c<? extends T7> cVar7, c<? extends T8> cVar8, c<? extends T9> cVar9, n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
ft.b.g(cVar7, "source7 is null");
ft.b.g(cVar8, "source8 is null");
ft.b.g(cVar9, "source9 is null");
return G8(ft.a.E(nVar), false, Y(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8, cVar9);
}
@h("none")
@d
@b(a.FULL)
public static <T, R> l<R> v0(c<? extends T>[] cVarArr, o<? super Object[], ? extends R> oVar) {
return w0(cVarArr, oVar, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> v3(T t10) {
ft.b.g(t10, "item is null");
return wt.a.R(new w1(t10));
}
@h(h.P)
@f
@d
@b(a.ERROR)
public static l<Long> v7(long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new p4(Math.max(0L, j10), timeUnit, j0Var));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> l<R> v8(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, c<? extends T7> cVar7, c<? extends T8> cVar8, m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
ft.b.g(cVar7, "source7 is null");
ft.b.g(cVar8, "source8 is null");
return G8(ft.a.D(mVar), false, Y(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T, R> l<R> w0(c<? extends T>[] cVarArr, o<? super Object[], ? extends R> oVar, int i10) {
ft.b.g(cVarArr, "sources is null");
ft.b.g(oVar, "combiner is null");
ft.b.h(i10, "bufferSize");
if (cVarArr.length == 0) {
return k2();
}
return wt.a.R(new u((c[]) cVarArr, (o) oVar, i10, true));
}
@h("none")
@f
@d
@b(a.SPECIAL)
public static <T> l<T> w1(o<T> oVar, b bVar) {
ft.b.g(oVar, "source is null");
ft.b.g(bVar, "mode is null");
return wt.a.R(new f0(oVar, bVar));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> w3(T t10, T t11) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
return R2(t10, t11);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, R> l<R> w8(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, c<? extends T7> cVar7, dt.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
ft.b.g(cVar7, "source7 is null");
return G8(ft.a.C(lVar), false, Y(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> x3(T t10, T t11, T t12) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
return R2(t10, t11, t12);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, T6, R> l<R> x8(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, c<? extends T6> cVar6, k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
ft.b.g(cVar6, "source6 is null");
return G8(ft.a.B(kVar), false, Y(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> y0(c<? extends c<? extends T>> cVar) {
return z0(cVar, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> y3(T t10, T t11, T t12, T t13) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
ft.b.g(t13, "item4 is null");
return R2(t10, t11, t12, t13);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, T5, R> l<R> y8(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, c<? extends T5> cVar5, dt.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
ft.b.g(cVar5, "source5 is null");
return G8(ft.a.A(jVar), false, Y(), cVar, cVar2, cVar3, cVar4, cVar5);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> z0(c<? extends c<? extends T>> cVar, int i10) {
return Y2(cVar).S0(ft.a.k(), i10);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> z3(T t10, T t11, T t12, T t13, T t14) {
ft.b.g(t10, "item1 is null");
ft.b.g(t11, "item2 is null");
ft.b.g(t12, "item3 is null");
ft.b.g(t13, "item4 is null");
ft.b.g(t14, "item5 is null");
return R2(t10, t11, t12, t13, t14);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T1, T2, T3, T4, R> l<R> z8(c<? extends T1> cVar, c<? extends T2> cVar2, c<? extends T3> cVar3, c<? extends T4> cVar4, i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
return G8(ft.a.z(iVar), false, Y(), cVar, cVar2, cVar3, cVar4);
}
@h("none")
@b(a.FULL)
public final void A(g<? super T> gVar, int i10) {
jt.l.d(this, gVar, ft.a.f64187f, ft.a.f64184c, i10);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> A1(T t10) {
ft.b.g(t10, "defaultItem is null");
return o6(v3(t10));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> A2(o<? super T, ? extends c<? extends R>> oVar, boolean z10) {
return C2(oVar, z10, Y(), Y());
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> A4(c<? extends T> cVar) {
ft.b.g(cVar, "next is null");
return B4(ft.a.n(cVar));
}
@h("none")
@f
@d
@b(a.ERROR)
public final <U> l<T> A5(c<U> cVar, boolean z10) {
ft.b.g(cVar, "sampler is null");
return wt.a.R(new j3(this, cVar, z10));
}
@h("none")
@d
@b(a.SPECIAL)
public final <R> R A7(o<? super l<T>, R> oVar) {
try {
return (R) ((o) ft.b.g(oVar, "converter is null")).apply(this);
} catch (Throwable th2) {
bt.b.b(th2);
throw st.k.f(th2);
}
}
@h("none")
@b(a.UNBOUNDED_IN)
public final void B(g<? super T> gVar, g<? super Throwable> gVar2) {
jt.l.c(this, gVar, gVar2, ft.a.f64184c);
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> B2(o<? super T, ? extends c<? extends R>> oVar, boolean z10, int i10) {
return C2(oVar, z10, i10, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> B4(o<? super Throwable, ? extends c<? extends T>> oVar) {
ft.b.g(oVar, "resumeFunction is null");
return wt.a.R(new p2(this, oVar, false));
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> B5(dt.c<T, T, T> cVar) {
ft.b.g(cVar, "accumulator is null");
return wt.a.R(new m3(this, cVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final Future<T> B7() {
return (Future) n6(new rt.j());
}
@h("none")
@b(a.FULL)
public final void C(g<? super T> gVar, g<? super Throwable> gVar2, int i10) {
jt.l.d(this, gVar, gVar2, ft.a.f64184c, i10);
}
@h(h.Q)
@d
@b(a.FULL)
public final l<T> C1(long j10, TimeUnit timeUnit) {
return E1(j10, timeUnit, yt.b.a(), false);
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> C2(o<? super T, ? extends c<? extends R>> oVar, boolean z10, int i10, int i11) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "maxConcurrency");
ft.b.h(i11, "bufferSize");
if (!(this instanceof gt.m)) {
return wt.a.R(new z0(this, oVar, z10, i10, i11));
}
Object call = ((gt.m) this).call();
if (call == null) {
return k2();
}
return l3.a(call, oVar);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> C4(o<? super Throwable, ? extends T> oVar) {
ft.b.g(oVar, "valueSupplier is null");
return wt.a.R(new q2(this, oVar));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> C5(R r10, dt.c<R, ? super T, R> cVar) {
ft.b.g(r10, "initialValue is null");
return D5(ft.a.m(r10), cVar);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<List<T>> C7() {
return wt.a.U(new r4(this));
}
@h("none")
@b(a.UNBOUNDED_IN)
public final void D(g<? super T> gVar, g<? super Throwable> gVar2, dt.a aVar) {
jt.l.c(this, gVar, gVar2, aVar);
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> D1(long j10, TimeUnit timeUnit, j0 j0Var) {
return E1(j10, timeUnit, j0Var, false);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final c D2(o<? super T, ? extends i> oVar) {
return E2(oVar, false, Integer.MAX_VALUE);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> D4(T t10) {
ft.b.g(t10, "item is null");
return C4(ft.a.n(t10));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> D5(Callable<R> callable, dt.c<R, ? super T, R> cVar) {
ft.b.g(callable, "seedSupplier is null");
ft.b.g(cVar, "accumulator is null");
return wt.a.R(new n3(this, callable, cVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<List<T>> D7(int i10) {
ft.b.h(i10, "capacityHint");
return wt.a.U(new r4(this, ft.a.f(i10)));
}
@h("none")
@b(a.FULL)
public final void E(g<? super T> gVar, g<? super Throwable> gVar2, dt.a aVar, int i10) {
jt.l.d(this, gVar, gVar2, aVar, i10);
}
@h(h.P)
@f
@d
@b(a.FULL)
public final l<T> E1(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new j0(this, Math.max(0L, j10), timeUnit, j0Var, z10));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final c E2(o<? super T, ? extends i> oVar, boolean z10, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "maxConcurrency");
return wt.a.Q(new b1(this, oVar, z10, i10));
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> E4(c<? extends T> cVar) {
ft.b.g(cVar, "next is null");
return wt.a.R(new p2(this, ft.a.n(cVar), true));
}
@h("none")
@d
@b(a.SPECIAL)
public final l<T> E6(long j10) {
if (j10 >= 0) {
return wt.a.R(new c4(this, j10));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j10);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final <U extends Collection<? super T>> k0<U> E7(Callable<U> callable) {
ft.b.g(callable, "collectionSupplier is null");
return wt.a.U(new r4(this, callable));
}
@h("none")
@d
@b(a.FULL)
public final l<List<T>> F(int i10) {
return G(i10, i10);
}
@h(h.Q)
@d
@b(a.FULL)
public final l<T> F1(long j10, TimeUnit timeUnit, boolean z10) {
return E1(j10, timeUnit, yt.b.a(), z10);
}
@h("none")
@d
@b(a.FULL)
public final <U> l<U> F2(o<? super T, ? extends Iterable<? extends U>> oVar) {
return G2(oVar, Y());
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<T> F3(T t10) {
ft.b.g(t10, "defaultItem");
return wt.a.U(new y1(this, t10));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> F4() {
return wt.a.R(new m0(this));
}
@h(h.Q)
@d
@b(a.PASS_THROUGH)
public final l<T> F6(long j10, TimeUnit timeUnit) {
return Q6(u7(j10, timeUnit));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <K> k0<Map<K, T>> F7(o<? super T, ? extends K> oVar) {
ft.b.g(oVar, "keySelector is null");
return c0(st.m.asCallable(), ft.a.F(oVar));
}
/* JADX DEBUG: Type inference failed for r2v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h("none")
@d
@b(a.FULL)
public final l<List<T>> G(int i10, int i11) {
return (l<U>) H(i10, i11, st.b.asCallable());
}
/* JADX DEBUG: Multi-variable search result rejected for r2v0, resolved type: dt.o<? super T, ? extends c00.c<V>> */
/* JADX WARN: Multi-variable type inference failed */
@h("none")
@d
@b(a.FULL)
public final <U, V> l<T> G1(c<U> cVar, o<? super T, ? extends c<V>> oVar) {
return K1(cVar).H1(oVar);
}
@h("none")
@f
@d
@b(a.FULL)
public final <U> l<U> G2(o<? super T, ? extends Iterable<? extends U>> oVar, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new f1(this, oVar, i10));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final s<T> G3() {
return wt.a.S(new x1(this));
}
@h("none")
@d
@b(a.FULL)
public final vt.b<T> G4() {
return vt.b.y(this);
}
@h(h.P)
@d
@b(a.PASS_THROUGH)
public final l<T> G6(long j10, TimeUnit timeUnit, j0 j0Var) {
return Q6(v7(j10, timeUnit, j0Var));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <K, V> k0<Map<K, V>> G7(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2) {
ft.b.g(oVar, "keySelector is null");
ft.b.g(oVar2, "valueSelector is null");
return c0(st.m.asCallable(), ft.a.G(oVar, oVar2));
}
@h("none")
@f
@d
@b(a.FULL)
public final <U extends Collection<? super T>> l<U> H(int i10, int i11, Callable<U> callable) {
ft.b.h(i10, "count");
ft.b.h(i11, "skip");
ft.b.g(callable, "bufferSupplier is null");
return wt.a.R(new jt.m(this, i10, i11, callable));
}
/* JADX DEBUG: Type inference failed for r2v2. Raw type applied. Possible types: vs.l<R>, vs.l<T> */
@h("none")
@f
@d
@b(a.FULL)
public final <U> l<T> H1(o<? super T, ? extends c<U>> oVar) {
ft.b.g(oVar, "itemDelayIndicator is null");
return (l<R>) r2(s1.c(oVar));
}
/* JADX DEBUG: Multi-variable search result rejected for r9v0, resolved type: dt.c<? super T, ? super U, ? extends V> */
/* JADX WARN: Multi-variable type inference failed */
/* JADX DEBUG: Type inference failed for r8v1. Raw type applied. Possible types: vs.l<R>, vs.l<V> */
@h("none")
@f
@d
@b(a.FULL)
public final <U, V> l<V> H2(o<? super T, ? extends Iterable<? extends U>> oVar, dt.c<? super T, ? super U, ? extends V> cVar) {
ft.b.g(oVar, "mapper is null");
ft.b.g(cVar, "resultSelector is null");
return (l<R>) x2(s1.a(oVar), cVar, false, Y(), Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<T> H3() {
return wt.a.U(new y1(this, null));
}
@h("none")
@d
@b(a.FULL)
public final vt.b<T> H4(int i10) {
ft.b.h(i10, "parallelism");
return vt.b.z(this, i10);
}
@h("none")
@d
@b(a.FULL)
public final l<T> H6(int i10) {
if (i10 < 0) {
throw new IndexOutOfBoundsException("count >= 0 required but it was " + i10);
} else if (i10 == 0) {
return wt.a.R(new q1(this));
} else {
if (i10 == 1) {
return wt.a.R(new e4(this));
}
return wt.a.R(new d4(this, i10));
}
}
/* JADX DEBUG: Multi-variable search result rejected for r4v0, resolved type: java.util.concurrent.Callable<? extends java.util.Map<K, V>> */
/* JADX WARN: Multi-variable type inference failed */
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <K, V> k0<Map<K, V>> H7(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2, Callable<? extends Map<K, V>> callable) {
ft.b.g(oVar, "keySelector is null");
ft.b.g(oVar2, "valueSelector is null");
return c0(callable, ft.a.G(oVar, oVar2));
}
@h("none")
@d
@b(a.FULL)
public final <U extends Collection<? super T>> l<U> I(int i10, Callable<U> callable) {
return H(i10, i10, callable);
}
@h(h.Q)
@d
@b(a.FULL)
public final l<T> I1(long j10, TimeUnit timeUnit) {
return J1(j10, timeUnit, yt.b.a());
}
/* JADX DEBUG: Multi-variable search result rejected for r9v0, resolved type: dt.c<? super T, ? super U, ? extends V> */
/* JADX WARN: Multi-variable type inference failed */
/* JADX DEBUG: Type inference failed for r8v1. Raw type applied. Possible types: vs.l<R>, vs.l<V> */
@h("none")
@f
@d
@b(a.FULL)
public final <U, V> l<V> I2(o<? super T, ? extends Iterable<? extends U>> oVar, dt.c<? super T, ? super U, ? extends V> cVar, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.g(cVar, "resultSelector is null");
return (l<R>) x2(s1.a(oVar), cVar, false, Y(), i10);
}
@h("none")
@f
@d
@b(a.SPECIAL)
public final <R> l<R> I3(p<? extends R, ? super T> pVar) {
ft.b.g(pVar, "lifter is null");
return wt.a.R(new z1(this, pVar));
}
@h("none")
@d
@b(a.FULL)
public final vt.b<T> I4(int i10, int i11) {
ft.b.h(i10, "parallelism");
ft.b.h(i11, "prefetch");
return vt.b.A(this, i10, i11);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> I5() {
return wt.a.R(new q3(this));
}
@h("none")
@d
@b(a.FULL)
public final l<T> I6(long j10, long j11, TimeUnit timeUnit) {
return K6(j10, j11, timeUnit, yt.b.a(), false, Y());
}
/* JADX DEBUG: Type inference failed for r4v1. Raw type applied. Possible types: vs.k0<java.util.Map<K, java.util.Collection<V>>>, vs.k0<java.util.Map<K, java.util.Collection<T>>> */
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final <K> k0<Map<K, Collection<T>>> I7(o<? super T, ? extends K> oVar) {
return (k0<Map<K, Collection<V>>>) L7(oVar, ft.a.k(), st.m.asCallable(), st.b.asFunction());
}
@h("none")
@f
@d
@b(a.FULL)
public final <U, R> l<R> I8(c<? extends U> cVar, dt.c<? super T, ? super U, ? extends R> cVar2) {
ft.b.g(cVar, "other is null");
return B8(this, cVar, cVar2);
}
/* JADX DEBUG: Type inference failed for r9v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h(h.Q)
@d
@b(a.ERROR)
public final l<List<T>> J(long j10, long j11, TimeUnit timeUnit) {
return (l<U>) L(j10, j11, timeUnit, yt.b.a(), st.b.asCallable());
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> J1(long j10, TimeUnit timeUnit, j0 j0Var) {
return K1(v7(j10, timeUnit, j0Var));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> J2(o<? super T, ? extends y<? extends R>> oVar) {
return K2(oVar, false, Integer.MAX_VALUE);
}
@h("none")
@d
@b(a.SPECIAL)
public final l<T> J3(long j10) {
if (j10 >= 0) {
return wt.a.R(new a2(this, j10));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j10);
}
@h("none")
@d
@b(a.FULL)
public final ct.a<T> J4() {
return K4(Y());
}
@h("none")
@d
@b(a.FULL)
public final l<T> J5() {
return J4().S8();
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> J6(long j10, long j11, TimeUnit timeUnit, j0 j0Var) {
return K6(j10, j11, timeUnit, j0Var, false, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final <K, V> k0<Map<K, Collection<V>>> J7(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2) {
return L7(oVar, oVar2, st.m.asCallable(), st.b.asFunction());
}
@h("none")
@d
@b(a.FULL)
public final <U, R> l<R> J8(c<? extends U> cVar, dt.c<? super T, ? super U, ? extends R> cVar2, boolean z10) {
return C8(this, cVar, cVar2, z10);
}
/* JADX DEBUG: Type inference failed for r9v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h(h.P)
@d
@b(a.ERROR)
public final l<List<T>> K(long j10, long j11, TimeUnit timeUnit, j0 j0Var) {
return (l<U>) L(j10, j11, timeUnit, j0Var, st.b.asCallable());
}
@h("none")
@f
@d
@b(a.FULL)
public final <U> l<T> K1(c<U> cVar) {
ft.b.g(cVar, "subscriptionIndicator is null");
return wt.a.R(new k0(this, cVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> K2(o<? super T, ? extends y<? extends R>> oVar, boolean z10, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "maxConcurrency");
return wt.a.R(new c1(this, oVar, z10, i10));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <R> l<R> K3(o<? super T, ? extends R> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.R(new b2(this, oVar));
}
@h("none")
@d
@b(a.FULL)
public final ct.a<T> K4(int i10) {
ft.b.h(i10, "bufferSize");
return r2.Y8(this, i10);
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<T> K5(T t10) {
ft.b.g(t10, "defaultItem is null");
return wt.a.U(new t3(this, t10));
}
@h(h.P)
@f
@d
@b(a.FULL)
public final l<T> K6(long j10, long j11, TimeUnit timeUnit, j0 j0Var, boolean z10, int i10) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
ft.b.h(i10, "bufferSize");
if (j10 >= 0) {
return wt.a.R(new f4(this, j10, j11, timeUnit, j0Var, i10, z10));
}
throw new IndexOutOfBoundsException("count >= 0 required but it was " + j10);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final <K, V> k0<Map<K, Collection<V>>> K7(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2, Callable<Map<K, Collection<V>>> callable) {
return L7(oVar, oVar2, callable, st.b.asFunction());
}
@h("none")
@d
@b(a.FULL)
public final <U, R> l<R> K8(c<? extends U> cVar, dt.c<? super T, ? super U, ? extends R> cVar2, boolean z10, int i10) {
return D8(this, cVar, cVar2, z10, i10);
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final <U extends Collection<? super T>> l<U> L(long j10, long j11, TimeUnit timeUnit, j0 j0Var, Callable<U> callable) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
ft.b.g(callable, "bufferSupplier is null");
return wt.a.R(new q(this, j10, j11, timeUnit, j0Var, callable, Integer.MAX_VALUE, false));
}
@h("none")
@Deprecated
@d
@b(a.PASS_THROUGH)
public final <T2> l<T2> L1() {
return wt.a.R(new l0(this, ft.a.k()));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> L2(o<? super T, ? extends q0<? extends R>> oVar) {
return M2(oVar, false, Integer.MAX_VALUE);
}
@h("none")
@d
@b(a.FULL)
public final l<a0<T>> L3() {
return wt.a.R(new e2(this));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> L4(o<? super l<T>, ? extends c<R>> oVar) {
return M4(oVar, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final s<T> L5() {
return wt.a.S(new s3(this));
}
@h(h.Q)
@d
@b(a.FULL)
public final l<T> L6(long j10, TimeUnit timeUnit) {
return O6(j10, timeUnit, yt.b.a(), false, Y());
}
/* JADX DEBUG: Multi-variable search result rejected for r4v0, resolved type: java.util.concurrent.Callable<? extends java.util.Map<K, java.util.Collection<V>>> */
/* JADX WARN: Multi-variable type inference failed */
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <K, V> k0<Map<K, Collection<V>>> L7(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2, Callable<? extends Map<K, Collection<V>>> callable, o<? super K, ? extends Collection<? super V>> oVar3) {
ft.b.g(oVar, "keySelector is null");
ft.b.g(oVar2, "valueSelector is null");
ft.b.g(callable, "mapSupplier is null");
ft.b.g(oVar3, "collectionFactory is null");
return c0(callable, ft.a.H(oVar, oVar2, oVar3));
}
@h("none")
@f
@d
@b(a.FULL)
public final <U, R> l<R> L8(Iterable<U> iterable, dt.c<? super T, ? super U, ? extends R> cVar) {
ft.b.g(iterable, "other is null");
ft.b.g(cVar, "zipper is null");
return wt.a.R(new c5(this, iterable, cVar));
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<List<T>> M(long j10, TimeUnit timeUnit) {
return P(j10, timeUnit, yt.b.a(), Integer.MAX_VALUE);
}
@h("none")
@f
@e
@d
@b(a.PASS_THROUGH)
public final <R> l<R> M1(o<? super T, a0<R>> oVar) {
ft.b.g(oVar, "selector is null");
return wt.a.R(new l0(this, oVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> M2(o<? super T, ? extends q0<? extends R>> oVar, boolean z10, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "maxConcurrency");
return wt.a.R(new e1(this, oVar, z10, i10));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> M4(o<? super l<T>, ? extends c<? extends R>> oVar, int i10) {
ft.b.g(oVar, "selector is null");
ft.b.h(i10, "prefetch");
return wt.a.R(new u2(this, oVar, i10, false));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<T> M5() {
return wt.a.U(new t3(this, null));
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> M6(long j10, TimeUnit timeUnit, j0 j0Var) {
return O6(j10, timeUnit, j0Var, false, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final b0<T> M7() {
return wt.a.T(new mt.g1(this));
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<List<T>> N(long j10, TimeUnit timeUnit, int i10) {
return P(j10, timeUnit, yt.b.a(), i10);
}
@h("none")
@d
@b(a.FULL)
public final l<T> N1() {
return P1(ft.a.k(), ft.a.g());
}
@h("none")
@d
@b(a.NONE)
public final at.c N2(g<? super T> gVar) {
return f6(gVar);
}
@h("none")
@d
@b(a.FULL)
public final l<T> N5(long j10) {
if (j10 <= 0) {
return wt.a.R(this);
}
return wt.a.R(new u3(this, j10));
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> N6(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10) {
return O6(j10, timeUnit, j0Var, z10, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<List<T>> N7() {
return P7(ft.a.p());
}
/* JADX DEBUG: Type inference failed for r9v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h(h.P)
@d
@b(a.ERROR)
public final l<List<T>> O(long j10, TimeUnit timeUnit, j0 j0Var) {
return (l<U>) Q(j10, timeUnit, j0Var, Integer.MAX_VALUE, st.b.asCallable(), false);
}
@h("none")
@d
@b(a.FULL)
public final <K> l<T> O1(o<? super T, K> oVar) {
return P1(oVar, ft.a.g());
}
@h("none")
@d
@b(a.NONE)
public final at.c O2(r<? super T> rVar) {
return Q2(rVar, ft.a.f64187f, ft.a.f64184c);
}
@h("none")
@d
@b(a.FULL)
public final l<T> O5(long j10, TimeUnit timeUnit) {
return W5(u7(j10, timeUnit));
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> O6(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10, int i10) {
return K6(Long.MAX_VALUE, j10, timeUnit, j0Var, z10, i10);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<List<T>> O7(int i10) {
return Q7(ft.a.p(), i10);
}
/* JADX DEBUG: Type inference failed for r9v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h(h.P)
@d
@b(a.ERROR)
public final l<List<T>> P(long j10, TimeUnit timeUnit, j0 j0Var, int i10) {
return (l<U>) Q(j10, timeUnit, j0Var, i10, st.b.asCallable(), false);
}
@h("none")
@d
@b(a.FULL)
public final <K> l<T> P1(o<? super T, K> oVar, Callable<? extends Collection<? super K>> callable) {
ft.b.g(oVar, "keySelector is null");
ft.b.g(callable, "collectionSupplier is null");
return wt.a.R(new n0(this, oVar, callable));
}
@h("none")
@d
@b(a.NONE)
public final at.c P2(r<? super T> rVar, g<? super Throwable> gVar) {
return Q2(rVar, gVar, ft.a.f64184c);
}
@h("none")
@d
@b(a.FULL)
public final l<T> P4(int i10) {
return n4(qt.e.f109149b, true, i10);
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> P5(long j10, TimeUnit timeUnit, j0 j0Var) {
return W5(v7(j10, timeUnit, j0Var));
}
@h(h.Q)
@d
@b(a.FULL)
public final l<T> P6(long j10, TimeUnit timeUnit, boolean z10) {
return O6(j10, timeUnit, yt.b.a(), z10, Y());
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<List<T>> P7(Comparator<? super T> comparator) {
ft.b.g(comparator, "comparator is null");
return C7().s0(ft.a.o(comparator));
}
@h(h.P)
@d
@b(a.ERROR)
public final <U extends Collection<? super T>> l<U> Q(long j10, TimeUnit timeUnit, j0 j0Var, int i10, Callable<U> callable, boolean z10) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
ft.b.g(callable, "bufferSupplier is null");
ft.b.h(i10, "count");
return wt.a.R(new q(this, j10, j10, timeUnit, j0Var, callable, i10, z10));
}
@h("none")
@d
@b(a.FULL)
public final l<T> Q1() {
return S1(ft.a.k());
}
@h("none")
@f
@d
@b(a.NONE)
public final at.c Q2(r<? super T> rVar, g<? super Throwable> gVar, dt.a aVar) {
ft.b.g(rVar, "onNext is null");
ft.b.g(gVar, "onError is null");
ft.b.g(aVar, "onComplete is null");
rt.i iVar = new rt.i(rVar, gVar, aVar);
j6(iVar);
return iVar;
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final s<T> Q4(dt.c<T, T, T> cVar) {
ft.b.g(cVar, "reducer is null");
return wt.a.S(new y2(this, cVar));
}
@h("none")
@d
@b(a.FULL)
public final l<T> Q5(int i10) {
if (i10 < 0) {
throw new IndexOutOfBoundsException("count >= 0 required but it was " + i10);
} else if (i10 == 0) {
return wt.a.R(this);
} else {
return wt.a.R(new v3(this, i10));
}
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <U> l<T> Q6(c<U> cVar) {
ft.b.g(cVar, "other is null");
return wt.a.R(new h4(this, cVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<List<T>> Q7(Comparator<? super T> comparator, int i10) {
ft.b.g(comparator, "comparator is null");
return D7(i10).s0(ft.a.o(comparator));
}
/* JADX DEBUG: Type inference failed for r2v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h("none")
@d
@b(a.ERROR)
public final <B> l<List<T>> R(c<B> cVar) {
return (l<U>) T(cVar, st.b.asCallable());
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> R0(o<? super T, ? extends c<? extends R>> oVar) {
return S0(oVar, 2);
}
@h("none")
@d
@b(a.FULL)
public final l<T> R1(dt.d<? super T, ? super T> dVar) {
ft.b.g(dVar, "comparer is null");
return wt.a.R(new o0(this, ft.a.k(), dVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> k0<R> R4(R r10, dt.c<R, ? super T, R> cVar) {
ft.b.g(r10, "seed is null");
ft.b.g(cVar, "reducer is null");
return wt.a.U(new z2(this, r10, cVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final l<T> R5(long j10, TimeUnit timeUnit) {
return U5(j10, timeUnit, yt.b.a(), false, Y());
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> R6(r<? super T> rVar) {
ft.b.g(rVar, "stopPredicate is null");
return wt.a.R(new i4(this, rVar));
}
/* JADX DEBUG: Type inference failed for r2v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h("none")
@d
@b(a.ERROR)
public final <B> l<List<T>> S(c<B> cVar, int i10) {
ft.b.h(i10, "initialCapacity");
return (l<U>) T(cVar, ft.a.f(i10));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> S0(o<? super T, ? extends c<? extends R>> oVar, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
if (!(this instanceof gt.m)) {
return wt.a.R(new w(this, oVar, i10, j.IMMEDIATE));
}
Object call = ((gt.m) this).call();
if (call == null) {
return k2();
}
return l3.a(call, oVar);
}
@h("none")
@d
@b(a.FULL)
public final <K> l<T> S1(o<? super T, K> oVar) {
ft.b.g(oVar, "keySelector is null");
return wt.a.R(new o0(this, oVar, ft.b.d()));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> k0<R> S4(Callable<R> callable, dt.c<R, ? super T, R> cVar) {
ft.b.g(callable, "seedSupplier is null");
ft.b.g(cVar, "reducer is null");
return wt.a.U(new a3(this, callable, cVar));
}
@h(h.P)
@d
@b(a.UNBOUNDED_IN)
public final l<T> S5(long j10, TimeUnit timeUnit, j0 j0Var) {
return U5(j10, timeUnit, j0Var, false, Y());
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> S6(r<? super T> rVar) {
ft.b.g(rVar, "predicate is null");
return wt.a.R(new j4(this, rVar));
}
@h(h.P)
@f
@d
@b(a.PASS_THROUGH)
public final l<T> S7(j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new s4(this, j0Var));
}
@h("none")
@d
@b(a.ERROR)
public final <B, U extends Collection<? super T>> l<U> T(c<B> cVar, Callable<U> callable) {
ft.b.g(cVar, "boundaryIndicator is null");
ft.b.g(callable, "bufferSupplier is null");
return wt.a.R(new p(this, cVar, callable));
}
@h("none")
@d
@b(a.FULL)
public final c T0(o<? super T, ? extends i> oVar) {
return U0(oVar, 2);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> T1(g<? super T> gVar) {
ft.b.g(gVar, "onAfterNext is null");
return wt.a.R(new p0(this, gVar));
}
@h("none")
@d
@b(a.FULL)
public final l<T> T4() {
return U4(Long.MAX_VALUE);
}
@h(h.P)
@d
@b(a.UNBOUNDED_IN)
public final l<T> T5(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10) {
return U5(j10, timeUnit, j0Var, z10, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final au.f<T> T6() {
au.f<T> fVar = new au.f<>();
j6(fVar);
return fVar;
}
/* JADX DEBUG: Type inference failed for r2v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h("none")
@d
@b(a.ERROR)
public final <B> l<List<T>> U(Callable<? extends c<B>> callable) {
return (l<U>) V(callable, st.b.asCallable());
}
@h("none")
@f
@d
@b(a.FULL)
public final c U0(o<? super T, ? extends i> oVar, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
return wt.a.Q(new lt.c(this, oVar, j.IMMEDIATE, i10));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> U1(dt.a aVar) {
return a2(ft.a.h(), ft.a.h(), ft.a.f64184c, aVar);
}
@h("none")
@d
@b(a.FULL)
public final l<T> U4(long j10) {
int i10 = (j10 > 0 ? 1 : (j10 == 0 ? 0 : -1));
if (i10 < 0) {
throw new IllegalArgumentException("times >= 0 required but it was " + j10);
} else if (i10 == 0) {
return k2();
} else {
return wt.a.R(new c3(this, j10));
}
}
@h(h.P)
@f
@d
@b(a.UNBOUNDED_IN)
public final l<T> U5(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10, int i10) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new w3(this, j10, timeUnit, j0Var, i10 << 1, z10));
}
@h("none")
@d
@b(a.FULL)
public final au.f<T> U6(long j10) {
au.f<T> fVar = new au.f<>(j10);
j6(fVar);
return fVar;
}
@h("none")
@d
@b(a.ERROR)
public final <B, U extends Collection<? super T>> l<U> V(Callable<? extends c<B>> callable, Callable<U> callable2) {
ft.b.g(callable, "boundaryIndicatorSupplier is null");
ft.b.g(callable2, "bufferSupplier is null");
return wt.a.R(new jt.o(this, callable, callable2));
}
@h("none")
@d
@b(a.FULL)
public final c V0(o<? super T, ? extends i> oVar) {
return X0(oVar, true, 2);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> V1(dt.a aVar) {
ft.b.g(aVar, "onFinally is null");
return wt.a.R(new q0(this, aVar));
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> V4(dt.e eVar) {
ft.b.g(eVar, "stop is null");
return wt.a.R(new d3(this, eVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final l<T> V5(long j10, TimeUnit timeUnit, boolean z10) {
return U5(j10, timeUnit, yt.b.a(), z10, Y());
}
@h("none")
@d
@b(a.FULL)
public final au.f<T> V6(long j10, boolean z10) {
au.f<T> fVar = new au.f<>(j10);
if (z10) {
fVar.cancel();
}
j6(fVar);
return fVar;
}
@h("none")
@d
@b(a.FULL)
public final l<l<T>> V7(long j10) {
return X7(j10, j10, Y());
}
/* JADX DEBUG: Type inference failed for r2v1. Raw type applied. Possible types: vs.l<U extends java.util.Collection<? super T>>, vs.l<java.util.List<T>> */
@h("none")
@d
@b(a.ERROR)
public final <TOpening, TClosing> l<List<T>> W(l<? extends TOpening> lVar, o<? super TOpening, ? extends c<? extends TClosing>> oVar) {
return (l<U>) X(lVar, oVar, st.b.asCallable());
}
@h("none")
@d
@b(a.FULL)
public final c W0(o<? super T, ? extends i> oVar, boolean z10) {
return X0(oVar, z10, 2);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> W1(dt.a aVar) {
return c2(ft.a.h(), ft.a.f64188g, aVar);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> W4(o<? super l<Object>, ? extends c<?>> oVar) {
ft.b.g(oVar, "handler is null");
return wt.a.R(new e3(this, oVar));
}
@h("none")
@f
@d
@b(a.FULL)
public final <U> l<T> W5(c<U> cVar) {
ft.b.g(cVar, "other is null");
return wt.a.R(new x3(this, cVar));
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> W6(long j10, TimeUnit timeUnit) {
return X6(j10, timeUnit, yt.b.a());
}
@h("none")
@d
@b(a.FULL)
public final l<l<T>> W7(long j10, long j11) {
return X7(j10, j11, Y());
}
@h("none")
@d
@b(a.ERROR)
public final <TOpening, TClosing, U extends Collection<? super T>> l<U> X(l<? extends TOpening> lVar, o<? super TOpening, ? extends c<? extends TClosing>> oVar, Callable<U> callable) {
ft.b.g(lVar, "openingIndicator is null");
ft.b.g(oVar, "closingIndicator is null");
ft.b.g(callable, "bufferSupplier is null");
return wt.a.R(new jt.n(this, lVar, oVar, callable));
}
@h("none")
@f
@d
@b(a.FULL)
public final c X0(o<? super T, ? extends i> oVar, boolean z10, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
return wt.a.Q(new lt.c(this, oVar, z10 ? j.END : j.BOUNDARY, i10));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> X1(dt.a aVar) {
return a2(ft.a.h(), ft.a.h(), aVar, ft.a.f64184c);
}
@h("none")
@d
@b(a.FULL)
public final ct.a<T> X4() {
return f3.c9(this);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> X5(r<? super T> rVar) {
ft.b.g(rVar, "predicate is null");
return wt.a.R(new y3(this, rVar));
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final l<T> X6(long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new k4(this, j10, timeUnit, j0Var));
}
@h("none")
@d
@b(a.FULL)
public final l<l<T>> X7(long j10, long j11, int i10) {
ft.b.i(j11, "skip");
ft.b.i(j10, "count");
ft.b.h(i10, "bufferSize");
return wt.a.R(new u4(this, j10, j11, i10));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> Y0(o<? super T, ? extends c<? extends R>> oVar) {
return Z0(oVar, 2, true);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> Y1(c00.d<? super T> dVar) {
ft.b.g(dVar, "subscriber is null");
return a2(s1.m(dVar), s1.l(dVar), s1.k(dVar), ft.a.f64184c);
}
@h("none")
@d
@b(a.FULL)
public final ct.a<T> Y4(int i10) {
ft.b.h(i10, "bufferSize");
return f3.Y8(this, i10);
}
/* JADX DEBUG: Type inference failed for r0v3. Raw type applied. Possible types: vs.l<U>, vs.l<T> */
@h("none")
@d
@b(a.FULL)
public final l<T> Y5() {
return (l<U>) C7().s1().K3(ft.a.o(ft.a.p())).F2(ft.a.k());
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> Y6(long j10, TimeUnit timeUnit) {
return v5(j10, timeUnit);
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<l<T>> Y7(long j10, long j11, TimeUnit timeUnit) {
return a8(j10, j11, timeUnit, yt.b.a(), Y());
}
@h("none")
@d
@b(a.FULL)
public final l<T> Z() {
return a0(16);
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> Z0(o<? super T, ? extends c<? extends R>> oVar, int i10, boolean z10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
if (this instanceof gt.m) {
Object call = ((gt.m) this).call();
if (call == null) {
return k2();
}
return l3.a(call, oVar);
}
return wt.a.R(new w(this, oVar, i10, z10 ? j.END : j.BOUNDARY));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> Z1(g<? super a0<T>> gVar) {
ft.b.g(gVar, "onNotification is null");
return a2(ft.a.t(gVar), ft.a.s(gVar), ft.a.r(gVar), ft.a.f64184c);
}
@h(h.Q)
@d
@b(a.FULL)
public final ct.a<T> Z4(int i10, long j10, TimeUnit timeUnit) {
return a5(i10, j10, timeUnit, yt.b.a());
}
/* JADX DEBUG: Type inference failed for r2v3. Raw type applied. Possible types: vs.l<U>, vs.l<T> */
@h("none")
@f
@d
@b(a.FULL)
public final l<T> Z5(Comparator<? super T> comparator) {
ft.b.g(comparator, "sortFunction");
return (l<U>) C7().s1().K3(ft.a.o(comparator)).F2(ft.a.k());
}
@h(h.P)
@d
@b(a.ERROR)
public final l<T> Z6(long j10, TimeUnit timeUnit, j0 j0Var) {
return w5(j10, timeUnit, j0Var);
}
@h(h.P)
@d
@b(a.ERROR)
public final l<l<T>> Z7(long j10, long j11, TimeUnit timeUnit, j0 j0Var) {
return a8(j10, j11, timeUnit, j0Var, Y());
}
@h("none")
@d
@b(a.FULL)
public final l<T> a0(int i10) {
ft.b.h(i10, "initialCapacity");
return wt.a.R(new jt.r(this, i10));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> a1(o<? super T, ? extends c<? extends R>> oVar) {
return b1(oVar, Y(), Y());
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> a2(g<? super T> gVar, g<? super Throwable> gVar2, dt.a aVar, dt.a aVar2) {
ft.b.g(gVar, "onNext is null");
ft.b.g(gVar2, "onError is null");
ft.b.g(aVar, "onComplete is null");
ft.b.g(aVar2, "onAfterTerminate is null");
return wt.a.R(new r0(this, gVar, gVar2, aVar, aVar2));
}
@h(h.P)
@d
@b(a.FULL)
public final ct.a<T> a5(int i10, long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.h(i10, "bufferSize");
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
ft.b.h(i10, "bufferSize");
return f3.a9(this, j10, timeUnit, j0Var, i10);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> a6(c<? extends T> cVar) {
ft.b.g(cVar, "other is null");
return E0(cVar, this);
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> a7(long j10, TimeUnit timeUnit) {
return c7(j10, timeUnit, yt.b.a(), false);
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final l<l<T>> a8(long j10, long j11, TimeUnit timeUnit, j0 j0Var, int i10) {
ft.b.h(i10, "bufferSize");
ft.b.i(j10, "timespan");
ft.b.i(j11, "timeskip");
ft.b.g(j0Var, "scheduler is null");
ft.b.g(timeUnit, "unit is null");
return wt.a.R(new y4(this, j10, j11, timeUnit, j0Var, Long.MAX_VALUE, i10, false));
}
/* JADX DEBUG: Type inference failed for r2v2. Raw type applied. Possible types: vs.l<R>, vs.l<U> */
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <U> l<U> b0(Class<U> cls) {
ft.b.g(cls, "clazz is null");
return (l<R>) K3(ft.a.e(cls));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> b1(o<? super T, ? extends c<? extends R>> oVar, int i10, int i11) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "maxConcurrency");
ft.b.h(i11, "prefetch");
return wt.a.R(new x(this, oVar, i10, i11, j.IMMEDIATE));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> b2(g<? super Throwable> gVar) {
g<? super T> h10 = ft.a.h();
dt.a aVar = ft.a.f64184c;
return a2(h10, gVar, aVar, aVar);
}
@h(h.P)
@d
@b(a.FULL)
public final ct.a<T> b5(int i10, j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return f3.e9(Y4(i10), j0Var);
}
@h("none")
@d
@b(a.FULL)
public final l<T> b6(Iterable<? extends T> iterable) {
return E0(X2(iterable), this);
}
@h(h.P)
@d
@b(a.ERROR)
public final l<T> b7(long j10, TimeUnit timeUnit, j0 j0Var) {
return c7(j10, timeUnit, j0Var, false);
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<l<T>> b8(long j10, TimeUnit timeUnit) {
return g8(j10, timeUnit, yt.b.a(), Long.MAX_VALUE, false);
}
@Override // c00.c
@h("none")
@b(a.SPECIAL)
public final void c(c00.d<? super T> dVar) {
if (dVar instanceof q) {
j6((q) dVar);
return;
}
ft.b.g(dVar, "s is null");
j6(new rt.u(dVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <U> k0<U> c0(Callable<? extends U> callable, dt.b<? super U, ? super T> bVar) {
ft.b.g(callable, "initialItemSupplier is null");
ft.b.g(bVar, "collector is null");
return wt.a.U(new t(this, callable, bVar));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> c1(o<? super T, ? extends c<? extends R>> oVar, int i10, int i11, boolean z10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "maxConcurrency");
ft.b.h(i11, "prefetch");
return wt.a.R(new x(this, oVar, i10, i11, z10 ? j.END : j.BOUNDARY));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> c2(g<? super c00.e> gVar, dt.q qVar, dt.a aVar) {
ft.b.g(gVar, "onSubscribe is null");
ft.b.g(qVar, "onRequest is null");
ft.b.g(aVar, "onCancel is null");
return wt.a.R(new s0(this, gVar, qVar, aVar));
}
@h(h.Q)
@d
@b(a.FULL)
public final ct.a<T> c5(long j10, TimeUnit timeUnit) {
return d5(j10, timeUnit, yt.b.a());
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> c6(T t10) {
ft.b.g(t10, "value is null");
return E0(v3(t10), this);
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final l<T> c7(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new l4(this, j10, timeUnit, j0Var, z10));
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<l<T>> c8(long j10, TimeUnit timeUnit, long j11) {
return g8(j10, timeUnit, yt.b.a(), j11, false);
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <U> k0<U> d0(U u10, dt.b<? super U, ? super T> bVar) {
ft.b.g(u10, "initialItem is null");
return c0(ft.a.m(u10), bVar);
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> d1(o<? super T, ? extends c<? extends R>> oVar, boolean z10) {
return c1(oVar, Y(), Y(), z10);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> d2(g<? super T> gVar) {
g<? super Throwable> h10 = ft.a.h();
dt.a aVar = ft.a.f64184c;
return a2(gVar, h10, aVar, aVar);
}
@h(h.P)
@d
@b(a.FULL)
public final ct.a<T> d5(long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return f3.Z8(this, j10, timeUnit, j0Var);
}
@h("none")
@d
@b(a.FULL)
public final l<T> d6(T... tArr) {
l R2 = R2(tArr);
if (R2 == k2()) {
return wt.a.R(this);
}
return E0(R2, this);
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> d7(long j10, TimeUnit timeUnit, boolean z10) {
return c7(j10, timeUnit, yt.b.a(), z10);
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<l<T>> d8(long j10, TimeUnit timeUnit, long j11, boolean z10) {
return g8(j10, timeUnit, yt.b.a(), j11, z10);
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<Boolean> e(r<? super T> rVar) {
ft.b.g(rVar, "predicate is null");
return wt.a.U(new jt.g(this, rVar));
}
@h("none")
@d
@b(a.FULL)
public final <U> l<U> e1(o<? super T, ? extends Iterable<? extends U>> oVar) {
return f1(oVar, 2);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> e2(dt.q qVar) {
return c2(ft.a.h(), qVar, ft.a.f64184c);
}
/* JADX DEBUG: Type inference failed for r4v1. Raw type applied. Possible types: vs.l<ct.b<K, V>>, vs.l<ct.b<K, T>> */
@h("none")
@d
@b(a.FULL)
public final <K> l<ct.b<K, T>> e3(o<? super T, ? extends K> oVar) {
return (l<ct.b<K, V>>) h3(oVar, ft.a.k(), false, Y());
}
@h(h.P)
@d
@b(a.FULL)
public final ct.a<T> e5(j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return f3.e9(X4(), j0Var);
}
@h("none")
@b(a.UNBOUNDED_IN)
public final at.c e6() {
return i6(ft.a.h(), ft.a.f64187f, ft.a.f64184c, s1.i.INSTANCE);
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> e7(long j10, TimeUnit timeUnit) {
return x1(j10, timeUnit);
}
@h(h.P)
@d
@b(a.ERROR)
public final l<l<T>> e8(long j10, TimeUnit timeUnit, j0 j0Var) {
return g8(j10, timeUnit, j0Var, Long.MAX_VALUE, false);
}
@h("none")
@f
@d
@b(a.FULL)
public final <U> l<U> f1(o<? super T, ? extends Iterable<? extends U>> oVar, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
return wt.a.R(new f1(this, oVar, i10));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> f2(g<? super c00.e> gVar) {
return c2(gVar, ft.a.f64188g, ft.a.f64184c);
}
@h("none")
@d
@b(a.FULL)
public final <K, V> l<ct.b<K, V>> f3(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2) {
return h3(oVar, oVar2, false, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> f5(o<? super l<T>, ? extends c<R>> oVar) {
ft.b.g(oVar, "selector is null");
return f3.d9(s1.d(this), oVar);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final at.c f6(g<? super T> gVar) {
return i6(gVar, ft.a.f64187f, ft.a.f64184c, s1.i.INSTANCE);
}
@h(h.P)
@d
@b(a.ERROR)
public final l<T> f7(long j10, TimeUnit timeUnit, j0 j0Var) {
return y1(j10, timeUnit, j0Var);
}
@h(h.P)
@d
@b(a.ERROR)
public final l<l<T>> f8(long j10, TimeUnit timeUnit, j0 j0Var, long j11) {
return g8(j10, timeUnit, j0Var, j11, false);
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> g1(o<? super T, ? extends y<? extends R>> oVar) {
return h1(oVar, 2);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> g2(dt.a aVar) {
return a2(ft.a.h(), ft.a.a(aVar), aVar, ft.a.f64184c);
}
@h("none")
@d
@b(a.FULL)
public final <K, V> l<ct.b<K, V>> g3(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2, boolean z10) {
return h3(oVar, oVar2, z10, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> g4(c<? extends T> cVar) {
ft.b.g(cVar, "other is null");
return O3(this, cVar);
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> g5(o<? super l<T>, ? extends c<R>> oVar, int i10) {
ft.b.g(oVar, "selector is null");
ft.b.h(i10, "bufferSize");
return f3.d9(s1.e(this, i10), oVar);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final at.c g6(g<? super T> gVar, g<? super Throwable> gVar2) {
return i6(gVar, gVar2, ft.a.f64184c, s1.i.INSTANCE);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> g7() {
return i7(TimeUnit.MILLISECONDS, yt.b.a());
}
@h(h.P)
@d
@b(a.ERROR)
public final l<l<T>> g8(long j10, TimeUnit timeUnit, j0 j0Var, long j11, boolean z10) {
return h8(j10, timeUnit, j0Var, j11, z10, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> h(c<? extends T> cVar) {
ft.b.g(cVar, "other is null");
return g(this, cVar);
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> h1(o<? super T, ? extends y<? extends R>> oVar, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
return wt.a.R(new lt.d(this, oVar, j.IMMEDIATE, i10));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final s<T> h2(long j10) {
if (j10 >= 0) {
return wt.a.S(new u0(this, j10));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j10);
}
@h("none")
@f
@d
@b(a.FULL)
public final <K, V> l<ct.b<K, V>> h3(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2, boolean z10, int i10) {
ft.b.g(oVar, "keySelector is null");
ft.b.g(oVar2, "valueSelector is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new n1(this, oVar, oVar2, i10, z10, null));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> h4(@f i iVar) {
ft.b.g(iVar, "other is null");
return wt.a.R(new f2(this, iVar));
}
@h(h.Q)
@d
@b(a.FULL)
public final <R> l<R> h5(o<? super l<T>, ? extends c<R>> oVar, int i10, long j10, TimeUnit timeUnit) {
return i5(oVar, i10, j10, timeUnit, yt.b.a());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final at.c h6(g<? super T> gVar, g<? super Throwable> gVar2, dt.a aVar) {
return i6(gVar, gVar2, aVar, s1.i.INSTANCE);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> h7(TimeUnit timeUnit) {
return i7(timeUnit, yt.b.a());
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final l<l<T>> h8(long j10, TimeUnit timeUnit, j0 j0Var, long j11, boolean z10, int i10) {
ft.b.h(i10, "bufferSize");
ft.b.g(j0Var, "scheduler is null");
ft.b.g(timeUnit, "unit is null");
ft.b.i(j11, "count");
return wt.a.R(new y4(this, j10, j10, timeUnit, j0Var, j11, i10, z10));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> i1(o<? super T, ? extends y<? extends R>> oVar) {
return k1(oVar, true, 2);
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<T> i2(long j10, T t10) {
if (j10 >= 0) {
ft.b.g(t10, "defaultItem is null");
return wt.a.U(new v0(this, j10, t10));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j10);
}
@h("none")
@f
@d
@b(a.FULL)
public final <K, V> l<ct.b<K, V>> i3(o<? super T, ? extends K> oVar, o<? super T, ? extends V> oVar2, boolean z10, int i10, o<? super g<Object>, ? extends Map<K, Object>> oVar3) {
ft.b.g(oVar, "keySelector is null");
ft.b.g(oVar2, "valueSelector is null");
ft.b.h(i10, "bufferSize");
ft.b.g(oVar3, "evictingMapFactory is null");
return wt.a.R(new n1(this, oVar, oVar2, i10, z10, oVar3));
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> i4(@f y<? extends T> yVar) {
ft.b.g(yVar, "other is null");
return wt.a.R(new g2(this, yVar));
}
@h(h.P)
@f
@d
@b(a.FULL)
public final <R> l<R> i5(o<? super l<T>, ? extends c<R>> oVar, int i10, long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(oVar, "selector is null");
ft.b.g(timeUnit, "unit is null");
ft.b.h(i10, "bufferSize");
ft.b.g(j0Var, "scheduler is null");
return f3.d9(s1.f(this, i10, j10, timeUnit, j0Var), oVar);
}
@h("none")
@f
@d
@b(a.SPECIAL)
public final at.c i6(g<? super T> gVar, g<? super Throwable> gVar2, dt.a aVar, g<? super c00.e> gVar3) {
ft.b.g(gVar, "onNext is null");
ft.b.g(gVar2, "onError is null");
ft.b.g(aVar, "onComplete is null");
ft.b.g(gVar3, "onSubscribe is null");
rt.m mVar = new rt.m(gVar, gVar2, aVar, gVar3);
j6(mVar);
return mVar;
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> i7(TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new m4(this, timeUnit, j0Var));
}
@h("none")
@d
@b(a.ERROR)
public final <B> l<l<T>> i8(c<B> cVar) {
return j8(cVar, Y());
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<Boolean> j(r<? super T> rVar) {
ft.b.g(rVar, "predicate is null");
return wt.a.U(new jt.j(this, rVar));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> j1(o<? super T, ? extends y<? extends R>> oVar, boolean z10) {
return k1(oVar, z10, 2);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<T> j2(long j10) {
if (j10 >= 0) {
return wt.a.U(new v0(this, j10, null));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j10);
}
/* JADX DEBUG: Type inference failed for r3v1. Raw type applied. Possible types: vs.l<ct.b<K, V>>, vs.l<ct.b<K, T>> */
@h("none")
@d
@b(a.FULL)
public final <K> l<ct.b<K, T>> j3(o<? super T, ? extends K> oVar, boolean z10) {
return (l<ct.b<K, V>>) h3(oVar, ft.a.k(), z10, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> j4(@f q0<? extends T> q0Var) {
ft.b.g(q0Var, "other is null");
return wt.a.R(new h2(this, q0Var));
}
@h(h.P)
@f
@d
@b(a.FULL)
public final <R> l<R> j5(o<? super l<T>, ? extends c<R>> oVar, int i10, j0 j0Var) {
ft.b.g(oVar, "selector is null");
ft.b.g(j0Var, "scheduler is null");
ft.b.h(i10, "bufferSize");
return f3.d9(s1.e(this, i10), s1.h(oVar, j0Var));
}
@h("none")
@b(a.SPECIAL)
public final void j6(q<? super T> qVar) {
ft.b.g(qVar, "s is null");
try {
c00.d<? super T> d02 = wt.a.d0(this, qVar);
ft.b.g(d02, "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");
k6(d02);
} catch (NullPointerException e10) {
throw e10;
} catch (Throwable th2) {
bt.b.b(th2);
wt.a.Y(th2);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th2);
throw nullPointerException;
}
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> j7(j0 j0Var) {
return i7(TimeUnit.MILLISECONDS, j0Var);
}
@h("none")
@f
@d
@b(a.ERROR)
public final <B> l<l<T>> j8(c<B> cVar, int i10) {
ft.b.g(cVar, "boundaryIndicator is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new v4(this, cVar, i10));
}
@h("none")
@d
@b(a.SPECIAL)
public final <R> R k(@f m<T, ? extends R> mVar) {
return (R) ((m) ft.b.g(mVar, "converter is null")).a(this);
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> k1(o<? super T, ? extends y<? extends R>> oVar, boolean z10, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
return wt.a.R(new lt.d(this, oVar, z10 ? j.END : j.BOUNDARY, i10));
}
@h("none")
@f
@d
@b(a.ERROR)
public final <TRight, TLeftEnd, TRightEnd, R> l<R> k3(c<? extends TRight> cVar, o<? super T, ? extends c<TLeftEnd>> oVar, o<? super TRight, ? extends c<TRightEnd>> oVar2, dt.c<? super T, ? super l<TRight>, ? extends R> cVar2) {
ft.b.g(cVar, "other is null");
ft.b.g(oVar, "leftEnd is null");
ft.b.g(oVar2, "rightEnd is null");
ft.b.g(cVar2, "resultSelector is null");
return wt.a.R(new o1(this, cVar, oVar, oVar2, cVar2));
}
@h(h.Q)
@d
@b(a.FULL)
public final <R> l<R> k5(o<? super l<T>, ? extends c<R>> oVar, long j10, TimeUnit timeUnit) {
return l5(oVar, j10, timeUnit, yt.b.a());
}
public abstract void k6(c00.d<? super T> dVar);
@h(h.Q)
@d
@b(a.PASS_THROUGH)
public final l<T> k7(long j10, TimeUnit timeUnit) {
return s7(j10, timeUnit, null, yt.b.a());
}
@h("none")
@d
@b(a.ERROR)
public final <U, V> l<l<T>> k8(c<U> cVar, o<? super U, ? extends c<V>> oVar) {
return l8(cVar, oVar, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final T l() {
rt.d dVar = new rt.d();
j6(dVar);
T t10 = (T) dVar.a();
if (t10 != null) {
return t10;
}
throw new NoSuchElementException();
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> l1(o<? super T, ? extends q0<? extends R>> oVar) {
return m1(oVar, 2);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> l3() {
return wt.a.R(new p1(this));
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> l4(j0 j0Var) {
return n4(j0Var, false, Y());
}
@h(h.P)
@f
@d
@b(a.FULL)
public final <R> l<R> l5(o<? super l<T>, ? extends c<R>> oVar, long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(oVar, "selector is null");
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return f3.d9(s1.g(this, j10, timeUnit, j0Var), oVar);
}
@h(h.P)
@f
@d
@b(a.PASS_THROUGH)
public final l<T> l6(@f j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return m6(j0Var, !(this instanceof f0));
}
@h(h.Q)
@f
@d
@b(a.FULL)
public final l<T> l7(long j10, TimeUnit timeUnit, c<? extends T> cVar) {
ft.b.g(cVar, "other is null");
return s7(j10, timeUnit, cVar, yt.b.a());
}
@h("none")
@f
@d
@b(a.ERROR)
public final <U, V> l<l<T>> l8(c<U> cVar, o<? super U, ? extends c<V>> oVar, int i10) {
ft.b.g(cVar, "openingIndicator is null");
ft.b.g(oVar, "closingIndicator is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new w4(this, cVar, oVar, i10));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final T m(T t10) {
rt.d dVar = new rt.d();
j6(dVar);
T t11 = (T) dVar.a();
return t11 != null ? t11 : t10;
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> m1(o<? super T, ? extends q0<? extends R>> oVar, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
return wt.a.R(new lt.e(this, oVar, j.IMMEDIATE, i10));
}
@d
@h("none")
@b(a.UNBOUNDED_IN)
public final c m3() {
return wt.a.Q(new r1(this));
}
@h(h.P)
@d
@b(a.FULL)
public final l<T> m4(j0 j0Var, boolean z10) {
return n4(j0Var, z10, Y());
}
@h(h.P)
@f
@d
@b(a.FULL)
public final <R> l<R> m5(o<? super l<T>, ? extends c<R>> oVar, j0 j0Var) {
ft.b.g(oVar, "selector is null");
ft.b.g(j0Var, "scheduler is null");
return f3.d9(s1.d(this), s1.h(oVar, j0Var));
}
@h(h.P)
@f
@d
@b(a.PASS_THROUGH)
public final l<T> m6(@f j0 j0Var, boolean z10) {
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new z3(this, j0Var, z10));
}
@h(h.P)
@d
@b(a.PASS_THROUGH)
public final l<T> m7(long j10, TimeUnit timeUnit, j0 j0Var) {
return s7(j10, timeUnit, null, j0Var);
}
@h("none")
@d
@b(a.ERROR)
public final <B> l<l<T>> m8(Callable<? extends c<B>> callable) {
return n8(callable, Y());
}
@h("none")
@b(a.UNBOUNDED_IN)
public final void n(g<? super T> gVar) {
Iterator<T> it2 = o().iterator();
while (it2.hasNext()) {
try {
gVar.accept(it2.next());
} catch (Throwable th2) {
bt.b.b(th2);
((at.c) it2).dispose();
throw st.k.f(th2);
}
}
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> n1(o<? super T, ? extends q0<? extends R>> oVar) {
return p1(oVar, true, 2);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<T> n2(r<? super T> rVar) {
ft.b.g(rVar, "predicate is null");
return wt.a.R(new y0(this, rVar));
}
@h(h.P)
@f
@d
@b(a.FULL)
public final l<T> n4(j0 j0Var, boolean z10, int i10) {
ft.b.g(j0Var, "scheduler is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new j2(this, j0Var, z10, i10));
}
@h("none")
@d
@b(a.FULL)
public final l<T> n5() {
return p5(Long.MAX_VALUE, ft.a.c());
}
@h("none")
@d
@b(a.SPECIAL)
public final <E extends c00.d<? super T>> E n6(E e10) {
c(e10);
return e10;
}
@h(h.P)
@f
@d
@b(a.FULL)
public final l<T> n7(long j10, TimeUnit timeUnit, j0 j0Var, c<? extends T> cVar) {
ft.b.g(cVar, "other is null");
return s7(j10, timeUnit, cVar, j0Var);
}
@h("none")
@f
@d
@b(a.ERROR)
public final <B> l<l<T>> n8(Callable<? extends c<B>> callable, int i10) {
ft.b.g(callable, "boundaryIndicatorSupplier is null");
ft.b.h(i10, "bufferSize");
return wt.a.R(new x4(this, callable, i10));
}
@h("none")
@d
@b(a.FULL)
public final Iterable<T> o() {
return p(Y());
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> o1(o<? super T, ? extends q0<? extends R>> oVar, boolean z10) {
return p1(oVar, z10, 2);
}
@h("none")
@d
@b(a.SPECIAL)
public final k0<T> o2(T t10) {
return i2(0, t10);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <U> l<U> o4(Class<U> cls) {
ft.b.g(cls, "clazz is null");
return n2(ft.a.l(cls)).b0(cls);
}
@h("none")
@d
@b(a.FULL)
public final l<T> o5(long j10) {
return p5(j10, ft.a.c());
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> o6(c<? extends T> cVar) {
ft.b.g(cVar, "other is null");
return wt.a.R(new a4(this, cVar));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <U, V> l<T> o7(c<U> cVar, o<? super T, ? extends c<V>> oVar) {
ft.b.g(cVar, "firstTimeoutIndicator is null");
return t7(cVar, oVar, null);
}
/* JADX DEBUG: Multi-variable search result rejected for r2v0, resolved type: vs.l<T> */
/* JADX WARN: Multi-variable type inference failed */
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <T1, T2, T3, T4, R> l<R> o8(c<T1> cVar, c<T2> cVar2, c<T3> cVar3, c<T4> cVar4, dt.j<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> jVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
ft.b.g(cVar4, "source4 is null");
return t8(new c[]{cVar, cVar2, cVar3, cVar4}, ft.a.A(jVar));
}
@h("none")
@d
@b(a.FULL)
public final Iterable<T> p(int i10) {
ft.b.h(i10, "bufferSize");
return new jt.b(this, i10);
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> p1(o<? super T, ? extends q0<? extends R>> oVar, boolean z10, int i10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "prefetch");
return wt.a.R(new lt.e(this, oVar, z10 ? j.END : j.BOUNDARY, i10));
}
@h("none")
@d
@b(a.SPECIAL)
public final s<T> p2() {
return h2(0);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final l<T> p4() {
return t4(Y(), false, true);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> p5(long j10, r<? super Throwable> rVar) {
if (j10 >= 0) {
ft.b.g(rVar, "predicate is null");
return wt.a.R(new h3(this, j10, rVar));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j10);
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> p6(o<? super T, ? extends c<? extends R>> oVar) {
return q6(oVar, Y());
}
@h("none")
@f
@d
@b(a.FULL)
public final <U, V> l<T> p7(c<U> cVar, o<? super T, ? extends c<V>> oVar, c<? extends T> cVar2) {
ft.b.g(cVar, "firstTimeoutSelector is null");
ft.b.g(cVar2, "other is null");
return t7(cVar, oVar, cVar2);
}
/* JADX DEBUG: Multi-variable search result rejected for r2v0, resolved type: vs.l<T> */
/* JADX WARN: Multi-variable type inference failed */
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <T1, T2, T3, R> l<R> p8(c<T1> cVar, c<T2> cVar2, c<T3> cVar3, i<? super T, ? super T1, ? super T2, ? super T3, R> iVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
ft.b.g(cVar3, "source3 is null");
return t8(new c[]{cVar, cVar2, cVar3}, ft.a.z(iVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final T q() {
rt.e eVar = new rt.e();
j6(eVar);
T t10 = (T) eVar.a();
if (t10 != null) {
return t10;
}
throw new NoSuchElementException();
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> q1(c<? extends T> cVar) {
ft.b.g(cVar, "other is null");
return A0(this, cVar);
}
@h("none")
@d
@b(a.SPECIAL)
public final k0<T> q2() {
return j2(0);
}
@h("none")
@d
@b(a.ERROR)
public final l<T> q4(int i10) {
return t4(i10, false, false);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> q5(dt.d<? super Integer, ? super Throwable> dVar) {
ft.b.g(dVar, "predicate is null");
return wt.a.R(new g3(this, dVar));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> q6(o<? super T, ? extends c<? extends R>> oVar, int i10) {
return r6(oVar, i10, false);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final <V> l<T> q7(o<? super T, ? extends c<V>> oVar) {
return t7(null, oVar, null);
}
/* JADX DEBUG: Multi-variable search result rejected for r2v0, resolved type: vs.l<T> */
/* JADX WARN: Multi-variable type inference failed */
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <T1, T2, R> l<R> q8(c<T1> cVar, c<T2> cVar2, dt.h<? super T, ? super T1, ? super T2, R> hVar) {
ft.b.g(cVar, "source1 is null");
ft.b.g(cVar2, "source2 is null");
return t8(new c[]{cVar, cVar2}, ft.a.y(hVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final T r(T t10) {
rt.e eVar = new rt.e();
j6(eVar);
T t11 = (T) eVar.a();
return t11 != null ? t11 : t10;
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<T> r1(@f i iVar) {
ft.b.g(iVar, "other is null");
return wt.a.R(new a0(this, iVar));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> r2(o<? super T, ? extends c<? extends R>> oVar) {
return C2(oVar, false, Y(), Y());
}
@h("none")
@d
@b(a.ERROR)
public final l<T> r4(int i10, dt.a aVar) {
return u4(i10, false, false, aVar);
}
@h("none")
@d
@b(a.FULL)
public final l<T> r5(r<? super Throwable> rVar) {
return p5(Long.MAX_VALUE, rVar);
}
public <R> l<R> r6(o<? super T, ? extends c<? extends R>> oVar, int i10, boolean z10) {
ft.b.g(oVar, "mapper is null");
ft.b.h(i10, "bufferSize");
if (!(this instanceof gt.m)) {
return wt.a.R(new b4(this, oVar, i10, z10));
}
Object call = ((gt.m) this).call();
if (call == null) {
return k2();
}
return l3.a(call, oVar);
}
@h("none")
@f
@d
@b(a.FULL)
public final <V> l<T> r7(o<? super T, ? extends c<V>> oVar, l<? extends T> lVar) {
ft.b.g(lVar, "other is null");
return t7(null, oVar, lVar);
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <U, R> l<R> r8(c<? extends U> cVar, dt.c<? super T, ? super U, ? extends R> cVar2) {
ft.b.g(cVar, "other is null");
ft.b.g(cVar2, "combiner is null");
return wt.a.R(new z4(this, cVar2, cVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final Iterable<T> s() {
return new jt.c(this);
}
@h("none")
@d
@b(a.FULL)
public final l<T> s1(@f y<? extends T> yVar) {
ft.b.g(yVar, "other is null");
return wt.a.R(new b0(this, yVar));
}
@h("none")
@d
@b(a.FULL)
public final <R> l<R> s2(o<? super T, ? extends c<? extends R>> oVar, int i10) {
return C2(oVar, false, i10, Y());
}
@h("none")
@d
@b(a.ERROR)
public final l<T> s4(int i10, boolean z10) {
return t4(i10, z10, false);
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> s5(dt.e eVar) {
ft.b.g(eVar, "stop is null");
return p5(Long.MAX_VALUE, ft.a.v(eVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final c s6(@f o<? super T, ? extends i> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.Q(new lt.f(this, oVar, false));
}
public final l<T> s7(long j10, TimeUnit timeUnit, c<? extends T> cVar, j0 j0Var) {
ft.b.g(timeUnit, "timeUnit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new o4(this, j10, timeUnit, j0Var, cVar));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <R> l<R> s8(Iterable<? extends c<?>> iterable, o<? super Object[], R> oVar) {
ft.b.g(iterable, "others is null");
ft.b.g(oVar, "combiner is null");
return wt.a.R(new a5(this, iterable, oVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final Iterable<T> t(T t10) {
return new jt.d(this, t10);
}
@h("none")
@d
@b(a.FULL)
public final l<T> t1(@f q0<? extends T> q0Var) {
ft.b.g(q0Var, "other is null");
return wt.a.R(new c0(this, q0Var));
}
@h("none")
@d
@b(a.FULL)
public final <U, R> l<R> t2(o<? super T, ? extends c<? extends U>> oVar, dt.c<? super T, ? super U, ? extends R> cVar) {
return x2(oVar, cVar, false, Y(), Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<Boolean> t3() {
return e(ft.a.b());
}
@h("none")
@d
@b(a.SPECIAL)
public final l<T> t4(int i10, boolean z10, boolean z11) {
ft.b.h(i10, "capacity");
return wt.a.R(new k2(this, i10, z11, z10, ft.a.f64184c));
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> t5(o<? super l<Throwable>, ? extends c<?>> oVar) {
ft.b.g(oVar, "handler is null");
return wt.a.R(new i3(this, oVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final c t6(@f o<? super T, ? extends i> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.Q(new lt.f(this, oVar, true));
}
public final <U, V> l<T> t7(c<U> cVar, o<? super T, ? extends c<V>> oVar, c<? extends T> cVar2) {
ft.b.g(oVar, "itemTimeoutIndicator is null");
return wt.a.R(new n4(this, cVar, oVar, cVar2));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final <R> l<R> t8(c<?>[] cVarArr, o<? super Object[], R> oVar) {
ft.b.g(cVarArr, "others is null");
ft.b.g(oVar, "combiner is null");
return wt.a.R(new a5(this, cVarArr, oVar));
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final Iterable<T> u() {
return new jt.e(this);
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final k0<Boolean> u1(Object obj) {
ft.b.g(obj, "item is null");
return j(ft.a.i(obj));
}
@h("none")
@d
@b(a.FULL)
public final <U, R> l<R> u2(o<? super T, ? extends c<? extends U>> oVar, dt.c<? super T, ? super U, ? extends R> cVar, int i10) {
return x2(oVar, cVar, false, i10, Y());
}
@h("none")
@f
@d
@b(a.ERROR)
public final <TRight, TLeftEnd, TRightEnd, R> l<R> u3(c<? extends TRight> cVar, o<? super T, ? extends c<TLeftEnd>> oVar, o<? super TRight, ? extends c<TRightEnd>> oVar2, dt.c<? super T, ? super TRight, ? extends R> cVar2) {
ft.b.g(cVar, "other is null");
ft.b.g(oVar, "leftEnd is null");
ft.b.g(oVar2, "rightEnd is null");
ft.b.g(cVar2, "resultSelector is null");
return wt.a.R(new v1(this, cVar, oVar, oVar2, cVar2));
}
@h("none")
@f
@d
@b(a.SPECIAL)
public final l<T> u4(int i10, boolean z10, boolean z11, dt.a aVar) {
ft.b.g(aVar, "onOverflow is null");
ft.b.h(i10, "capacity");
return wt.a.R(new k2(this, i10, z11, z10, aVar));
}
@h("none")
@b(a.PASS_THROUGH)
public final void u5(c00.d<? super T> dVar) {
ft.b.g(dVar, "s is null");
if (dVar instanceof au.d) {
j6((au.d) dVar);
} else {
j6(new au.d(dVar));
}
}
@h("none")
@d
@b(a.SPECIAL)
public final <R> l<R> u6(o<? super T, ? extends c<? extends R>> oVar) {
return v6(oVar, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final T v() {
return M5().i();
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final k0<Long> v1() {
return wt.a.U(new e0(this));
}
@h("none")
@d
@b(a.FULL)
public final <U, R> l<R> v2(o<? super T, ? extends c<? extends U>> oVar, dt.c<? super T, ? super U, ? extends R> cVar, boolean z10) {
return x2(oVar, cVar, z10, Y(), Y());
}
@h("none")
@f
@d
@b(a.SPECIAL)
public final l<T> v4(long j10, dt.a aVar, a aVar2) {
ft.b.g(aVar2, "overflowStrategy is null");
ft.b.i(j10, "capacity");
return wt.a.R(new l2(this, j10, aVar, aVar2));
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> v5(long j10, TimeUnit timeUnit) {
return w5(j10, timeUnit, yt.b.a());
}
@h("none")
@d
@b(a.SPECIAL)
public final <R> l<R> v6(o<? super T, ? extends c<? extends R>> oVar, int i10) {
return r6(oVar, i10, true);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final T w(T t10) {
return K5(t10).i();
}
@h("none")
@d
@b(a.FULL)
public final <U, R> l<R> w2(o<? super T, ? extends c<? extends U>> oVar, dt.c<? super T, ? super U, ? extends R> cVar, boolean z10, int i10) {
return x2(oVar, cVar, z10, i10, Y());
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final l<T> w4(boolean z10) {
return t4(Y(), z10, true);
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final l<T> w5(long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new k3(this, j10, timeUnit, j0Var, false));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> w6(@f o<? super T, ? extends y<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.R(new lt.g(this, oVar, false));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> w7() {
return y7(TimeUnit.MILLISECONDS, yt.b.a());
}
@h("none")
@b(a.UNBOUNDED_IN)
public final void x() {
jt.l.a(this);
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final <R> l<R> x0(r<? super T, ? extends R> rVar) {
return Y2(((r) ft.b.g(rVar, "composer is null")).a(this));
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> x1(long j10, TimeUnit timeUnit) {
return y1(j10, timeUnit, yt.b.a());
}
@h("none")
@f
@d
@b(a.FULL)
public final <U, R> l<R> x2(o<? super T, ? extends c<? extends U>> oVar, dt.c<? super T, ? super U, ? extends R> cVar, boolean z10, int i10, int i11) {
ft.b.g(oVar, "mapper is null");
ft.b.g(cVar, "combiner is null");
ft.b.h(i10, "maxConcurrency");
ft.b.h(i11, "bufferSize");
return C2(s1.b(oVar, cVar), z10, i10, i11);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final l<T> x4() {
return wt.a.R(new m2(this));
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final l<T> x5(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new k3(this, j10, timeUnit, j0Var, z10));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> x6(@f o<? super T, ? extends y<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.R(new lt.g(this, oVar, true));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> x7(TimeUnit timeUnit) {
return y7(timeUnit, yt.b.a());
}
@h("none")
@b(a.SPECIAL)
public final void y(c00.d<? super T> dVar) {
jt.l.b(this, dVar);
}
@h(h.P)
@f
@d
@b(a.ERROR)
public final l<T> y1(long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.R(new h0(this, j10, timeUnit, j0Var));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> y2(o<? super T, ? extends c<? extends R>> oVar, o<? super Throwable, ? extends c<? extends R>> oVar2, Callable<? extends c<? extends R>> callable) {
ft.b.g(oVar, "onNextMapper is null");
ft.b.g(oVar2, "onErrorMapper is null");
ft.b.g(callable, "onCompleteSupplier is null");
return M3(new c2(this, oVar, oVar2, callable));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final l<T> y4(g<? super T> gVar) {
ft.b.g(gVar, "onDrop is null");
return wt.a.R(new m2(this, gVar));
}
@h(h.Q)
@d
@b(a.ERROR)
public final l<T> y5(long j10, TimeUnit timeUnit, boolean z10) {
return x5(j10, timeUnit, yt.b.a(), z10);
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> y6(@f o<? super T, ? extends q0<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.R(new lt.h(this, oVar, false));
}
@h("none")
@f
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> y7(TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return K3(ft.a.w(timeUnit, j0Var));
}
@h("none")
@b(a.UNBOUNDED_IN)
public final void z(g<? super T> gVar) {
jt.l.c(this, gVar, ft.a.f64187f, ft.a.f64184c);
}
@h("none")
@f
@d
@b(a.ERROR)
public final <U> l<T> z1(o<? super T, ? extends c<U>> oVar) {
ft.b.g(oVar, "debounceIndicator is null");
return wt.a.R(new g0(this, oVar));
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> z2(o<? super T, ? extends c<? extends R>> oVar, o<Throwable, ? extends c<? extends R>> oVar2, Callable<? extends c<? extends R>> callable, int i10) {
ft.b.g(oVar, "onNextMapper is null");
ft.b.g(oVar2, "onErrorMapper is null");
ft.b.g(callable, "onCompleteSupplier is null");
return N3(new c2(this, oVar, oVar2, callable), i10);
}
@h("none")
@d
@b(a.UNBOUNDED_IN)
public final l<T> z4() {
return wt.a.R(new o2(this));
}
@h("none")
@f
@d
@b(a.ERROR)
public final <U> l<T> z5(c<U> cVar) {
ft.b.g(cVar, "sampler is null");
return wt.a.R(new j3(this, cVar, false));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <R> l<R> z6(@f o<? super T, ? extends q0<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.R(new lt.h(this, oVar, true));
}
@h("none")
@d
@b(a.PASS_THROUGH)
public final l<yt.d<T>> z7(j0 j0Var) {
return y7(TimeUnit.MILLISECONDS, j0Var);
}
}