米游社.apk(点击下载) / c.java

package vs;

import dt.g;
import ft.b;
import ht.j;
import it.a0;
import it.b0;
import it.c0;
import it.d0;
import it.e;
import it.e0;
import it.f0;
import it.g0;
import it.h0;
import it.i;
import it.i0;
import it.j0;
import it.k0;
import it.l;
import it.l0;
import it.m;
import it.m0;
import it.n;
import it.n0;
import it.o;
import it.o0;
import it.p;
import it.p0;
import it.q;
import it.r;
import it.r0;
import it.s;
import it.t;
import it.u;
import it.v;
import it.w;
import it.x;
import it.y;
import it.z;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import kt.q0;
import st.k;
import wt.a;
import zs.d;
import zs.f;
import zs.h;

/* compiled from: Completable */
public abstract class c implements i {
    @h("none")
    @f
    @d
    public static c A(Callable<? extends i> callable) {
        b.g(callable, "completableSupplier");
        return a.Q(new it.h(callable));
    }

    @d
    @h("none")
    @f
    public static c P(Throwable th2) {
        b.g(th2, "error is null");
        return a.Q(new o(th2));
    }

    @h("none")
    @f
    @d
    public static c Q(Callable<? extends Throwable> callable) {
        b.g(callable, "errorSupplier is null");
        return a.Q(new p(callable));
    }

    @d
    @h("none")
    @f
    public static c R(dt.a aVar) {
        b.g(aVar, "run is null");
        return a.Q(new q(aVar));
    }

    @h("none")
    @f
    @d
    public static c S(Callable<?> callable) {
        b.g(callable, "callable is null");
        return a.Q(new r(callable));
    }

    @h("none")
    @f
    @d
    public static c T(Future<?> future) {
        b.g(future, "future is null");
        return R(ft.a.j(future));
    }

    @d
    @h(h.Q)
    public static c T0(long j10, TimeUnit timeUnit) {
        return U0(j10, timeUnit, yt.b.a());
    }

    @h("none")
    @f
    @d
    public static <T> c U(y<T> yVar) {
        b.g(yVar, "maybe is null");
        return a.Q(new q0(yVar));
    }

    @d
    @h(h.P)
    @f
    public static c U0(long j10, TimeUnit timeUnit, j0 j0Var) {
        b.g(timeUnit, "unit is null");
        b.g(j0Var, "scheduler is null");
        return a.Q(new n0(j10, timeUnit, j0Var));
    }

    @h("none")
    @f
    @d
    public static <T> c V(g0<T> g0Var) {
        b.g(g0Var, "observable is null");
        return a.Q(new s(g0Var));
    }

    @h("none")
    @f
    @d
    @zs.b(zs.a.UNBOUNDED_IN)
    public static <T> c W(c00.c<T> cVar) {
        b.g(cVar, "publisher is null");
        return a.Q(new t(cVar));
    }

    @d
    @h("none")
    @f
    public static c X(Runnable runnable) {
        b.g(runnable, "run is null");
        return a.Q(new u(runnable));
    }

    @h("none")
    @f
    @d
    public static <T> c Y(q0<T> q0Var) {
        b.g(q0Var, "single is null");
        return a.Q(new v(q0Var));
    }

    public static NullPointerException Y0(Throwable th2) {
        NullPointerException nullPointerException = new NullPointerException("Actually not, but can't pass out an exception otherwise...");
        nullPointerException.initCause(th2);
        return nullPointerException;
    }

    @h("none")
    @d
    @zs.b(zs.a.UNBOUNDED_IN)
    public static c c0(c00.c<? extends i> cVar) {
        return f0(cVar, Integer.MAX_VALUE, false);
    }

    @d
    @h("none")
    @f
    public static c c1(i iVar) {
        b.g(iVar, "source is null");
        if (!(iVar instanceof c)) {
            return a.Q(new w(iVar));
        }
        throw new IllegalArgumentException("Use of unsafeCreate(Completable)!");
    }

    @h("none")
    @d
    @zs.b(zs.a.FULL)
    public static c d0(c00.c<? extends i> cVar, int i10) {
        return f0(cVar, i10, false);
    }

    @h("none")
    @f
    @d
    public static c e(Iterable<? extends i> iterable) {
        b.g(iterable, "sources is null");
        return a.Q(new it.a(null, iterable));
    }

    @h("none")
    @f
    @d
    public static c e0(Iterable<? extends i> iterable) {
        b.g(iterable, "sources is null");
        return a.Q(new e0(iterable));
    }

