Aqara Home v2.4.1版本的 MD5 值为：529779ac2bc0131db52a1fc3098d2b35
以下内容为反编译后的 k0.java 源代码，内容仅作参考
package p.a;
import java.util.NoSuchElementException;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import p.a.y0.e.b.d1;
import p.a.y0.e.b.r3;
import p.a.y0.e.e.e3;
import p.a.y0.e.g.s0;
import p.a.y0.e.g.t0;
import p.a.y0.e.g.u0;
import p.a.y0.e.g.v0;
import p.a.y0.e.g.w0;
import p.a.y0.e.g.x0;
import p.a.y0.e.g.y0;
import p.a.y0.e.g.z0;
public abstract class k0<T> implements q0<T> {
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> a(Iterable<? extends q0<? extends T>> iterable) {
p.a.y0.b.b.a(iterable, "sources is null");
return p.a.c1.a.a(new p.a.y0.e.g.a(null, iterable));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> b(Iterable<? extends q0<? extends T>> iterable) {
return c((x.g.c) l.f((Iterable) iterable));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(x.g.c<? extends q0<? extends T>> cVar) {
return a(cVar, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> d(x.g.c<? extends q0<? extends T>> cVar) {
return l.q(cVar).e(p.a.y0.e.g.h0.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> k0<T> e(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "publisher is null");
return p.a.c1.a.a(new p.a.y0.e.g.e0(cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> f(x.g.c<? extends q0<? extends T>> cVar) {
p.a.y0.b.b.a(cVar, "sources is null");
return p.a.c1.a.a(new d1(cVar, p.a.y0.e.g.h0.b(), false, Integer.MAX_VALUE, l.Q()));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> g(x.g.c<? extends q0<? extends T>> cVar) {
p.a.y0.b.b.a(cVar, "sources is null");
return p.a.c1.a.a(new d1(cVar, p.a.y0.e.g.h0.b(), true, Integer.MAX_VALUE, l.Q()));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> h(q0<T> q0Var) {
p.a.y0.b.b.a(q0Var, "source is null");
if (q0Var instanceof k0) {
return p.a.c1.a.a((k0) q0Var);
}
return p.a.c1.a.a(new p.a.y0.e.g.f0(q0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> r() {
return p.a.c1.a.a(p.a.y0.e.g.m0.a);
}
public abstract void c(@p.a.t0.f n0<? super T> n0Var);
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <R> k0<R> i(p.a.x0.o<? super T, ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.g.k0(this, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> j(p.a.x0.o<? super Throwable, ? extends q0<? extends T>> oVar) {
p.a.y0.b.b.a(oVar, "resumeFunctionInCaseOfError is null");
return p.a.c1.a.a(new p.a.y0.e.g.p0(this, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> k(p.a.x0.o<Throwable, ? extends T> oVar) {
p.a.y0.b.b.a(oVar, "resumeFunction is null");
return p.a.c1.a.a(new p.a.y0.e.g.o0(this, oVar, null));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> l(p.a.x0.o<? super l<Object>, ? extends x.g.c<?>> oVar) {
return n().z(oVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> m(p.a.x0.o<? super l<Throwable>, ? extends x.g.c<?>> oVar) {
return a((l) n().B(oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> R n(p.a.x0.o<? super k0<T>, R> oVar) {
try {
return (R) ((p.a.x0.o) p.a.y0.b.b.a(oVar, "convert is null")).apply(this);
} catch (Throwable th) {
p.a.v0.b.b(th);
throw p.a.y0.j.k.c(th);
}
}
@p.a.t0.d
@p.a.t0.h("none")
public final Future<T> o() {
return (Future) b((k0<T>) new p.a.y0.d.r());
}
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> p() {
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.n0(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> q() {
if (this instanceof p.a.y0.c.d) {
return ((p.a.y0.c.d) this).b();
}
return p.a.c1.a.a(new v0(this));
}
@p.a.t0.h("none")
public final p.a.u0.c subscribe() {
return subscribe(p.a.y0.b.a.d(), p.a.y0.b.a.f29916f);
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.a1.n<T> test() {
p.a.a1.n<T> nVar = new p.a.a1.n<>();
a((n0) nVar);
return nVar;
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> b(g0<? extends q0<? extends T>> g0Var) {
p.a.y0.b.b.a(g0Var, "sources is null");
return p.a.c1.a.a(new p.a.y0.e.e.v(g0Var, p.a.y0.e.g.h0.c(), 2, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(q0<? extends T>... q0VarArr) {
return l.b((Object[]) q0VarArr).e(p.a.y0.e.g.h0.b());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> d(Iterable<? extends q0<? extends T>> iterable) {
return f(l.f((Iterable) iterable));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> l() {
return a((l) n().E());
}
@Deprecated
@p.a.t0.d
@p.a.t0.h("none")
public final c m() {
return p.a.c1.a.a(new p.a.y0.e.a.v(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar) {
return subscribe(gVar, p.a.y0.b.a.f29916f);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> a(q0<? extends T>... q0VarArr) {
if (q0VarArr.length == 0) {
return b((Callable<? extends Throwable>) p.a.y0.e.g.h0.a());
}
if (q0VarArr.length == 1) {
return h(q0VarArr[0]);
}
return p.a.c1.a.a(new p.a.y0.e.g.a(q0VarArr, 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 <T> l<T> c(Iterable<? extends q0<? extends T>> iterable) {
return l.f((Iterable) iterable).e(p.a.y0.e.g.h0.b());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> d(q0<? extends T> q0Var, q0<? extends T> q0Var2) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
return g(l.b((Object[]) new q0[]{q0Var, q0Var2}));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> e(Iterable<? extends q0<? extends T>> iterable) {
return g(l.f((Iterable) iterable));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> f(q0<? extends q0<? extends T>> q0Var) {
p.a.y0.b.b.a(q0Var, "source is null");
return p.a.c1.a.a(new p.a.y0.e.g.x(q0Var, p.a.y0.b.a.e()));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> g(q0<T> q0Var) {
p.a.y0.b.b.a(q0Var, "onSubscribe is null");
if (!(q0Var instanceof k0)) {
return p.a.c1.a.a(new p.a.y0.e.g.f0(q0Var));
}
throw new IllegalArgumentException("unsafeCreate(Single) should be upgraded");
}
@p.a.t0.e
@p.a.t0.d
@p.a.t0.h("none")
public final k0<a0<T>> i() {
return p.a.c1.a.a(new p.a.y0.e.g.l0(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> j() {
return p.a.c1.a.a(new p.a.y0.e.g.l(this));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> k() {
return n().C();
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2) {
p.a.y0.b.b.a(gVar, "onSuccess is null");
p.a.y0.b.b.a(gVar2, "onError is null");
p.a.y0.d.k kVar = new p.a.y0.d.k(gVar, gVar2);
a((n0) kVar);
return kVar;
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.a1.n<T> test(boolean z2) {
p.a.a1.n<T> nVar = new p.a.a1.n<>();
if (z2) {
nVar.cancel();
}
a((n0) nVar);
return nVar;
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> b(q0<? extends T>... q0VarArr) {
return p.a.c1.a.a(new p.a.y0.e.b.w(l.b((Object[]) q0VarArr), p.a.y0.e.g.h0.b(), 2, p.a.y0.j.j.BOUNDARY));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> c(Callable<? extends T> callable) {
p.a.y0.b.b.a(callable, "callable is null");
return p.a.c1.a.a(new p.a.y0.e.g.d0(callable));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> e(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.s(this, oVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final 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 u0(this));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> b(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.g.w(callable));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> f() {
return p.a.c1.a.a(new p.a.y0.e.g.b(this));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<U> h(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.g.a0(this, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> c(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "observableSource is null");
return p.a.c1.a.a(new e3(g0Var, null));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static k0<Long> d(long j2, TimeUnit timeUnit) {
return d(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final T e() {
p.a.y0.d.h hVar = new p.a.y0.d.h();
a((n0) hVar);
return (T) hVar.b();
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> f(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.g.c0(this, 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 <T> l<T> b(q0<? extends T> q0Var, q0<? extends T> q0Var2, q0<? extends T> q0Var3) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
return f(l.b((Object[]) new q0[]{q0Var, q0Var2, q0Var3}));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static k0<Long> 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 t0(j2, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> g() {
return p.a.c1.a.a(new p.a.y0.e.g.g0(this));
}
@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.v(this));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(x.g.c<? extends q0<? extends T>> 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.b.z(cVar, p.a.y0.e.g.h0.b(), i2, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> c(T t2) {
p.a.y0.b.b.a((Object) t2, "item is null");
return p.a.c1.a.a(new p.a.y0.e.g.i0(t2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U> l<U> g(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.g.z(this, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <E> k0<T> e(q0<? extends E> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return b((x.g.c) new u0(q0Var));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(q0<? extends T> q0Var, q0<? extends T> q0Var2) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
return f(l.b((Object[]) new q0[]{q0Var, q0Var2}));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.e
@p.a.t0.d
public final k0<T> d(p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onTerminate is null");
return p.a.c1.a.a(new p.a.y0.e.g.u(this, aVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(q0<? extends T> q0Var, q0<? extends T> q0Var2) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
return c((x.g.c) l.b((Object[]) new q0[]{q0Var, q0Var2}));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> b(q0<? extends T> q0Var, q0<? extends T> q0Var2, q0<? extends T> q0Var3, q0<? extends T> q0Var4) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
return f(l.b((Object[]) new q0[]{q0Var, q0Var2, q0Var3, q0Var4}));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> d(p.a.x0.g<? super T> gVar) {
p.a.y0.b.b.a(gVar, "onSuccess is null");
return p.a.c1.a.a(new p.a.y0.e.g.t(this, gVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(q0<? extends T> q0Var, q0<? extends T> q0Var2, q0<? extends T> q0Var3) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
return g(l.b((Object[]) new q0[]{q0Var, q0Var2, q0Var3}));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(q0<? extends T> q0Var, q0<? extends T> q0Var2, q0<? extends T> q0Var3) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
return c((x.g.c) l.b((Object[]) new q0[]{q0Var, q0Var2, q0Var3}));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <R> s<R> d(p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.g.b0(this, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> b(q0<? extends T> q0Var, q0<? extends T> q0Var2) {
p.a.y0.b.b.a(q0Var, "first is null");
p.a.y0.b.b.a(q0Var2, "second is null");
return p.a.c1.a.a(new p.a.y0.e.g.v(q0Var, q0Var2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> d(q0<? extends T> q0Var) {
return c(this, q0Var);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(q0<? extends T> q0Var, q0<? extends T> q0Var2, q0<? extends T> q0Var3, q0<? extends T> q0Var4) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
return g(l.b((Object[]) new q0[]{q0Var, q0Var2, q0Var3, q0Var4}));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(q0<? extends T> q0Var, q0<? extends T> q0Var2, q0<? extends T> q0Var3, q0<? extends T> q0Var4) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
return c((x.g.c) l.b((Object[]) new q0[]{q0Var, q0Var2, q0Var3, q0Var4}));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> b(q0<? extends T> q0Var) {
return a(this, q0Var);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final k0<T> b(long j2, TimeUnit timeUnit) {
return b(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final k0<T> b(long j2, TimeUnit timeUnit, j0 j0Var) {
return a((g0) b0.timer(j2, timeUnit, j0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> b(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.g.o(this, aVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <U> k0<T> c(q0<U> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return p.a.c1.a.a(new p.a.y0.e.g.j(this, q0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> a(o0<T> o0Var) {
p.a.y0.b.b.a(o0Var, "source is null");
return p.a.c1.a.a(new p.a.y0.e.g.d(o0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> b(p.a.x0.b<? super T, ? super Throwable> bVar) {
p.a.y0.b.b.a(bVar, "onEvent is null");
return p.a.c1.a.a(new p.a.y0.e.g.r(this, bVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> c(p.a.x0.g<? super p.a.u0.c> gVar) {
p.a.y0.b.b.a(gVar, "onSubscribe is null");
return p.a.c1.a.a(new p.a.y0.e.g.s(this, gVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> a(Callable<? extends q0<? extends T>> callable) {
p.a.y0.b.b.a(callable, "singleSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.g.e(callable));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> b(p.a.x0.g<? super Throwable> gVar) {
p.a.y0.b.b.a(gVar, "onError is null");
return p.a.c1.a.a(new p.a.y0.e.g.q(this, gVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> c(p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onDispose is null");
return p.a.c1.a.a(new p.a.y0.e.g.p(this, aVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> a(Throwable th) {
p.a.y0.b.b.a(th, "exception is null");
return b((Callable<? extends Throwable>) p.a.y0.b.a.b(th));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <R> k0<R> b(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.g.x(this, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final c c(p.a.x0.o<? super T, ? extends i> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.g.y(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> a(Future<? extends T> future) {
return a(l.a(future));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<T> a(Future<? extends T> future, long j2, TimeUnit timeUnit) {
return a(l.a(future, j2, timeUnit));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> b(T t2) {
p.a.y0.b.b.a((Object) t2, "value is null");
return p.a.c1.a.a(new p.a.y0.e.g.o0(this, null, t2));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final k0<T> c(long j2, TimeUnit timeUnit) {
return b(j2, timeUnit, p.a.e1.b.a(), (q0) null);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static <T> k0<T> a(Future<? extends T> future, long j2, TimeUnit timeUnit, j0 j0Var) {
return a(l.a(future, j2, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final k0<T> c(long j2, TimeUnit timeUnit, j0 j0Var) {
return b(j2, timeUnit, j0Var, (q0) null);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static <T> k0<T> a(Future<? extends T> future, j0 j0Var) {
return a(l.a((Future) future, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> b(long j2) {
return a((l) n().f(j2));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final k0<T> c(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new w0(this, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, U> k0<T> a(Callable<U> callable, p.a.x0.o<? super U, ? extends q0<? extends T>> oVar, p.a.x0.g<? super U> gVar) {
return a((Callable) callable, (p.a.x0.o) oVar, (p.a.x0.g) gVar, true);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> b(p.a.x0.r<? super Throwable> rVar) {
return a((l) n().e(rVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, U> k0<T> a(Callable<U> callable, p.a.x0.o<? super U, ? extends q0<? extends T>> oVar, p.a.x0.g<? super U> gVar, boolean z2) {
p.a.y0.b.b.a(callable, "resourceSupplier is null");
p.a.y0.b.b.a(oVar, "singleFunction is null");
p.a.y0.b.b.a(gVar, "disposer is null");
return p.a.c1.a.a(new x0(callable, oVar, gVar, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <E extends n0<? super T>> E b(E e2) {
a((n0) e2);
return e2;
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final k0<T> b(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new p.a.y0.e.g.q0(this, j0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> b(i iVar) {
p.a.y0.b.b.a(iVar, "other is null");
return b((x.g.c) new p.a.y0.e.a.o0(iVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> k0<R> a(Iterable<? extends q0<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(iterable, "sources is null");
return p.a.c1.a.a(new z0(iterable, oVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <E> k0<T> b(x.g.c<E> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return p.a.c1.a.a(new p.a.y0.e.g.r0(this, cVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
return a(p.a.y0.b.a.a((p.a.x0.c) cVar), q0Var, q0Var2);
}
private k0<T> b(long j2, TimeUnit timeUnit, j0 j0Var, q0<? extends T> q0Var) {
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 s0(this, j2, timeUnit, j0Var, q0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, q0<? extends T3> q0Var3, p.a.x0.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
return a(p.a.y0.b.a.a((p.a.x0.h) hVar), q0Var, q0Var2, q0Var3);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, q0<? extends T3> q0Var3, q0<? extends T4> q0Var4, p.a.x0.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
return a(p.a.y0.b.a.a((p.a.x0.i) iVar), q0Var, q0Var2, q0Var3, q0Var4);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, q0<? extends T3> q0Var3, q0<? extends T4> q0Var4, q0<? extends T5> q0Var5, p.a.x0.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
p.a.y0.b.b.a(q0Var5, "source5 is null");
return a(p.a.y0.b.a.a((p.a.x0.j) jVar), q0Var, q0Var2, q0Var3, q0Var4, q0Var5);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, q0<? extends T3> q0Var3, q0<? extends T4> q0Var4, q0<? extends T5> q0Var5, q0<? extends T6> q0Var6, p.a.x0.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
p.a.y0.b.b.a(q0Var5, "source5 is null");
p.a.y0.b.b.a(q0Var6, "source6 is null");
return a(p.a.y0.b.a.a((p.a.x0.k) kVar), q0Var, q0Var2, q0Var3, q0Var4, q0Var5, q0Var6);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, q0<? extends T3> q0Var3, q0<? extends T4> q0Var4, q0<? extends T5> q0Var5, q0<? extends T6> q0Var6, q0<? extends T7> q0Var7, p.a.x0.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
p.a.y0.b.b.a(q0Var5, "source5 is null");
p.a.y0.b.b.a(q0Var6, "source6 is null");
p.a.y0.b.b.a(q0Var7, "source7 is null");
return a(p.a.y0.b.a.a((p.a.x0.l) lVar), q0Var, q0Var2, q0Var3, q0Var4, q0Var5, q0Var6, q0Var7);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, q0<? extends T3> q0Var3, q0<? extends T4> q0Var4, q0<? extends T5> q0Var5, q0<? extends T6> q0Var6, q0<? extends T7> q0Var7, q0<? extends T8> q0Var8, p.a.x0.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
p.a.y0.b.b.a(q0Var5, "source5 is null");
p.a.y0.b.b.a(q0Var6, "source6 is null");
p.a.y0.b.b.a(q0Var7, "source7 is null");
p.a.y0.b.b.a(q0Var8, "source8 is null");
return a(p.a.y0.b.a.a((p.a.x0.m) mVar), q0Var, q0Var2, q0Var3, q0Var4, q0Var5, q0Var6, q0Var7, q0Var8);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> k0<R> a(q0<? extends T1> q0Var, q0<? extends T2> q0Var2, q0<? extends T3> q0Var3, q0<? extends T4> q0Var4, q0<? extends T5> q0Var5, q0<? extends T6> q0Var6, q0<? extends T7> q0Var7, q0<? extends T8> q0Var8, q0<? extends T9> q0Var9, p.a.x0.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
p.a.y0.b.b.a(q0Var, "source1 is null");
p.a.y0.b.b.a(q0Var2, "source2 is null");
p.a.y0.b.b.a(q0Var3, "source3 is null");
p.a.y0.b.b.a(q0Var4, "source4 is null");
p.a.y0.b.b.a(q0Var5, "source5 is null");
p.a.y0.b.b.a(q0Var6, "source6 is null");
p.a.y0.b.b.a(q0Var7, "source7 is null");
p.a.y0.b.b.a(q0Var8, "source8 is null");
p.a.y0.b.b.a(q0Var9, "source9 is null");
return a(p.a.y0.b.a.a((p.a.x0.n) nVar), q0Var, q0Var2, q0Var3, q0Var4, q0Var5, q0Var6, q0Var7, q0Var8, q0Var9);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> k0<R> a(p.a.x0.o<? super Object[], ? extends R> oVar, q0<? extends T>... q0VarArr) {
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(q0VarArr, "sources is null");
if (q0VarArr.length == 0) {
return a((Throwable) new NoSuchElementException());
}
return p.a.c1.a.a(new y0(q0VarArr, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> a(q0<? extends T> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return a(this, q0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> R a(@p.a.t0.f l0<T, ? extends R> l0Var) {
return (R) ((l0) p.a.y0.b.b.a(l0Var, "converter is null")).apply(this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> k0<R> a(r0<? super T, ? extends R> r0Var) {
return h(((r0) p.a.y0.b.b.a(r0Var, "transformer is null")).apply(this));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <U> k0<U> a(Class<? extends U> cls) {
p.a.y0.b.b.a(cls, "clazz is null");
return (k0<U>) i(p.a.y0.b.a.a((Class) cls));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final k0<T> a(long j2, TimeUnit timeUnit) {
return a(j2, timeUnit, p.a.e1.b.a(), false);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final k0<T> a(long j2, TimeUnit timeUnit, boolean z2) {
return a(j2, timeUnit, p.a.e1.b.a(), z2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final k0<T> 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 k0<T> 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.g.f(this, j2, timeUnit, j0Var, z2));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> a(i iVar) {
p.a.y0.b.b.a(iVar, "other is null");
return p.a.c1.a.a(new p.a.y0.e.g.g(this, iVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <U> k0<T> a(g0<U> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return p.a.c1.a.a(new p.a.y0.e.g.h(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 <U> k0<T> a(x.g.c<U> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return p.a.c1.a.a(new p.a.y0.e.g.i(this, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.e
@p.a.t0.d
public final <R> s<R> a(p.a.x0.o<? super T, a0<R>> oVar) {
p.a.y0.b.b.a(oVar, "selector is null");
return p.a.c1.a.a(new p.a.y0.e.g.k(this, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> a(p.a.x0.g<? super T> gVar) {
p.a.y0.b.b.a(gVar, "onAfterSuccess is null");
return p.a.c1.a.a(new p.a.y0.e.g.m(this, gVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> a(p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onAfterTerminate is null");
return p.a.c1.a.a(new p.a.y0.e.g.n(this, aVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> a(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new p.a.y0.e.c.z(this, rVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <R> k0<R> a(p0<? extends R, ? super T> p0Var) {
p.a.y0.b.b.a(p0Var, "lift is null");
return p.a.c1.a.a(new p.a.y0.e.g.j0(this, p0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Boolean> a(Object obj) {
return a(obj, p.a.y0.b.b.a());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Boolean> a(Object obj, p.a.x0.d<Object, Object> dVar) {
p.a.y0.b.b.a(obj, "value is null");
p.a.y0.b.b.a(dVar, "comparer is null");
return p.a.c1.a.a(new p.a.y0.e.g.c(this, obj, dVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final k0<T> a(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new p.a.y0.e.g.n0(this, j0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> a(k0<? extends T> k0Var) {
p.a.y0.b.b.a(k0Var, "resumeSingleInCaseOfError is null");
return j(p.a.y0.b.a.c(k0Var));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(long j2) {
return n().e(j2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(p.a.x0.e eVar) {
return n().a(eVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> a(p.a.x0.d<? super Integer, ? super Throwable> dVar) {
return a((l) n().b(dVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> a(long j2, p.a.x0.r<? super Throwable> rVar) {
return a((l) n().a(j2, rVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c a(p.a.x0.b<? super T, ? super Throwable> bVar) {
p.a.y0.b.b.a(bVar, "onCallback is null");
p.a.y0.d.d dVar = new p.a.y0.d.d(bVar);
a((n0) dVar);
return dVar;
}
@Override
@p.a.t0.h("none")
public final void a(n0<? super T> n0Var) {
p.a.y0.b.b.a(n0Var, "observer is null");
n0<? super T> a = p.a.c1.a.a(this, n0Var);
p.a.y0.b.b.a(a, "The RxJavaPlugins.onSubscribe hook returned a null SingleObserver. Please check the handler provided to RxJavaPlugins.setOnSingleSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
try {
c((n0) a);
} catch (NullPointerException e2) {
throw e2;
} catch (Throwable th) {
p.a.v0.b.b(th);
NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final k0<T> a(long j2, TimeUnit timeUnit, j0 j0Var, q0<? extends T> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return b(j2, timeUnit, j0Var, q0Var);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final k0<T> a(long j2, TimeUnit timeUnit, q0<? extends T> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return b(j2, timeUnit, p.a.e1.b.a(), q0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> k0<R> a(q0<U> q0Var, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
return a(this, q0Var, cVar);
}
public static <T> k0<T> a(l<T> lVar) {
return p.a.c1.a.a(new r3(lVar, null));
}
}