Aqara Home v2.4.1版本的 MD5 值为：529779ac2bc0131db52a1fc3098d2b35

以下内容为反编译后的 c.java 源代码，内容仅作参考

package p.a;

import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
public abstract class c implements i {
    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c a(i... iVarArr) {
        p.a.y0.b.b.a(iVarArr, "sources is null");
        if (iVarArr.length == 0) {
            return q();
        }
        if (iVarArr.length == 1) {
            return h(iVarArr[0]);
        }
        return p.a.c1.a.a(new p.a.y0.e.a.a(iVarArr, null));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c b(i... iVarArr) {
        p.a.y0.b.b.a(iVarArr, "sources is null");
        if (iVarArr.length == 0) {
            return q();
        }
        if (iVarArr.length == 1) {
            return h(iVarArr[0]);
        }
        return p.a.c1.a.a(new p.a.y0.e.a.e(iVarArr));
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c c(x.g.c<? extends i> cVar) {
        return a(cVar, 2);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c d(Callable<?> callable) {
        p.a.y0.b.b.a(callable, "callable is null");
        return p.a.c1.a.a(new p.a.y0.e.a.r(callable));
    }

    @p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c e(x.g.c<? extends i> cVar) {
        return a(cVar, Integer.MAX_VALUE, false);
    }

    @p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c f(x.g.c<? extends i> cVar) {
        return a(cVar, Integer.MAX_VALUE, true);
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c h(i iVar) {
        p.a.y0.b.b.a(iVar, "source is null");
        if (iVar instanceof c) {
            return p.a.c1.a.a((c) iVar);
        }
        return p.a.c1.a.a(new p.a.y0.e.a.w(iVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c q() {
        return p.a.c1.a.a(p.a.y0.e.a.n.a);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public static c r() {
        return p.a.c1.a.a(p.a.y0.e.a.f0.a);
    }

    public abstract void c(f fVar);

    @p.a.t0.e
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> k0<a0<T>> i() {
        return p.a.c1.a.a(new p.a.y0.e.a.z(this));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c j() {
        return a(p.a.y0.b.a.b());
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c k() {
        return p.a.c1.a.a(new p.a.y0.e.a.j(this));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c l() {
        return d(n().C());
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c m() {
        return d(n().E());
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> l<T> n() {
        if (this instanceof p.a.y0.c.b) {
            return ((p.a.y0.c.b) this).d();
        }
        return p.a.c1.a.a(new p.a.y0.e.a.o0(this));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> s<T> o() {
        if (this instanceof p.a.y0.c.c) {
            return ((p.a.y0.c.c) this).c();
        }
        return p.a.c1.a.a(new p.a.y0.e.c.k0(this));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> b0<T> p() {
        if (this instanceof p.a.y0.c.d) {
            return ((p.a.y0.c.d) this).b();
        }
        return p.a.c1.a.a(new p.a.y0.e.a.p0(this));
    }

    @p.a.t0.h("none")
    public final p.a.u0.c subscribe() {
        p.a.y0.d.o oVar = new p.a.y0.d.o();
        a((f) oVar);
        return oVar;
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final p.a.a1.n<Void> test() {
        p.a.a1.n<Void> nVar = new p.a.a1.n<>();
        a((f) nVar);
        return nVar;
    }

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

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public static c f(long j2, TimeUnit timeUnit) {
        return d(j2, timeUnit, p.a.e1.b.a());
    }

    @p.a.t0.h("none")
    public final void e() {
        p.a.y0.d.h hVar = new p.a.y0.d.h();
        a((f) hVar);
        hVar.b();
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
    @p.a.t0.d
    public static <T> c d(x.g.c<T> cVar) {
        p.a.y0.b.b.a(cVar, "publisher is null");
        return p.a.c1.a.a(new p.a.y0.e.a.t(cVar));
    }

    @p.a.t0.g
    @p.a.t0.d
    @p.a.t0.h("none")
    public final Throwable f() {
        p.a.y0.d.h hVar = new p.a.y0.d.h();
        a((f) hVar);
        return hVar.c();
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final p.a.a1.n<Void> test(boolean z2) {
        p.a.a1.n<Void> nVar = new p.a.a1.n<>();
        if (z2) {
            nVar.cancel();
        }
        a((f) nVar);
        return nVar;
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c c(i... iVarArr) {
        p.a.y0.b.b.a(iVarArr, "sources is null");
        if (iVarArr.length == 0) {
            return q();
        }
        if (iVarArr.length == 1) {
            return h(iVarArr[0]);
        }
        return p.a.c1.a.a(new p.a.y0.e.a.b0(iVarArr));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c d(i... iVarArr) {
        p.a.y0.b.b.a(iVarArr, "sources is null");
        return p.a.c1.a.a(new p.a.y0.e.a.c0(iVarArr));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c g(p.a.x0.a aVar) {
        p.a.y0.b.b.a(aVar, "run is null");
        return p.a.c1.a.a(new p.a.y0.e.a.q(aVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c e(p.a.x0.a aVar) {
        p.a.x0.g<? super p.a.u0.c> d = p.a.y0.b.a.d();
        p.a.x0.g<? super Throwable> d2 = p.a.y0.b.a.d();
        p.a.x0.a aVar2 = p.a.y0.b.a.c;
        return a(d, d2, aVar2, aVar2, aVar2, aVar);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c h() {
        return p.a.c1.a.a(new p.a.y0.e.a.x(this));
    }

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c f(p.a.x0.a aVar) {
        p.a.x0.g<? super p.a.u0.c> d = p.a.y0.b.a.d();
        p.a.x0.g<? super Throwable> d2 = p.a.y0.b.a.d();
        p.a.x0.a aVar2 = p.a.y0.b.a.c;
        return a(d, d2, aVar2, aVar, aVar2, aVar2);
    }

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

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c d(Iterable<? extends i> iterable) {
        p.a.y0.b.b.a(iterable, "sources is null");
        return p.a.c1.a.a(new p.a.y0.e.a.d0(iterable));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final c f(i iVar) {
        p.a.y0.b.b.a(iVar, "other is null");
        return p.a.c1.a.a(new p.a.y0.e.a.l0(this, iVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c g() {
        return p.a.c1.a.a(new p.a.y0.e.a.c(this));
    }

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public final c e(long j2, TimeUnit timeUnit) {
        return b(j2, timeUnit, p.a.e1.b.a(), null);
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    public static c a(x.g.c<? extends i> cVar, int i2) {
        p.a.y0.b.b.a(cVar, "sources is null");
        p.a.y0.b.b.a(i2, "prefetch");
        return p.a.c1.a.a(new p.a.y0.e.a.d(cVar, i2));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c b(Callable<? extends i> callable) {
        p.a.y0.b.b.a(callable, "completableSupplier");
        return p.a.c1.a.a(new p.a.y0.e.a.h(callable));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public static c d(long j2, TimeUnit timeUnit, j0 j0Var) {
        p.a.y0.b.b.a(timeUnit, "unit is null");
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new p.a.y0.e.a.n0(j2, timeUnit, j0Var));
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> c b(y<T> yVar) {
        p.a.y0.b.b.a(yVar, "maybe is null");
        return p.a.c1.a.a(new p.a.y0.e.c.q0(yVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c a(g gVar) {
        p.a.y0.b.b.a(gVar, "source is null");
        return p.a.c1.a.a(new p.a.y0.e.a.g(gVar));
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c c(x.g.c<? extends i> cVar, int i2) {
        return a(cVar, i2, true);
    }

    @p.a.t0.e
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public final c d(long j2, TimeUnit timeUnit) {
        return b(j2, timeUnit, p.a.e1.b.a());
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> c b(g0<T> g0Var) {
        p.a.y0.b.b.a(g0Var, "observable is null");
        return p.a.c1.a.a(new p.a.y0.e.a.s(g0Var));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final c c(i iVar) {
        p.a.y0.b.b.a(iVar, "other is null");
        return p.a.c1.a.a(new p.a.y0.e.a.b(this, iVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c d(p.a.x0.a aVar) {
        p.a.x0.g<? super p.a.u0.c> d = p.a.y0.b.a.d();
        p.a.x0.g<? super Throwable> d2 = p.a.y0.b.a.d();
        p.a.x0.a aVar2 = p.a.y0.b.a.c;
        return a(d, d2, aVar, aVar2, aVar2, aVar2);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c a(Throwable th) {
        p.a.y0.b.b.a(th, "error is null");
        return p.a.c1.a.a(new p.a.y0.e.a.o(th));
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> c b(q0<T> q0Var) {
        p.a.y0.b.b.a(q0Var, "single is null");
        return p.a.c1.a.a(new p.a.y0.e.a.v(q0Var));
    }

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public final c c(long j2, TimeUnit timeUnit) {
        return a(j2, timeUnit, p.a.e1.b.a(), false);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c a(Future<?> future) {
        p.a.y0.b.b.a(future, "future is null");
        return g(p.a.y0.b.a.a(future));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c c(p.a.x0.g<? super p.a.u0.c> gVar) {
        p.a.x0.g<? super Throwable> d = p.a.y0.b.a.d();
        p.a.x0.a aVar = p.a.y0.b.a.c;
        return a(gVar, d, aVar, aVar, aVar, aVar);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final <U> U d(p.a.x0.o<? super c, U> oVar) {
        try {
            return (U) ((p.a.x0.o) p.a.y0.b.b.a(oVar, "converter is null")).apply(this);
        } catch (Throwable th) {
            p.a.v0.b.b(th);
            throw p.a.y0.j.k.c(th);
        }
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c b(x.g.c<? extends i> cVar, int i2) {
        return a(cVar, i2, false);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final c c(p.a.x0.a aVar) {
        p.a.y0.b.b.a(aVar, "onFinally is null");
        return p.a.c1.a.a(new p.a.y0.e.a.l(this, aVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static c a(Runnable runnable) {
        p.a.y0.b.b.a(runnable, "run is null");
        return p.a.c1.a.a(new p.a.y0.e.a.u(runnable));
    }

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c c(p.a.x0.o<? super l<Throwable>, ? extends x.g.c<?>> oVar) {
        return d(n().B(oVar));
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    public static c a(x.g.c<? extends i> cVar, int i2, boolean z2) {
        p.a.y0.b.b.a(cVar, "sources is null");
        p.a.y0.b.b.a(i2, "maxConcurrency");
        return p.a.c1.a.a(new p.a.y0.e.a.a0(cVar, i2, z2));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c b(i iVar) {
        p.a.y0.b.b.a(iVar, "next is null");
        return p.a.c1.a.a(new p.a.y0.e.a.b(this, iVar));
    }

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c c(long j2, TimeUnit timeUnit, j0 j0Var) {
        return b(j2, timeUnit, j0Var, null);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c c(j0 j0Var) {
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new p.a.y0.e.a.k(this, j0Var));
    }

    @p.a.t0.g
    @p.a.t0.d
    @p.a.t0.h("none")
    public final Throwable b(long j2, TimeUnit timeUnit) {
        p.a.y0.b.b.a(timeUnit, "unit is null");
        p.a.y0.d.h hVar = new p.a.y0.d.h();
        a((f) hVar);
        return hVar.b(j2, timeUnit);
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <R> c a(Callable<R> callable, p.a.x0.o<? super R, ? extends i> oVar, p.a.x0.g<? super R> gVar, boolean z2) {
        p.a.y0.b.b.a(callable, "resourceSupplier is null");
        p.a.y0.b.b.a(oVar, "completableFunction is null");
        p.a.y0.b.b.a(gVar, "disposer is null");
        return p.a.c1.a.a(new p.a.y0.e.a.r0(callable, oVar, gVar, z2));
    }

    @p.a.t0.e
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c b(long j2, TimeUnit timeUnit, j0 j0Var) {
        return d(j2, timeUnit, j0Var).b(this);
    }

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

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c b(p.a.x0.a aVar) {
        p.a.x0.g<? super p.a.u0.c> d = p.a.y0.b.a.d();
        p.a.x0.g<? super Throwable> d2 = p.a.y0.b.a.d();
        p.a.x0.a aVar2 = p.a.y0.b.a.c;
        return a(d, d2, aVar2, aVar2, aVar, aVar2);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> b0<T> a(g0<T> g0Var) {
        p.a.y0.b.b.a(g0Var, "next is null");
        return p.a.c1.a.a(new p.a.y0.e.d.a(this, g0Var));
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    public final <T> l<T> a(x.g.c<T> cVar) {
        p.a.y0.b.b.a(cVar, "next is null");
        return p.a.c1.a.a(new p.a.y0.e.d.b(this, cVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c b(p.a.x0.o<? super l<Object>, ? extends x.g.c<?>> oVar) {
        return d(n().z(oVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c b(long j2) {
        return d(n().f(j2));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> k0<T> a(q0<T> q0Var) {
        p.a.y0.b.b.a(q0Var, "next is null");
        return p.a.c1.a.a(new p.a.y0.e.g.g(q0Var, this));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c b(p.a.x0.r<? super Throwable> rVar) {
        return d(n().e(rVar));
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    public final <T> l<T> b(x.g.c<T> cVar) {
        p.a.y0.b.b.a(cVar, "other is null");
        return n().j((x.g.c) cVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> s<T> a(y<T> yVar) {
        p.a.y0.b.b.a(yVar, "next is null");
        return p.a.c1.a.a(new p.a.y0.e.c.o(yVar, this));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final <E extends f> E b(E e2) {
        a((f) e2);
        return e2;
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c b(j0 j0Var) {
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new p.a.y0.e.a.k0(this, j0Var));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final boolean a(long j2, TimeUnit timeUnit) {
        p.a.y0.b.b.a(timeUnit, "unit is null");
        p.a.y0.d.h hVar = new p.a.y0.d.h();
        a((f) hVar);
        return hVar.a(j2, timeUnit);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    private c b(long j2, TimeUnit timeUnit, j0 j0Var, i iVar) {
        p.a.y0.b.b.a(timeUnit, "unit is null");
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new p.a.y0.e.a.m0(this, j2, timeUnit, j0Var, iVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(j jVar) {
        return h(((j) p.a.y0.b.b.a(jVar, "transformer is null")).apply(this));
    }

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c a(long j2, TimeUnit timeUnit, j0 j0Var) {
        return a(j2, timeUnit, j0Var, false);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c a(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
        p.a.y0.b.b.a(timeUnit, "unit is null");
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new p.a.y0.e.a.i(this, j2, timeUnit, j0Var, z2));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(p.a.x0.g<? super Throwable> gVar) {
        p.a.x0.g<? super p.a.u0.c> d = p.a.y0.b.a.d();
        p.a.x0.a aVar = p.a.y0.b.a.c;
        return a(d, gVar, aVar, aVar, aVar, aVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    private c a(p.a.x0.g<? super p.a.u0.c> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar, p.a.x0.a aVar2, p.a.x0.a aVar3, p.a.x0.a aVar4) {
        p.a.y0.b.b.a(gVar, "onSubscribe is null");
        p.a.y0.b.b.a(gVar2, "onError is null");
        p.a.y0.b.b.a(aVar, "onComplete is null");
        p.a.y0.b.b.a(aVar2, "onTerminate is null");
        p.a.y0.b.b.a(aVar3, "onAfterTerminate is null");
        p.a.y0.b.b.a(aVar4, "onDispose is null");
        return p.a.c1.a.a(new p.a.y0.e.a.i0(this, gVar, gVar2, aVar, aVar2, aVar3, aVar4));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(h hVar) {
        p.a.y0.b.b.a(hVar, "onLift is null");
        return p.a.c1.a.a(new p.a.y0.e.a.y(this, hVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c a(j0 j0Var) {
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new p.a.y0.e.a.g0(this, j0Var));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(p.a.x0.r<? super Throwable> rVar) {
        p.a.y0.b.b.a(rVar, "predicate is null");
        return p.a.c1.a.a(new p.a.y0.e.a.h0(this, rVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(p.a.x0.o<? super Throwable, ? extends i> oVar) {
        p.a.y0.b.b.a(oVar, "errorMapper is null");
        return p.a.c1.a.a(new p.a.y0.e.a.j0(this, oVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(long j2) {
        return d(n().e(j2));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(p.a.x0.e eVar) {
        return d(n().a(eVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(p.a.x0.d<? super Integer, ? super Throwable> dVar) {
        return d(n().b(dVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final c a(long j2, p.a.x0.r<? super Throwable> rVar) {
        return d(n().a(j2, rVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> b0<T> a(b0<T> b0Var) {
        p.a.y0.b.b.a(b0Var, "other is null");
        return b0Var.concatWith(p());
    }

    @Override
    @p.a.t0.h("none")
    public final void a(f fVar) {
        p.a.y0.b.b.a(fVar, "observer is null");
        try {
            f a = p.a.c1.a.a(this, fVar);
            p.a.y0.b.b.a(a, "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");
            c(a);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            p.a.v0.b.b(th);
            p.a.c1.a.b(th);
            throw b(th);
        }
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final p.a.u0.c a(p.a.x0.a aVar) {
        p.a.y0.b.b.a(aVar, "onComplete is null");
        p.a.y0.d.j jVar = new p.a.y0.d.j(aVar);
        a((f) jVar);
        return jVar;
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public final c a(long j2, TimeUnit timeUnit, i iVar) {
        p.a.y0.b.b.a(iVar, "other is null");
        return b(j2, timeUnit, p.a.e1.b.a(), iVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final c a(long j2, TimeUnit timeUnit, j0 j0Var, i iVar) {
        p.a.y0.b.b.a(iVar, "other is null");
        return b(j2, timeUnit, j0Var, iVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> k0<T> a(Callable<? extends T> callable) {
        p.a.y0.b.b.a(callable, "completionValueSupplier is null");
        return p.a.c1.a.a(new p.a.y0.e.a.q0(this, callable, null));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <T> k0<T> a(T t2) {
        p.a.y0.b.b.a((Object) t2, "completionValue is null");
        return p.a.c1.a.a(new p.a.y0.e.a.q0(this, null, t2));
    }
}