    @d
    @h("none")
    public static <R> c e1(Callable<R> callable, dt.o<? super R, ? extends i> oVar, g<? super R> gVar) {
        return f1(callable, oVar, gVar, true);
    }

    @d
    @h("none")
    @f
    public static c f(i... iVarArr) {
        b.g(iVarArr, "sources is null");
        if (iVarArr.length == 0) {
            return s();
        }
        if (iVarArr.length == 1) {
            return g1(iVarArr[0]);
        }
        return a.Q(new it.a(iVarArr, null));
    }

    @h("none")
    @f
    @d
    @zs.b(zs.a.FULL)
    public static c f0(c00.c<? extends i> cVar, int i10, boolean z10) {
        b.g(cVar, "sources is null");
        b.h(i10, "maxConcurrency");
        return a.Q(new a0(cVar, i10, z10));
    }

    @h("none")
    @f
    @d
    public static <R> c f1(Callable<R> callable, dt.o<? super R, ? extends i> oVar, g<? super R> gVar, boolean z10) {
        b.g(callable, "resourceSupplier is null");
        b.g(oVar, "completableFunction is null");
        b.g(gVar, "disposer is null");
        return a.Q(new r0(callable, oVar, gVar, z10));
    }

    @d
    @h("none")
    @f
    public static c g0(i... iVarArr) {
        b.g(iVarArr, "sources is null");
        if (iVarArr.length == 0) {
            return s();
        }
        if (iVarArr.length == 1) {
            return g1(iVarArr[0]);
        }
        return a.Q(new b0(iVarArr));
    }

    @d
    @h("none")
    @f
    public static c g1(i iVar) {
        b.g(iVar, "source is null");
        if (iVar instanceof c) {
            return a.Q((c) iVar);
        }
        return a.Q(new w(iVar));
    }

    @d
    @h("none")
    @f
    public static c h0(i... iVarArr) {
        b.g(iVarArr, "sources is null");
        return a.Q(new c0(iVarArr));
    }

    @h("none")
    @d
    @zs.b(zs.a.UNBOUNDED_IN)
    public static c i0(c00.c<? extends i> cVar) {
        return f0(cVar, Integer.MAX_VALUE, true);
    }

    @h("none")
    @d
    @zs.b(zs.a.FULL)
    public static c j0(c00.c<? extends i> cVar, int i10) {
        return f0(cVar, i10, true);
    }

    @h("none")
    @f
    @d
    public static c k0(Iterable<? extends i> iterable) {
        b.g(iterable, "sources is null");
        return a.Q(new d0(iterable));
    }

    @d
    @h("none")
    public static c m0() {
        return a.Q(f0.f71705a);
    }

    @d
    @h("none")
    @f
    public static c s() {
        return a.Q(n.f71794a);
    }

    @h("none")
    @d
    @zs.b(zs.a.FULL)
    public static c u(c00.c<? extends i> cVar) {
        return v(cVar, 2);
    }

    @h("none")
    @f
    @d
    @zs.b(zs.a.FULL)
    public static c v(c00.c<? extends i> cVar, int i10) {
        b.g(cVar, "sources is null");
        b.h(i10, "prefetch");
        return a.Q(new it.d(cVar, i10));
    }

    @h("none")
    @f
    @d
    public static c w(Iterable<? extends i> iterable) {
        b.g(iterable, "sources is null");
        return a.Q(new it.f(iterable));
    }

    @d
    @h("none")
    @f
    public static c x(i... iVarArr) {
        b.g(iVarArr, "sources is null");
        if (iVarArr.length == 0) {
            return s();
        }
        if (iVarArr.length == 1) {
            return g1(iVarArr[0]);
        }
        return a.Q(new e(iVarArr));
    }

    @d
    @h("none")
    @f
    public static c z(g gVar) {
        b.g(gVar, "source is null");
        return a.Q(new it.g(gVar));
    }

    @d
    @h("none")
    public final c A0(dt.r<? super Throwable> rVar) {
        return W(W0().r5(rVar));
    }

    @d
    @h(h.Q)
    public final c B(long j10, TimeUnit timeUnit) {
        return D(j10, timeUnit, yt.b.a(), false);
    }

    @d
    @h("none")
    public final c B0(dt.o<? super l<Throwable>, ? extends c00.c<?>> oVar) {
        return W(W0().t5(oVar));
    }

    @d
    @h(h.P)
    public final c C(long j10, TimeUnit timeUnit, j0 j0Var) {
        return D(j10, timeUnit, j0Var, false);
    }

