package vs;
import c00.c;
import dt.g;
import dt.i;
import dt.l;
import dt.m;
import dt.n;
import dt.o;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import jt.d1;
import jt.z;
import kt.a0;
import kt.a1;
import kt.b0;
import kt.b1;
import kt.c0;
import kt.c1;
import kt.d0;
import kt.e;
import kt.e0;
import kt.e1;
import kt.f0;
import kt.f1;
import kt.g0;
import kt.g1;
import kt.h0;
import kt.h1;
import kt.i0;
import kt.i1;
import kt.j;
import kt.j0;
import kt.j1;
import kt.k;
import kt.k0;
import kt.k1;
import kt.l0;
import kt.l1;
import kt.m0;
import kt.m1;
import kt.n0;
import kt.n1;
import kt.o0;
import kt.o1;
import kt.p;
import kt.p1;
import kt.q;
import kt.q0;
import kt.q1;
import kt.r;
import kt.r1;
import kt.s0;
import kt.s1;
import kt.t;
import kt.t0;
import kt.t1;
import kt.u;
import kt.u0;
import kt.u1;
import kt.v;
import kt.v0;
import kt.w;
import kt.w0;
import kt.x;
import kt.x0;
import kt.y;
import kt.y0;
import kt.z0;
import zs.a;
import zs.b;
import zs.d;
import zs.f;
import zs.h;
/* compiled from: Maybe */
public abstract class s<T> implements y<T> {
@h("none")
@d
@b(a.FULL)
public static <T> l<T> A0(Iterable<? extends y<? extends T>> iterable) {
return y0(l.X2(iterable));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> B0(y<? extends T> yVar, y<? extends T> yVar2) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
return F0(yVar, yVar2);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> C0(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
return F0(yVar, yVar2, yVar3);
}
@h("none")
@f
@d
public static <T> s<T> D(w<T> wVar) {
ft.b.g(wVar, "onSubscribe is null");
return wt.a.S(new j(wVar));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> D0(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3, y<? extends T> yVar4) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
return F0(yVar, yVar2, yVar3, yVar4);
}
@h("none")
@f
@d
public static <T> s<T> E0(y<? extends y<? extends T>> yVar) {
ft.b.g(yVar, "source is null");
return wt.a.S(new h0(yVar, ft.a.k()));
}
@h("none")
@f
@d
public static <T> s<T> F(Callable<? extends y<? extends T>> callable) {
ft.b.g(callable, "maybeSupplier is null");
return wt.a.S(new k(callable));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> F0(y<? extends T>... yVarArr) {
ft.b.g(yVarArr, "sources is null");
if (yVarArr.length == 0) {
return l.k2();
}
if (yVarArr.length == 1) {
return wt.a.R(new m1(yVarArr[0]));
}
return wt.a.R(new x0(yVarArr));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> G0(y<? extends T>... yVarArr) {
if (yVarArr.length == 0) {
return l.k2();
}
return l.R2(yVarArr).B2(o1.instance(), true, yVarArr.length);
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> H0(c<? extends y<? extends T>> cVar) {
return I0(cVar, Integer.MAX_VALUE);
}
@d
@h(h.Q)
public static s<Long> H1(long j10, TimeUnit timeUnit) {
return I1(j10, timeUnit, yt.b.a());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> I0(c<? extends y<? extends T>> cVar, int i10) {
ft.b.g(cVar, "source is null");
ft.b.h(i10, "maxConcurrency");
return wt.a.R(new d1(cVar, o1.instance(), true, i10, 1));
}
@h(h.P)
@f
@d
public static s<Long> I1(long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.S(new l1(Math.max(0L, j10), timeUnit, j0Var));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> J0(Iterable<? extends y<? extends T>> iterable) {
return l.X2(iterable).A2(o1.instance(), true);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> K0(y<? extends T> yVar, y<? extends T> yVar2) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
return G0(yVar, yVar2);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> L0(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
return G0(yVar, yVar2, yVar3);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> M0(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3, y<? extends T> yVar4) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
return G0(yVar, yVar2, yVar3, yVar4);
}
@d
@h("none")
public static <T> s<T> O0() {
return wt.a.S(y0.f83081a);
}
@h("none")
@f
@d
public static <T> s<T> O1(y<T> yVar) {
if (!(yVar instanceof s)) {
ft.b.g(yVar, "onSubscribe is null");
return wt.a.S(new q1(yVar));
}
throw new IllegalArgumentException("unsafeCreate(Maybe) should be upgraded");
}
@d
@h("none")
public static <T, D> s<T> Q1(Callable<? extends D> callable, o<? super D, ? extends y<? extends T>> oVar, g<? super D> gVar) {
return R1(callable, oVar, gVar, true);
}
@h("none")
@f
@d
public static <T, D> s<T> R1(Callable<? extends D> callable, o<? super D, ? extends y<? 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, "disposer is null");
return wt.a.S(new s1(callable, oVar, gVar, z10));
}
@h("none")
@f
@d
public static <T> s<T> S1(y<T> yVar) {
if (yVar instanceof s) {
return wt.a.S((s) yVar);
}
ft.b.g(yVar, "onSubscribe is null");
return wt.a.S(new q1(yVar));
}
@h("none")
@f
@d
public static <T, R> s<R> T1(Iterable<? extends y<? 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.S(new u1(iterable, oVar));
}
@h("none")
@f
@d
public static <T1, T2, R> s<R> U1(y<? extends T1> yVar, y<? extends T2> yVar2, dt.c<? super T1, ? super T2, ? extends R> cVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
return c2(ft.a.x(cVar), yVar, yVar2);
}
@h("none")
@f
@d
public static <T1, T2, T3, R> s<R> V1(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, dt.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
return c2(ft.a.y(hVar), yVar, yVar2, yVar3);
}
@d
@h("none")
public static <T> s<T> W() {
return wt.a.S(u.f83038a);
}
@h("none")
@f
@d
public static <T1, T2, T3, T4, R> s<R> W1(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
return c2(ft.a.z(iVar), yVar, yVar2, yVar3, yVar4);
}
@h("none")
@f
@d
public static <T> s<T> X(Throwable th2) {
ft.b.g(th2, "exception is null");
return wt.a.S(new w(th2));
}
@h("none")
@f
@d
public static <T1, T2, T3, T4, T5, R> s<R> X1(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, y<? extends T5> yVar5, dt.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
ft.b.g(yVar5, "source5 is null");
return c2(ft.a.A(jVar), yVar, yVar2, yVar3, yVar4, yVar5);
}
@h("none")
@f
@d
public static <T> s<T> Y(Callable<? extends Throwable> callable) {
ft.b.g(callable, "errorSupplier is null");
return wt.a.S(new x(callable));
}
@h("none")
@f
@d
public static <T1, T2, T3, T4, T5, T6, R> s<R> Y1(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, y<? extends T5> yVar5, y<? extends T6> yVar6, dt.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
ft.b.g(yVar5, "source5 is null");
ft.b.g(yVar6, "source6 is null");
return c2(ft.a.B(kVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6);
}
@h("none")
@f
@d
public static <T1, T2, T3, T4, T5, T6, T7, R> s<R> Z1(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, y<? extends T5> yVar5, y<? extends T6> yVar6, y<? extends T7> yVar7, l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
ft.b.g(yVar5, "source5 is null");
ft.b.g(yVar6, "source6 is null");
ft.b.g(yVar7, "source7 is null");
return c2(ft.a.C(lVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6, yVar7);
}
@h("none")
@f
@d
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> s<R> a2(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, y<? extends T5> yVar5, y<? extends T6> yVar6, y<? extends T7> yVar7, y<? extends T8> yVar8, m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
ft.b.g(yVar5, "source5 is null");
ft.b.g(yVar6, "source6 is null");
ft.b.g(yVar7, "source7 is null");
ft.b.g(yVar8, "source8 is null");
return c2(ft.a.D(mVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6, yVar7, yVar8);
}
@h("none")
@f
@d
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> s<R> b2(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, y<? extends T5> yVar5, y<? extends T6> yVar6, y<? extends T7> yVar7, y<? extends T8> yVar8, y<? extends T9> yVar9, 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(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
ft.b.g(yVar5, "source5 is null");
ft.b.g(yVar6, "source6 is null");
ft.b.g(yVar7, "source7 is null");
ft.b.g(yVar8, "source8 is null");
ft.b.g(yVar9, "source9 is null");
return c2(ft.a.E(nVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6, yVar7, yVar8, yVar9);
}
@h("none")
@f
@d
public static <T> s<T> c(Iterable<? extends y<? extends T>> iterable) {
ft.b.g(iterable, "sources is null");
return wt.a.S(new kt.b(null, iterable));
}
@h("none")
@f
@d
public static <T, R> s<R> c2(o<? super Object[], ? extends R> oVar, y<? extends T>... yVarArr) {
ft.b.g(yVarArr, "sources is null");
if (yVarArr.length == 0) {
return W();
}
ft.b.g(oVar, "zipper is null");
return wt.a.S(new t1(yVarArr, oVar));
}
@d
@h("none")
public static <T> s<T> e(y<? extends T>... yVarArr) {
if (yVarArr.length == 0) {
return W();
}
if (yVarArr.length == 1) {
return S1(yVarArr[0]);
}
return wt.a.S(new kt.b(yVarArr, null));
}
@h("none")
@f
@d
public static <T> s<T> k0(dt.a aVar) {
ft.b.g(aVar, "run is null");
return wt.a.S(new i0(aVar));
}
@d
@h("none")
public static <T> k0<Boolean> k1(y<? extends T> yVar, y<? extends T> yVar2) {
return l1(yVar, yVar2, ft.b.d());
}
@h("none")
@f
@d
public static <T> s<T> l0(@f Callable<? extends T> callable) {
ft.b.g(callable, "callable is null");
return wt.a.S(new j0(callable));
}
@h("none")
@f
@d
public static <T> k0<Boolean> l1(y<? extends T> yVar, y<? extends T> yVar2, dt.d<? super T, ? super T> dVar) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(dVar, "isEqual is null");
return wt.a.U(new v(yVar, yVar2, dVar));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> m(c<? extends y<? extends T>> cVar) {
return n(cVar, 2);
}
@h("none")
@f
@d
public static <T> s<T> m0(i iVar) {
ft.b.g(iVar, "completableSource is null");
return wt.a.S(new k0(iVar));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> n(c<? extends y<? extends T>> cVar, int i10) {
ft.b.g(cVar, "sources is null");
ft.b.h(i10, "prefetch");
return wt.a.R(new z(cVar, o1.instance(), i10, st.j.IMMEDIATE));
}
@h("none")
@f
@d
public static <T> s<T> n0(Future<? extends T> future) {
ft.b.g(future, "future is null");
return wt.a.S(new l0(future, 0, null));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> o(Iterable<? extends y<? extends T>> iterable) {
ft.b.g(iterable, "sources is null");
return wt.a.R(new kt.g(iterable));
}
@h("none")
@f
@d
public static <T> s<T> o0(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.S(new l0(future, j10, timeUnit));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> p(y<? extends T> yVar, y<? extends T> yVar2) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
return s(yVar, yVar2);
}
@h("none")
@f
@d
public static <T> s<T> p0(Runnable runnable) {
ft.b.g(runnable, "run is null");
return wt.a.S(new m0(runnable));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> q(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
return s(yVar, yVar2, yVar3);
}
@h("none")
@f
@d
public static <T> s<T> q0(q0<T> q0Var) {
ft.b.g(q0Var, "singleSource is null");
return wt.a.S(new n0(q0Var));
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> r(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3, y<? extends T> yVar4) {
ft.b.g(yVar, "source1 is null");
ft.b.g(yVar2, "source2 is null");
ft.b.g(yVar3, "source3 is null");
ft.b.g(yVar4, "source4 is null");
return s(yVar, yVar2, yVar3, yVar4);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> s(y<? extends T>... yVarArr) {
ft.b.g(yVarArr, "sources is null");
if (yVarArr.length == 0) {
return l.k2();
}
if (yVarArr.length == 1) {
return wt.a.R(new m1(yVarArr[0]));
}
return wt.a.R(new e(yVarArr));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> t(y<? extends T>... yVarArr) {
if (yVarArr.length == 0) {
return l.k2();
}
if (yVarArr.length == 1) {
return wt.a.R(new m1(yVarArr[0]));
}
return wt.a.R(new kt.f(yVarArr));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> u(y<? extends T>... yVarArr) {
return l.R2(yVarArr).a1(o1.instance());
}
@h("none")
@f
@d
public static <T> s<T> u0(T t10) {
ft.b.g(t10, "item is null");
return wt.a.S(new t0(t10));
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> v(c<? extends y<? extends T>> cVar) {
return l.Y2(cVar).Y0(o1.instance());
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> w(Iterable<? extends y<? extends T>> iterable) {
ft.b.g(iterable, "sources is null");
return l.X2(iterable).Y0(o1.instance());
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> x(c<? extends y<? extends T>> cVar) {
return l.Y2(cVar).a1(o1.instance());
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> y(Iterable<? extends y<? extends T>> iterable) {
return l.X2(iterable).a1(o1.instance());
}
@h("none")
@d
@b(a.FULL)
public static <T> l<T> y0(c<? extends y<? extends T>> cVar) {
return z0(cVar, Integer.MAX_VALUE);
}
@h("none")
@f
@d
@b(a.FULL)
public static <T> l<T> z0(c<? extends y<? extends T>> cVar, int i10) {
ft.b.g(cVar, "source is null");
ft.b.h(i10, "maxConcurrency");
return wt.a.R(new d1(cVar, o1.instance(), false, i10, 1));
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> A(y<? extends T> yVar) {
ft.b.g(yVar, "other is null");
return p(this, yVar);
}
@h(h.Q)
@f
@d
public final s<T> A1(long j10, TimeUnit timeUnit, y<? extends T> yVar) {
ft.b.g(yVar, "fallback is null");
return C1(j10, timeUnit, yt.b.a(), yVar);
}
@h("none")
@f
@d
public final k0<Boolean> B(Object obj) {
ft.b.g(obj, "item is null");
return wt.a.U(new kt.h(this, obj));
}
@d
@h(h.P)
public final s<T> B1(long j10, TimeUnit timeUnit, j0 j0Var) {
return F1(I1(j10, timeUnit, j0Var));
}
@d
@h("none")
public final k0<Long> C() {
return wt.a.U(new kt.i(this));
}
@h(h.P)
@f
@d
public final s<T> C1(long j10, TimeUnit timeUnit, j0 j0Var, y<? extends T> yVar) {
ft.b.g(yVar, "fallback is null");
return G1(I1(j10, timeUnit, j0Var), yVar);
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <U> s<T> D1(c<U> cVar) {
ft.b.g(cVar, "timeoutIndicator is null");
return wt.a.S(new k1(this, cVar, null));
}
@h("none")
@f
@d
public final s<T> E(T t10) {
ft.b.g(t10, "defaultItem is null");
return t1(u0(t10));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <U> s<T> E1(c<U> cVar, y<? extends T> yVar) {
ft.b.g(cVar, "timeoutIndicator is null");
ft.b.g(yVar, "fallback is null");
return wt.a.S(new k1(this, cVar, yVar));
}
@h("none")
@f
@d
public final <U> s<T> F1(y<U> yVar) {
ft.b.g(yVar, "timeoutIndicator is null");
return wt.a.S(new j1(this, yVar, null));
}
@d
@h(h.Q)
public final s<T> G(long j10, TimeUnit timeUnit) {
return H(j10, timeUnit, yt.b.a());
}
@h("none")
@f
@d
public final <U> s<T> G1(y<U> yVar, y<? extends T> yVar2) {
ft.b.g(yVar, "timeoutIndicator is null");
ft.b.g(yVar2, "fallback is null");
return wt.a.S(new j1(this, yVar, yVar2));
}
@h(h.P)
@f
@d
public final s<T> H(long j10, TimeUnit timeUnit, j0 j0Var) {
ft.b.g(timeUnit, "unit is null");
ft.b.g(j0Var, "scheduler is null");
return wt.a.S(new kt.l(this, Math.max(0L, j10), timeUnit, j0Var));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <U, V> s<T> I(c<U> cVar) {
ft.b.g(cVar, "delayIndicator is null");
return wt.a.S(new kt.m(this, cVar));
}
@d
@h(h.Q)
public final s<T> J(long j10, TimeUnit timeUnit) {
return K(j10, timeUnit, yt.b.a());
}
@h("none")
@f
@d
public final <R> R J1(o<? super s<T>, R> oVar) {
try {
return (R) ((o) ft.b.g(oVar, "convert is null")).apply(this);
} catch (Throwable th2) {
bt.b.b(th2);
throw st.k.f(th2);
}
}
@d
@h(h.P)
public final s<T> K(long j10, TimeUnit timeUnit, j0 j0Var) {
return L(l.v7(j10, timeUnit, j0Var));
}
@h("none")
@d
@b(a.FULL)
public final l<T> K1() {
if (this instanceof gt.b) {
return ((gt.b) this).d();
}
return wt.a.R(new m1(this));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <U> s<T> L(c<U> cVar) {
ft.b.g(cVar, "subscriptionIndicator is null");
return wt.a.S(new kt.n(this, cVar));
}
@d
@h("none")
public final b0<T> L1() {
if (this instanceof gt.d) {
return ((gt.d) this).a();
}
return wt.a.T(new n1(this));
}
@h("none")
@f
@d
public final s<T> M(g<? super T> gVar) {
ft.b.g(gVar, "onAfterSuccess is null");
return wt.a.S(new q(this, gVar));
}
@d
@h("none")
public final k0<T> M1() {
return wt.a.U(new p1(this, null));
}
@h("none")
@f
@d
public final s<T> N(dt.a aVar) {
g h10 = ft.a.h();
g h11 = ft.a.h();
g h12 = ft.a.h();
dt.a aVar2 = ft.a.f64184c;
return wt.a.S(new kt.d1(this, h10, h11, h12, aVar2, (dt.a) ft.b.g(aVar, "onAfterTerminate is null"), aVar2));
}
@h("none")
@f
@d
@b(a.FULL)
public final l<T> N0(y<? extends T> yVar) {
ft.b.g(yVar, "other is null");
return B0(this, yVar);
}
@h("none")
@f
@d
public final k0<T> N1(T t10) {
ft.b.g(t10, "defaultValue is null");
return wt.a.U(new p1(this, t10));
}
@h("none")
@f
@d
public final s<T> O(dt.a aVar) {
ft.b.g(aVar, "onFinally is null");
return wt.a.S(new r(this, aVar));
}
@h("none")
@f
@d
public final s<T> P(dt.a aVar) {
dt.a aVar2 = ft.a.f64184c;
return wt.a.S(new kt.d1(this, ft.a.h(), ft.a.h(), ft.a.h(), (dt.a) ft.b.g(aVar, "onComplete is null"), aVar2, aVar2));
}
@h(h.P)
@f
@d
public final s<T> P0(j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return wt.a.S(new z0(this, j0Var));
}
@h(h.P)
@f
@d
public final s<T> P1(j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return wt.a.S(new r1(this, j0Var));
}
@h("none")
@f
@d
public final s<T> Q(dt.a aVar) {
g h10 = ft.a.h();
g h11 = ft.a.h();
g h12 = ft.a.h();
dt.a aVar2 = ft.a.f64184c;
return wt.a.S(new kt.d1(this, h10, h11, h12, aVar2, aVar2, (dt.a) ft.b.g(aVar, "onDispose is null")));
}
@h("none")
@f
@d
public final <U> s<U> Q0(Class<U> cls) {
ft.b.g(cls, "clazz is null");
return Z(ft.a.l(cls)).k(cls);
}
@h("none")
@f
@d
public final s<T> R(g<? super Throwable> gVar) {
dt.a aVar = ft.a.f64184c;
return wt.a.S(new kt.d1(this, ft.a.h(), ft.a.h(), (g) ft.b.g(gVar, "onError is null"), aVar, aVar, aVar));
}
@d
@h("none")
public final s<T> R0() {
return S0(ft.a.c());
}
@d
@h("none")
public final s<T> S(dt.b<? super T, ? super Throwable> bVar) {
ft.b.g(bVar, "onEvent is null");
return wt.a.S(new kt.s(this, bVar));
}
@h("none")
@f
@d
public final s<T> S0(dt.r<? super Throwable> rVar) {
ft.b.g(rVar, "predicate is null");
return wt.a.S(new a1(this, rVar));
}
@h("none")
@f
@d
public final s<T> T(g<? super at.c> gVar) {
g h10 = ft.a.h();
g h11 = ft.a.h();
dt.a aVar = ft.a.f64184c;
return wt.a.S(new kt.d1(this, (g) ft.b.g(gVar, "onSubscribe is null"), h10, h11, aVar, aVar, aVar));
}
@h("none")
@f
@d
public final s<T> T0(o<? super Throwable, ? extends y<? extends T>> oVar) {
ft.b.g(oVar, "resumeFunction is null");
return wt.a.S(new b1(this, oVar, true));
}
@h("none")
@f
@d
public final s<T> U(g<? super T> gVar) {
g h10 = ft.a.h();
dt.a aVar = ft.a.f64184c;
return wt.a.S(new kt.d1(this, ft.a.h(), (g) ft.b.g(gVar, "onSuccess is null"), h10, aVar, aVar, aVar));
}
@h("none")
@f
@d
public final s<T> U0(y<? extends T> yVar) {
ft.b.g(yVar, "next is null");
return T0(ft.a.n(yVar));
}
@h("none")
@f
@zs.e
@d
public final s<T> V(dt.a aVar) {
ft.b.g(aVar, "onTerminate is null");
return wt.a.S(new t(this, aVar));
}
@h("none")
@f
@d
public final s<T> V0(o<? super Throwable, ? extends T> oVar) {
ft.b.g(oVar, "valueSupplier is null");
return wt.a.S(new c1(this, oVar));
}
@h("none")
@f
@d
public final s<T> W0(T t10) {
ft.b.g(t10, "item is null");
return V0(ft.a.n(t10));
}
@h("none")
@f
@d
public final s<T> X0(y<? extends T> yVar) {
ft.b.g(yVar, "next is null");
return wt.a.S(new b1(this, ft.a.n(yVar), false));
}
@d
@h("none")
public final s<T> Y0() {
return wt.a.S(new p(this));
}
@h("none")
@f
@d
public final s<T> Z(dt.r<? super T> rVar) {
ft.b.g(rVar, "predicate is null");
return wt.a.S(new y(this, rVar));
}
@h("none")
@d
@b(a.FULL)
public final l<T> Z0() {
return a1(Long.MAX_VALUE);
}
@h("none")
@f
@d
public final <R> s<R> a0(o<? super T, ? extends y<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.S(new h0(this, oVar));
}
@h("none")
@d
@b(a.FULL)
public final l<T> a1(long j10) {
return K1().U4(j10);
}
@Override // vs.y
@h("none")
public final void b(v<? super T> vVar) {
ft.b.g(vVar, "observer is null");
v<? super T> f02 = wt.a.f0(this, vVar);
ft.b.g(f02, "The RxJavaPlugins.onSubscribe hook returned a null MaybeObserver. Please check the handler provided to RxJavaPlugins.setOnMaybeSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
try {
q1(f02);
} catch (NullPointerException e10) {
throw e10;
} catch (Throwable th2) {
bt.b.b(th2);
NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
nullPointerException.initCause(th2);
throw nullPointerException;
}
}
@h("none")
@f
@d
public final <U, R> s<R> b0(o<? super T, ? extends y<? extends U>> oVar, dt.c<? super T, ? super U, ? extends R> cVar) {
ft.b.g(oVar, "mapper is null");
ft.b.g(cVar, "resultSelector is null");
return wt.a.S(new a0(this, oVar, cVar));
}
@h("none")
@d
@b(a.FULL)
public final l<T> b1(dt.e eVar) {
return K1().V4(eVar);
}
@h("none")
@f
@d
public final <R> s<R> c0(o<? super T, ? extends y<? extends R>> oVar, o<? super Throwable, ? extends y<? extends R>> oVar2, Callable<? extends y<? extends R>> callable) {
ft.b.g(oVar, "onSuccessMapper is null");
ft.b.g(oVar2, "onErrorMapper is null");
ft.b.g(callable, "onCompleteSupplier is null");
return wt.a.S(new e0(this, oVar, oVar2, callable));
}
@h("none")
@d
@b(a.FULL)
public final l<T> c1(o<? super l<Object>, ? extends c<?>> oVar) {
return K1().W4(oVar);
}
@h("none")
@f
@d
public final c d0(o<? super T, ? extends i> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.Q(new b0(this, oVar));
}
@d
@h("none")
public final s<T> d1() {
return f1(Long.MAX_VALUE, ft.a.c());
}
@h("none")
@f
@d
public final <U, R> s<R> d2(y<? extends U> yVar, dt.c<? super T, ? super U, ? extends R> cVar) {
ft.b.g(yVar, "other is null");
return U1(this, yVar, cVar);
}
@h("none")
@f
@d
public final <R> b0<R> e0(o<? super T, ? extends g0<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.T(new lt.j(this, oVar));
}
@d
@h("none")
public final s<T> e1(long j10) {
return f1(j10, ft.a.c());
}
@h("none")
@f
@d
public final s<T> f(y<? extends T> yVar) {
ft.b.g(yVar, "other is null");
return e(this, yVar);
}
@h("none")
@f
@d
@b(a.FULL)
public final <R> l<R> f0(o<? super T, ? extends c<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.R(new lt.k(this, oVar));
}
@d
@h("none")
public final s<T> f1(long j10, dt.r<? super Throwable> rVar) {
return K1().p5(j10, rVar).L5();
}
@d
@h("none")
public final <R> R g(@f t<T, ? extends R> tVar) {
return (R) ((t) ft.b.g(tVar, "converter is null")).a(this);
}
@h("none")
@f
@d
public final <R> k0<R> g0(o<? super T, ? extends q0<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.U(new f0(this, oVar));
}
@d
@h("none")
public final s<T> g1(dt.d<? super Integer, ? super Throwable> dVar) {
return K1().q5(dVar).L5();
}
@d
@h("none")
public final T h() {
ht.h hVar = new ht.h();
b(hVar);
return (T) hVar.b();
}
@h("none")
@f
@d
public final <R> s<R> h0(o<? super T, ? extends q0<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.S(new g0(this, oVar));
}
@d
@h("none")
public final s<T> h1(dt.r<? super Throwable> rVar) {
return f1(Long.MAX_VALUE, rVar);
}
@d
@h("none")
public final T i(T t10) {
ft.b.g(t10, "defaultValue is null");
ht.h hVar = new ht.h();
b(hVar);
return (T) hVar.c(t10);
}
@h("none")
@f
@d
@b(a.FULL)
public final <U> l<U> i0(o<? super T, ? extends Iterable<? extends U>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.R(new c0(this, oVar));
}
@h("none")
@f
@d
public final s<T> i1(dt.e eVar) {
ft.b.g(eVar, "stop is null");
return f1(Long.MAX_VALUE, ft.a.v(eVar));
}
@d
@h("none")
public final s<T> j() {
return wt.a.S(new kt.c(this));
}
@h("none")
@f
@d
public final <U> b0<U> j0(o<? super T, ? extends Iterable<? extends U>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.T(new d0(this, oVar));
}
@d
@h("none")
public final s<T> j1(o<? super l<Throwable>, ? extends c<?>> oVar) {
return K1().t5(oVar).L5();
}
/* JADX DEBUG: Type inference failed for r2v2. Raw type applied. Possible types: vs.s<R>, vs.s<U> */
@h("none")
@f
@d
public final <U> s<U> k(Class<? extends U> cls) {
ft.b.g(cls, "clazz is null");
return (s<R>) w0(ft.a.e(cls));
}
@d
@h("none")
public final <R> s<R> l(z<? super T, ? extends R> zVar) {
return S1(((z) ft.b.g(zVar, "transformer is null")).a(this));
}
@h("none")
public final at.c m1() {
return p1(ft.a.h(), ft.a.f64187f, ft.a.f64184c);
}
@d
@h("none")
public final at.c n1(g<? super T> gVar) {
return p1(gVar, ft.a.f64187f, ft.a.f64184c);
}
@d
@h("none")
public final at.c o1(g<? super T> gVar, g<? super Throwable> gVar2) {
return p1(gVar, gVar2, ft.a.f64184c);
}
@h("none")
@f
@d
public final at.c p1(g<? super T> gVar, g<? super Throwable> gVar2, dt.a aVar) {
ft.b.g(gVar, "onSuccess is null");
ft.b.g(gVar2, "onError is null");
ft.b.g(aVar, "onComplete is null");
return (at.c) s1(new kt.d(gVar, gVar2, aVar));
}
public abstract void q1(v<? super T> vVar);
@d
@h("none")
public final s<T> r0() {
return wt.a.S(new o0(this));
}
@h(h.P)
@f
@d
public final s<T> r1(j0 j0Var) {
ft.b.g(j0Var, "scheduler is null");
return wt.a.S(new e1(this, j0Var));
}
@d
@h("none")
public final c s0() {
return wt.a.Q(new q0(this));
}
@d
@h("none")
public final <E extends v<? super T>> E s1(E e10) {
b(e10);
return e10;
}
@d
@h("none")
public final k0<Boolean> t0() {
return wt.a.U(new s0(this));
}
@h("none")
@f
@d
public final s<T> t1(y<? extends T> yVar) {
ft.b.g(yVar, "other is null");
return wt.a.S(new f1(this, yVar));
}
@h("none")
@f
@d
public final k0<T> u1(q0<? extends T> q0Var) {
ft.b.g(q0Var, "other is null");
return wt.a.U(new g1(this, q0Var));
}
@h("none")
@f
@d
public final <R> s<R> v0(x<? extends R, ? super T> xVar) {
ft.b.g(xVar, "lift is null");
return wt.a.S(new u0(this, xVar));
}
@h("none")
@f
@d
@b(a.UNBOUNDED_IN)
public final <U> s<T> v1(c<U> cVar) {
ft.b.g(cVar, "other is null");
return wt.a.S(new i1(this, cVar));
}
@h("none")
@f
@d
public final <R> s<R> w0(o<? super T, ? extends R> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.S(new v0(this, oVar));
}
@h("none")
@f
@d
public final <U> s<T> w1(y<U> yVar) {
ft.b.g(yVar, "other is null");
return wt.a.S(new h1(this, yVar));
}
@h("none")
@zs.e
@d
public final k0<a0<T>> x0() {
return wt.a.U(new w0(this));
}
@d
@h("none")
public final ut.n<T> x1() {
ut.n<T> nVar = new ut.n<>();
b(nVar);
return nVar;
}
@d
@h("none")
public final ut.n<T> y1(boolean z10) {
ut.n<T> nVar = new ut.n<>();
if (z10) {
nVar.cancel();
}
b(nVar);
return nVar;
}
@h("none")
@f
@d
public final <R> s<R> z(o<? super T, ? extends y<? extends R>> oVar) {
ft.b.g(oVar, "mapper is null");
return wt.a.S(new h0(this, oVar));
}
@d
@h(h.Q)
public final s<T> z1(long j10, TimeUnit timeUnit) {
return B1(j10, timeUnit, yt.b.a());
}
}