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

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

package p.a;

import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import p.a.y0.e.c.a1;
import p.a.y0.e.c.b1;
import p.a.y0.e.c.c1;
import p.a.y0.e.c.d1;
import p.a.y0.e.c.e1;
import p.a.y0.e.c.f1;
import p.a.y0.e.c.g1;
import p.a.y0.e.c.h1;
import p.a.y0.e.c.i1;
import p.a.y0.e.c.j1;
import p.a.y0.e.c.k1;
import p.a.y0.e.c.l1;
import p.a.y0.e.c.m1;
import p.a.y0.e.c.n1;
import p.a.y0.e.c.o1;
import p.a.y0.e.c.p1;
import p.a.y0.e.c.q1;
import p.a.y0.e.c.r1;
import p.a.y0.e.c.s0;
import p.a.y0.e.c.s1;
import p.a.y0.e.c.t0;
import p.a.y0.e.c.t1;
import p.a.y0.e.c.u0;
import p.a.y0.e.c.u1;
import p.a.y0.e.c.v0;
import p.a.y0.e.c.w0;
import p.a.y0.e.c.x0;
import p.a.y0.e.c.y0;
import p.a.y0.e.c.z0;
public abstract class s<T> implements y<T> {
    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> a(Iterable<? extends y<? extends T>> iterable) {
        p.a.y0.b.b.a(iterable, "sources is null");
        return p.a.c1.a.a(new p.a.y0.e.c.b(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 y<? extends T>> iterable) {
        p.a.y0.b.b.a(iterable, "sources is null");
        return p.a.c1.a.a(new p.a.y0.e.c.g(iterable));
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> c(y<? extends T>... yVarArr) {
        if (yVarArr.length == 0) {
            return l.R();
        }
        if (yVarArr.length == 1) {
            return p.a.c1.a.a(new m1(yVarArr[0]));
        }
        return p.a.c1.a.a(new p.a.y0.e.c.f(yVarArr));
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> d(y<? extends T>... yVarArr) {
        return l.b((Object[]) yVarArr).e(o1.instance());
    }

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

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> f(x.g.c<? extends y<? extends T>> cVar) {
        return l.q(cVar).d(o1.instance());
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> g(x.g.c<? extends y<? extends T>> cVar) {
        return l.q(cVar).e(o1.instance());
    }

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

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> j(y<T> yVar) {
        if (!(yVar instanceof s)) {
            p.a.y0.b.b.a(yVar, "onSubscribe is null");
            return p.a.c1.a.a(new q1(yVar));
        }
        throw new IllegalArgumentException("unsafeCreate(Maybe) should be upgraded");
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> k(y<T> yVar) {
        if (yVar instanceof s) {
            return p.a.c1.a.a((s) yVar);
        }
        p.a.y0.b.b.a(yVar, "onSubscribe is null");
        return p.a.c1.a.a(new q1(yVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> r() {
        return p.a.c1.a.a((s) p.a.y0.e.c.u.a);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> s() {
        return p.a.c1.a.a(y0.a);
    }

    public abstract void c(v<? super T> vVar);

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> l(p.a.x0.o<? super Throwable, ? extends T> oVar) {
        p.a.y0.b.b.a(oVar, "valueSupplier is null");
        return p.a.c1.a.a(new c1(this, oVar));
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public final l<T> m() {
        return a(Long.MAX_VALUE);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> n() {
        return a(Long.MAX_VALUE, p.a.y0.b.a.b());
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> R o(p.a.x0.o<? super s<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 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 n1(this));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final k0<T> q() {
        return p.a.c1.a.a(new p1(this, null));
    }

    @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.y0.b.a.c);
    }

    @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((v) nVar);
        return nVar;
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> d(Iterable<? extends y<? extends T>> iterable) {
        return l.f((Iterable) iterable).e(o1.instance());
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> e(Iterable<? extends y<? extends T>> iterable) {
        return h(l.f((Iterable) iterable));
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> s<R> g(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.c.g0(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 final <U> l<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.c.c0(this, oVar));
    }

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

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

    @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.y0.b.a.c);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> a(y<? extends T>... yVarArr) {
        if (yVarArr.length == 0) {
            return r();
        }
        if (yVarArr.length == 1) {
            return k(yVarArr[0]);
        }
        return p.a.c1.a.a(new p.a.y0.e.c.b(yVarArr, 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> b(y<? extends T> yVar, y<? extends T> yVar2) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        return b(yVar, yVar2);
    }

    @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(y<? extends T> yVar, y<? extends T> yVar2) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        return f(yVar, yVar2);
    }

    @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(y<? extends T>... yVarArr) {
        p.a.y0.b.b.a(yVarArr, "sources is null");
        if (yVarArr.length == 0) {
            return l.R();
        }
        if (yVarArr.length == 1) {
            return p.a.c1.a.a(new m1(yVarArr[0]));
        }
        return p.a.c1.a.a(new x0(yVarArr));
    }

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

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

    @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) {
        return subscribe(gVar, gVar2, p.a.y0.b.a.c);
    }

    @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((v) nVar);
        return nVar;
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> f(T t2) {
        p.a.y0.b.b.a((Object) t2, "item is null");
        return p.a.c1.a.a((s) new t0(t2));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> g() {
        return p.a.c1.a.a(new p.a.y0.e.c.o0(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.c.q0(this));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <U> b0<U> i(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.c.d0(this, oVar));
    }

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

    @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.x0.a aVar) {
        p.a.y0.b.b.a(gVar, "onSuccess is null");
        p.a.y0.b.b.a(gVar2, "onError is null");
        p.a.y0.b.b.a(aVar, "onComplete is null");
        return (p.a.u0.c) b((s<T>) new p.a.y0.e.c.d(gVar, gVar2, aVar));
    }

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

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> s<R> j(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 v0(this, oVar));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> k() {
        return b(p.a.y0.b.a.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> b(y<? extends T>... yVarArr) {
        p.a.y0.b.b.a(yVarArr, "sources is null");
        if (yVarArr.length == 0) {
            return l.R();
        }
        if (yVarArr.length == 1) {
            return p.a.c1.a.a(new m1(yVarArr[0]));
        }
        return p.a.c1.a.a(new p.a.y0.e.c.e(yVarArr));
    }

    @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 y<? extends T>> iterable) {
        p.a.y0.b.b.a(iterable, "sources is null");
        return l.f((Iterable) iterable).d(o1.instance());
    }

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public static s<Long> d(long j2, TimeUnit timeUnit) {
        return d(j2, timeUnit, p.a.e1.b.a());
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> f(y<? extends T>... yVarArr) {
        if (yVarArr.length == 0) {
            return l.R();
        }
        return l.b((Object[]) yVarArr).d(o1.instance(), true, yVarArr.length);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final k0<Boolean> i() {
        return p.a.c1.a.a(new s0(this));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> k(p.a.x0.o<? super Throwable, ? extends y<? extends T>> oVar) {
        p.a.y0.b.b.a(oVar, "resumeFunction is null");
        return p.a.c1.a.a(new b1(this, oVar, true));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public static s<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 l1(Math.max(0L, j2), timeUnit, j0Var));
    }

    @p.a.t0.e
    @p.a.t0.d
    @p.a.t0.h("none")
    public final k0<a0<T>> j() {
        return p.a.c1.a.a(new w0(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(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        return b(yVar, yVar2, yVar3);
    }

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> k0<Boolean> e(y<? extends T> yVar, y<? extends T> yVar2) {
        return a(yVar, yVar2, p.a.y0.b.b.a());
    }

    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> l<T> f(Iterable<? extends y<? extends T>> iterable) {
        return l.f((Iterable) iterable).e(o1.instance(), true);
    }

    @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(y<? extends T> yVar, y<? extends T> yVar2) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        return e(yVar, yVar2);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> d(p.a.x0.a aVar) {
        p.a.x0.g d = p.a.y0.b.a.d();
        p.a.x0.g d2 = p.a.y0.b.a.d();
        p.a.x0.g d3 = p.a.y0.b.a.d();
        p.a.x0.a aVar2 = p.a.y0.b.a.c;
        return p.a.c1.a.a(new d1(this, d, d2, d3, aVar2, aVar2, (p.a.x0.a) p.a.y0.b.b.a(aVar, "onDispose is null")));
    }

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

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

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.e
    @p.a.t0.d
    public final s<T> e(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.c.t(this, aVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> k0<R> f(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.c.f0(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> a(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3, y<? extends T> yVar4) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        return b(yVar, yVar2, yVar3, yVar4);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<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.c.x(callable));
    }

    @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 y<? extends T>> cVar, int i2) {
        p.a.y0.b.b.a(cVar, "source is null");
        p.a.y0.b.b.a(i2, "maxConcurrency");
        return p.a.c1.a.a(new p.a.y0.e.b.d1(cVar, o1.instance(), true, i2, 1));
    }

    @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> e(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.d.k(this, oVar));
    }

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

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

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

    @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(x.g.c<? extends y<? extends T>> cVar, int i2) {
        p.a.y0.b.b.a(cVar, "source is null");
        p.a.y0.b.b.a(i2, "maxConcurrency");
        return p.a.c1.a.a(new p.a.y0.e.b.d1(cVar, o1.instance(), false, i2, 1));
    }

    @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(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        return f(yVar, yVar2, yVar3);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> d(p.a.x0.g<? super T> gVar) {
        p.a.x0.g d = p.a.y0.b.a.d();
        p.a.x0.a aVar = p.a.y0.b.a.c;
        return p.a.c1.a.a(new d1(this, p.a.y0.b.a.d(), (p.a.x0.g) p.a.y0.b.b.a(gVar, "onSuccess is null"), d, aVar, aVar, 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(x.g.c<? extends y<? 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, o1.instance(), i2, p.a.y0.j.j.IMMEDIATE));
    }

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

    @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(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        return e(yVar, yVar2, yVar3);
    }

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

    @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(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3, y<? extends T> yVar4) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        return f(yVar, yVar2, yVar3, yVar4);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> b0<R> d(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.j(this, oVar));
    }

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

    @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(y<? extends T> yVar, y<? extends T> yVar2, y<? extends T> yVar3, y<? extends T> yVar4) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        return e(yVar, yVar2, yVar3, yVar4);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> d(y<? extends T> yVar) {
        p.a.y0.b.b.a(yVar, "next is null");
        return k(p.a.y0.b.a.c(yVar));
    }

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public final T c() {
        p.a.y0.d.h hVar = new p.a.y0.d.h();
        a((v) hVar);
        return (T) hVar.b();
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> d(T t2) {
        p.a.y0.b.b.a((Object) t2, "item is null");
        return l(p.a.y0.b.a.c(t2));
    }

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

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
    @p.a.t0.d
    public final <U> s<T> d(x.g.c<U> cVar) {
        p.a.y0.b.b.a(cVar, "timeoutIndicator is null");
        return p.a.c1.a.a(new k1(this, cVar, null));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> a(Future<? extends T> future) {
        p.a.y0.b.b.a(future, "future is null");
        return p.a.c1.a.a(new p.a.y0.e.c.l0(future, 0L, null));
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.FULL)
    @p.a.t0.d
    public final l<T> b(y<? extends T> yVar) {
        p.a.y0.b.b.a(yVar, "other is null");
        return b(this, yVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> c(T t2) {
        p.a.y0.b.b.a((Object) t2, "defaultItem is null");
        return f((y) f(t2));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T> s<T> a(Future<? extends T> future, long j2, TimeUnit timeUnit) {
        p.a.y0.b.b.a(future, "future is null");
        p.a.y0.b.b.a(timeUnit, "unit is null");
        return p.a.c1.a.a(new p.a.y0.e.c.l0(future, j2, timeUnit));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final k0<Boolean> b(Object obj) {
        p.a.y0.b.b.a(obj, "item is null");
        return p.a.c1.a.a(new p.a.y0.e.c.h(this, obj));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> c(p.a.x0.a aVar) {
        p.a.x0.a aVar2 = p.a.y0.b.a.c;
        return p.a.c1.a.a(new d1(this, p.a.y0.b.a.d(), p.a.y0.b.a.d(), p.a.y0.b.a.d(), (p.a.x0.a) p.a.y0.b.b.a(aVar, "onComplete is null"), aVar2, aVar2));
    }

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

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

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public final s<T> b(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> k0<Boolean> a(y<? extends T> yVar, y<? extends T> yVar2, p.a.x0.d<? super T, ? super T> dVar) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(dVar, "isEqual is null");
        return p.a.c1.a.a(new p.a.y0.e.c.v(yVar, yVar2, dVar));
    }

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final s<T> b(long j2, TimeUnit timeUnit, j0 j0Var) {
        return b((x.g.c) l.r(j2, timeUnit, j0Var));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<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.c.r(this, aVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> c(p.a.x0.g<? super p.a.u0.c> gVar) {
        p.a.x0.g d = p.a.y0.b.a.d();
        p.a.x0.g d2 = p.a.y0.b.a.d();
        p.a.x0.a aVar = p.a.y0.b.a.c;
        return p.a.c1.a.a(new d1(this, (p.a.x0.g) p.a.y0.b.b.a(gVar, "onSubscribe is null"), d, d2, aVar, aVar, aVar));
    }

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T, D> s<T> a(Callable<? extends D> callable, p.a.x0.o<? super D, ? extends y<? extends T>> oVar, p.a.x0.g<? super D> 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 <T, D> s<T> a(Callable<? extends D> callable, p.a.x0.o<? super D, ? extends y<? extends T>> oVar, p.a.x0.g<? super D> gVar, boolean z2) {
        p.a.y0.b.b.a(callable, "resourceSupplier is null");
        p.a.y0.b.b.a(oVar, "sourceSupplier is null");
        p.a.y0.b.b.a(gVar, "disposer is null");
        return p.a.c1.a.a(new s1(callable, oVar, gVar, z2));
    }

    @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.c.b0(this, oVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> s<R> b(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.c.h0(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 final l<T> c(y<? extends T> yVar) {
        p.a.y0.b.b.a(yVar, "other is null");
        return c(this, yVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T, R> s<R> a(Iterable<? extends y<? 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 u1(iterable, oVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <U> s<U> b(Class<U> cls) {
        p.a.y0.b.b.a(cls, "clazz is null");
        return a((p.a.x0.r) p.a.y0.b.a.b((Class) cls)).a((Class) cls);
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> c(p.a.x0.r<? super Throwable> rVar) {
        return a(Long.MAX_VALUE, rVar);
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
    @p.a.t0.d
    public final <U> s<T> c(x.g.c<U> cVar) {
        p.a.y0.b.b.a(cVar, "other is null");
        return p.a.c1.a.a(new i1(this, cVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T1, T2, R> s<R> a(y<? extends T1> yVar, y<? extends T2> yVar2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        return a(p.a.y0.b.a.a((p.a.x0.c) cVar), yVar, yVar2);
    }

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

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> b(long j2) {
        return a(j2, p.a.y0.b.a.b());
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T1, T2, T3, R> s<R> a(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, p.a.x0.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        return a(p.a.y0.b.a.a((p.a.x0.h) hVar), yVar, yVar2, yVar3);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> b(p.a.x0.e eVar) {
        p.a.y0.b.b.a(eVar, "stop is null");
        return a(Long.MAX_VALUE, p.a.y0.b.a.a(eVar));
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final s<T> b(j0 j0Var) {
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new e1(this, j0Var));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T1, T2, T3, T4, R> s<R> a(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, p.a.x0.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        return a(p.a.y0.b.a.a((p.a.x0.i) iVar), yVar, yVar2, yVar3, yVar4);
    }

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

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T1, T2, T3, T4, T5, R> s<R> a(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, y<? extends T5> yVar5, p.a.x0.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
        p.a.y0.b.b.a(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        p.a.y0.b.b.a(yVar5, "source5 is null");
        return a(p.a.y0.b.a.a((p.a.x0.j) jVar), yVar, yVar2, yVar3, yVar4, yVar5);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T1, T2, T3, T4, T5, T6, R> s<R> a(y<? extends T1> yVar, y<? extends T2> yVar2, y<? extends T3> yVar3, y<? extends T4> yVar4, y<? extends T5> yVar5, y<? extends T6> yVar6, 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(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        p.a.y0.b.b.a(yVar5, "source5 is null");
        p.a.y0.b.b.a(yVar6, "source6 is null");
        return a(p.a.y0.b.a.a((p.a.x0.k) kVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T1, T2, T3, T4, T5, T6, T7, R> s<R> a(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, 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(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        p.a.y0.b.b.a(yVar5, "source5 is null");
        p.a.y0.b.b.a(yVar6, "source6 is null");
        p.a.y0.b.b.a(yVar7, "source7 is null");
        return a(p.a.y0.b.a.a((p.a.x0.l) lVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6, yVar7);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T1, T2, T3, T4, T5, T6, T7, T8, R> s<R> a(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, 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(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        p.a.y0.b.b.a(yVar5, "source5 is null");
        p.a.y0.b.b.a(yVar6, "source6 is null");
        p.a.y0.b.b.a(yVar7, "source7 is null");
        p.a.y0.b.b.a(yVar8, "source8 is null");
        return a(p.a.y0.b.a.a((p.a.x0.m) mVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6, yVar7, yVar8);
    }

    @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> s<R> a(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, 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(yVar, "source1 is null");
        p.a.y0.b.b.a(yVar2, "source2 is null");
        p.a.y0.b.b.a(yVar3, "source3 is null");
        p.a.y0.b.b.a(yVar4, "source4 is null");
        p.a.y0.b.b.a(yVar5, "source5 is null");
        p.a.y0.b.b.a(yVar6, "source6 is null");
        p.a.y0.b.b.a(yVar7, "source7 is null");
        p.a.y0.b.b.a(yVar8, "source8 is null");
        p.a.y0.b.b.a(yVar9, "source9 is null");
        return a(p.a.y0.b.a.a((p.a.x0.n) nVar), yVar, yVar2, yVar3, yVar4, yVar5, yVar6, yVar7, yVar8, yVar9);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public static <T, R> s<R> a(p.a.x0.o<? super Object[], ? extends R> oVar, y<? extends T>... yVarArr) {
        p.a.y0.b.b.a(yVarArr, "sources is null");
        if (yVarArr.length == 0) {
            return r();
        }
        p.a.y0.b.b.a(oVar, "zipper is null");
        return p.a.c1.a.a(new t1(yVarArr, oVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> a(y<? extends T> yVar) {
        p.a.y0.b.b.a(yVar, "other is null");
        return a(this, yVar);
    }

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

    @p.a.t0.d
    @p.a.t0.h("none")
    public final T a(T t2) {
        p.a.y0.b.b.a((Object) t2, "defaultValue is null");
        p.a.y0.d.h hVar = new p.a.y0.d.h();
        a((v) hVar);
        return (T) hVar.a(t2);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <U> s<U> a(Class<? extends U> cls) {
        p.a.y0.b.b.a(cls, "clazz is null");
        return (s<U>) j(p.a.y0.b.a.a((Class) cls));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> s<R> a(z<? super T, ? extends R> zVar) {
        return k(((z) p.a.y0.b.b.a(zVar, "transformer is null")).apply(this));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> s<R> a(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.c.h0(this, oVar));
    }

    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public final s<T> a(long j2, TimeUnit timeUnit) {
        return a(j2, timeUnit, p.a.e1.b.a());
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final s<T> a(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.c.l(this, Math.max(0L, j2), timeUnit, j0Var));
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
    @p.a.t0.d
    public final <U, V> s<T> a(x.g.c<U> cVar) {
        p.a.y0.b.b.a(cVar, "delayIndicator is null");
        return p.a.c1.a.a(new p.a.y0.e.c.m(this, cVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<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.c.q(this, gVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> a(p.a.x0.a aVar) {
        return p.a.c1.a.a(new d1(this, p.a.y0.b.a.d(), p.a.y0.b.a.d(), p.a.y0.b.a.d(), p.a.y0.b.a.c, (p.a.x0.a) p.a.y0.b.b.a(aVar, "onAfterTerminate is null"), p.a.y0.b.a.c));
    }

    @p.a.t0.d
    @p.a.t0.h("none")
    public final s<T> a(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.c.s(this, bVar));
    }

    @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.y(this, rVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> s<R> a(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, p.a.x0.o<? super Throwable, ? extends y<? extends R>> oVar2, Callable<? extends y<? extends R>> callable) {
        p.a.y0.b.b.a(oVar, "onSuccessMapper is null");
        p.a.y0.b.b.a(oVar2, "onErrorMapper is null");
        p.a.y0.b.b.a(callable, "onCompleteSupplier is null");
        return p.a.c1.a.a(new p.a.y0.e.c.e0(this, oVar, oVar2, callable));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <U, R> s<R> a(p.a.x0.o<? super T, ? extends y<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
        p.a.y0.b.b.a(oVar, "mapper is null");
        p.a.y0.b.b.a(cVar, "resultSelector is null");
        return p.a.c1.a.a(new p.a.y0.e.c.a0(this, oVar, cVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <R> s<R> a(x<? extends R, ? super T> xVar) {
        p.a.y0.b.b.a(xVar, "lift is null");
        return p.a.c1.a.a(new u0(this, xVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final s<T> a(j0 j0Var) {
        p.a.y0.b.b.a(j0Var, "scheduler is null");
        return p.a.c1.a.a(new z0(this, j0Var));
    }

    @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 o().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 o().a(eVar);
    }

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

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

    @Override
    @p.a.t0.h("none")
    public final void a(v<? super T> vVar) {
        p.a.y0.b.b.a(vVar, "observer is null");
        v<? super T> a = p.a.c1.a.a(this, vVar);
        p.a.y0.b.b.a(a, "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 {
            c((v) 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("none")
    public final k0<T> a(q0<? extends T> q0Var) {
        p.a.y0.b.b.a(q0Var, "other is null");
        return p.a.c1.a.a(new g1(this, q0Var));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.L0)
    public final s<T> a(long j2, TimeUnit timeUnit, y<? extends T> yVar) {
        p.a.y0.b.b.a(yVar, "fallback is null");
        return a(j2, timeUnit, p.a.e1.b.a(), yVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h(p.a.t0.h.K0)
    public final s<T> a(long j2, TimeUnit timeUnit, j0 j0Var, y<? extends T> yVar) {
        p.a.y0.b.b.a(yVar, "fallback is null");
        return a(d(j2, timeUnit, j0Var), yVar);
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <U> s<T> a(y<U> yVar, y<? extends T> yVar2) {
        p.a.y0.b.b.a(yVar, "timeoutIndicator is null");
        p.a.y0.b.b.a(yVar2, "fallback is null");
        return p.a.c1.a.a(new j1(this, yVar, yVar2));
    }

    @p.a.t0.f
    @p.a.t0.h("none")
    @p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
    @p.a.t0.d
    public final <U> s<T> a(x.g.c<U> cVar, y<? extends T> yVar) {
        p.a.y0.b.b.a(cVar, "timeoutIndicator is null");
        p.a.y0.b.b.a(yVar, "fallback is null");
        return p.a.c1.a.a(new k1(this, cVar, yVar));
    }

    @p.a.t0.f
    @p.a.t0.d
    @p.a.t0.h("none")
    public final <U, R> s<R> a(y<? extends U> yVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
        p.a.y0.b.b.a(yVar, "other is null");
        return a(this, yVar, cVar);
    }
}