    @d
    @h("none")
    @f
    public final c C0(i iVar) {
        b.g(iVar, "other is null");
        return x(iVar, this);
    }

    @d
    @h(h.P)
    @f
    public final c D(long j10, TimeUnit timeUnit, j0 j0Var, boolean z10) {
        b.g(timeUnit, "unit is null");
        b.g(j0Var, "scheduler is null");
        return a.Q(new i(this, j10, timeUnit, j0Var, z10));
    }

    @h("none")
    @f
    @d
    @zs.b(zs.a.FULL)
    public final <T> l<T> D0(c00.c<T> cVar) {
        b.g(cVar, "other is null");
        return W0().a6(cVar);
    }

    @zs.e
    @d
    @h(h.Q)
    public final c E(long j10, TimeUnit timeUnit) {
        return F(j10, timeUnit, yt.b.a());
    }

    @h("none")
    @f
    @d
    public final <T> b0<T> E0(b0<T> b0Var) {
        b.g(b0Var, "other is null");
        return b0Var.m1(Z0());
    }

    @zs.e
    @d
    @h(h.P)
    public final c F(long j10, TimeUnit timeUnit, j0 j0Var) {
        return U0(j10, timeUnit, j0Var).h(this);
    }

    @h("none")
    public final at.c F0() {
        ht.o oVar = new ht.o();
        b(oVar);
        return oVar;
    }

    @d
    @h("none")
    public final c G(dt.a aVar) {
        g<? super at.c> h10 = ft.a.h();
        g<? super Throwable> h11 = ft.a.h();
        dt.a aVar2 = ft.a.f64184c;
        return M(h10, h11, aVar2, aVar2, aVar, aVar2);
    }

    @d
    @h("none")
    @f
    public final at.c G0(dt.a aVar) {
        b.g(aVar, "onComplete is null");
        j jVar = new j(aVar);
        b(jVar);
        return jVar;
    }

    @d
    @h("none")
    @f
    public final c H(dt.a aVar) {
        b.g(aVar, "onFinally is null");
        return a.Q(new l(this, aVar));
    }

    @h("none")
    @f
    @d
    public final at.c H0(dt.a aVar, g<? super Throwable> gVar) {
        b.g(gVar, "onError is null");
        b.g(aVar, "onComplete is null");
        j jVar = new j(gVar, aVar);
        b(jVar);
        return jVar;
    }

    @d
    @h("none")
    public final c I(dt.a aVar) {
        g<? super at.c> h10 = ft.a.h();
        g<? super Throwable> h11 = ft.a.h();
        dt.a aVar2 = ft.a.f64184c;
        return M(h10, h11, aVar, aVar2, aVar2, aVar2);
    }

    public abstract void I0(f fVar);

    @d
    @h("none")
    public final c J(dt.a aVar) {
        g<? super at.c> h10 = ft.a.h();
        g<? super Throwable> h11 = ft.a.h();
        dt.a aVar2 = ft.a.f64184c;
        return M(h10, h11, aVar2, aVar2, aVar2, aVar);
    }

    @d
    @h(h.P)
    @f
    public final c J0(j0 j0Var) {
        b.g(j0Var, "scheduler is null");
        return a.Q(new k0(this, j0Var));
    }

    @d
    @h("none")
    public final c K(g<? super Throwable> gVar) {
        g<? super at.c> h10 = ft.a.h();
        dt.a aVar = ft.a.f64184c;
        return M(h10, gVar, aVar, aVar, aVar, aVar);
    }

    @d
    @h("none")
    public final <E extends f> E K0(E e10) {
        b(e10);
        return e10;
    }

    @h("none")
    @f
    @d
    public final c L(g<? super Throwable> gVar) {
        b.g(gVar, "onEvent is null");
        return a.Q(new m(this, gVar));
    }

    @d
    @h("none")
    @f
    public final c L0(i iVar) {
        b.g(iVar, "other is null");
        return a.Q(new l0(this, iVar));
    }

    @h("none")
    @f
    @d
    public final c M(g<? super at.c> gVar, g<? super Throwable> gVar2, dt.a aVar, dt.a aVar2, dt.a aVar3, dt.a aVar4) {
        b.g(gVar, "onSubscribe is null");
        b.g(gVar2, "onError is null");
        b.g(aVar, "onComplete is null");
        b.g(aVar2, "onTerminate is null");
        b.g(aVar3, "onAfterTerminate is null");
        b.g(aVar4, "onDispose is null");
        return a.Q(new i0(this, gVar, gVar2, aVar, aVar2, aVar3, aVar4));
    }

