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));
}
}