    @d
    @h("none")
    public final ut.n<Void> M0() {
        ut.n<Void> nVar = new ut.n<>();
        b(nVar);
        return nVar;
    }

    @d
    @h("none")
    public final c N(g<? super at.c> gVar) {
        g<? super Throwable> h10 = ft.a.h();
        dt.a aVar = ft.a.f64184c;
        return M(gVar, h10, aVar, aVar, aVar, aVar);
    }

    @d
    @h("none")
    public final ut.n<Void> N0(boolean z10) {
        ut.n<Void> nVar = new ut.n<>();
        if (z10) {
            nVar.cancel();
        }
        b(nVar);
        return nVar;
    }

    @d
    @h("none")
    public final c O(dt.a aVar) {
        g<? super at.c> h10 = ft.a.h();
        g<? super Throwable> h11 = ft.a.h();
        dt.a aVar2 = ft.a.f64184c;
        return M(h10, h11, aVar2, aVar, aVar2, aVar2);
    }

    @d
    @h(h.Q)
    public final c O0(long j10, TimeUnit timeUnit) {
        return S0(j10, timeUnit, yt.b.a(), null);
    }

    @d
    @h(h.Q)
    @f
    public final c P0(long j10, TimeUnit timeUnit, i iVar) {
        b.g(iVar, "other is null");
        return S0(j10, timeUnit, yt.b.a(), iVar);
    }

    @d
    @h(h.P)
    public final c Q0(long j10, TimeUnit timeUnit, j0 j0Var) {
        return S0(j10, timeUnit, j0Var, null);
    }

    @d
    @h(h.P)
    @f
    public final c R0(long j10, TimeUnit timeUnit, j0 j0Var, i iVar) {
        b.g(iVar, "other is null");
        return S0(j10, timeUnit, j0Var, iVar);
    }

    @d
    @h(h.P)
    @f
    public final c S0(long j10, TimeUnit timeUnit, j0 j0Var, i iVar) {
        b.g(timeUnit, "unit is null");
        b.g(j0Var, "scheduler is null");
        return a.Q(new m0(this, j10, timeUnit, j0Var, iVar));
    }

    @d
    @h("none")
    public final <U> U V0(dt.o<? super c, U> oVar) {
        try {
            return (U) ((dt.o) b.g(oVar, "converter is null")).apply(this);
        } catch (Throwable th2) {
            bt.b.b(th2);
            throw k.f(th2);
        }
    }

    @h("none")
    @d
    @zs.b(zs.a.FULL)
    public final <T> l<T> W0() {
        if (this instanceof gt.b) {
            return ((gt.b) this).d();
        }
        return a.R(new o0(this));
    }

    @d
    @h("none")
    public final <T> s<T> X0() {
        if (this instanceof gt.c) {
            return ((gt.c) this).c();
        }
        return a.S(new kt.k0(this));
    }

    @d
    @h("none")
    public final c Z() {
        return a.Q(new x(this));
    }

    @d
    @h("none")
    public final <T> b0<T> Z0() {
        if (this instanceof gt.d) {
            return ((gt.d) this).a();
        }
        return a.T(new p0(this));
    }

    @d
    @h("none")
    @f
    public final c a0(h hVar) {
        b.g(hVar, "onLift is null");
        return a.Q(new y(this, hVar));
    }

    @h("none")
    @f
    @d
    public final <T> k0<T> a1(Callable<? extends T> callable) {
        b.g(callable, "completionValueSupplier is null");
        return a.U(new it.q0(this, callable, null));
    }

    @Override // vs.i
    @h("none")
    public final void b(f fVar) {
        b.g(fVar, "observer is null");
        try {
            f e02 = a.e0(this, fVar);
            b.g(e02, "The RxJavaPlugins.onSubscribe hook returned a null CompletableObserver. Please check the handler provided to RxJavaPlugins.setOnCompletableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
            I0(e02);
        } catch (NullPointerException e10) {
            throw e10;
        } catch (Throwable th2) {
            bt.b.b(th2);
            a.Y(th2);
            throw Y0(th2);
        }
    }

    @h("none")
    @zs.e
    @d
    public final <T> k0<a0<T>> b0() {
        return a.U(new z(this));
    }

    @h("none")
    @f
    @d
    public final <T> k0<T> b1(T t10) {
        b.g(t10, "completionValue is null");
        return a.U(new it.q0(this, null, t10));
    }

    @d
    @h(h.P)
    @f
    public final c d1(j0 j0Var) {
        b.g(j0Var, "scheduler is null");
        return a.Q(new it.k(this, j0Var));
    }

    @d
    @h("none")
    @f
    public final c g(i iVar) {
        b.g(iVar, "other is null");
        return f(this, iVar);
    }

    @d
    @h("none")
    public final c h(i iVar) {
        b.g(iVar, "next is null");
        return a.Q(new it.b(this, iVar));
    }

    @h("none")
    @f
    @d
    @zs.b(zs.a.FULL)
    public final <T> l<T> i(c00.c<T> cVar) {
        b.g(cVar, "next is null");
        return a.R(new lt.b(this, cVar));
    }

    @h("none")
    @f
    @d
    public final <T> s<T> j(y<T> yVar) {
        b.g(yVar, "next is null");
        return a.S(new kt.o(yVar, this));
    }

    @h("none")
    @f
    @d
    public final <T> b0<T> k(g0<T> g0Var) {
        b.g(g0Var, "next is null");
        return a.T(new lt.a(this, g0Var));
    }

    @h("none")
    @f
    @d
    public final <T> k0<T> l(q0<T> q0Var) {
        b.g(q0Var, "next is null");
        return a.U(new ot.g(q0Var, this));
    }

    @d
    @h("none")
    @f
    public final c l0(i iVar) {
        b.g(iVar, "other is null");
        return g0(this, iVar);
    }

    @d
    @h("none")
    public final <R> R m(@f d<? extends R> dVar) {
        return (R) ((d) b.g(dVar, "converter is null")).a(this);
    }

    @h("none")
    public final void n() {
        ht.h hVar = new ht.h();
        b(hVar);
        hVar.b();
    }

    @d
    @h(h.P)
    @f
    public final c n0(j0 j0Var) {
        b.g(j0Var, "scheduler is null");
        return a.Q(new g0(this, j0Var));
    }

    @d
    @h("none")
    @f
    public final boolean o(long j10, TimeUnit timeUnit) {
        b.g(timeUnit, "unit is null");
        ht.h hVar = new ht.h();
        b(hVar);
        return hVar.a(j10, timeUnit);
    }

    @d
    @h("none")
    public final c o0() {
        return p0(ft.a.c());
    }

    @d
    @h("none")
    @zs.g
    public final Throwable p() {
        ht.h hVar = new ht.h();
        b(hVar);
        return hVar.d();
    }

    @h("none")
    @f
    @d
    public final c p0(dt.r<? super Throwable> rVar) {
        b.g(rVar, "predicate is null");
        return a.Q(new h0(this, rVar));
    }

    @d
    @h("none")
    @zs.g
    public final Throwable q(long j10, TimeUnit timeUnit) {
        b.g(timeUnit, "unit is null");
        ht.h hVar = new ht.h();
        b(hVar);
        return hVar.e(j10, timeUnit);
    }

    @h("none")
    @f
    @d
    public final c q0(dt.o<? super Throwable, ? extends i> oVar) {
        b.g(oVar, "errorMapper is null");
        return a.Q(new j0(this, oVar));
    }

    @d
    @h("none")
    public final c r() {
        return a.Q(new it.c(this));
    }

    @d
    @h("none")
    public final c r0() {
        return a.Q(new it.j(this));
    }

    @d
    @h("none")
    public final c s0() {
        return W(W0().T4());
    }

    @d
    @h("none")
    public final c t(j jVar) {
        return g1(((j) b.g(jVar, "transformer is null")).a(this));
    }

    @d
    @h("none")
    public final c t0(long j10) {
        return W(W0().U4(j10));
    }

    @d
    @h("none")
    public final c u0(dt.e eVar) {
        return W(W0().V4(eVar));
    }

    @d
    @h("none")
    public final c v0(dt.o<? super l<Object>, ? extends c00.c<?>> oVar) {
        return W(W0().W4(oVar));
    }

    @d
    @h("none")
    public final c w0() {
        return W(W0().n5());
    }

    @d
    @h("none")
    public final c x0(long j10) {
        return W(W0().o5(j10));
    }

    @d
    @h("none")
    @f
    public final c y(i iVar) {
        b.g(iVar, "other is null");
        return a.Q(new it.b(this, iVar));
    }

    @d
    @h("none")
    public final c y0(long j10, dt.r<? super Throwable> rVar) {
        return W(W0().p5(j10, rVar));
    }

    @d
    @h("none")
    public final c z0(dt.d<? super Integer, ? super Throwable> dVar) {
        return W(W0().q5(dVar));
    }
}