Sunbit v2.4.4版本的 MD5 值为：a5021e5e2a58eb1d6741b432fe7533c4

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

package h.a.a.c;

import java.util.Objects;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
public abstract class j implements p {
    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @SafeVarargs
    public static j a(@h.a.a.b.f p... pVarArr) {
        Objects.requireNonNull(pVarArr, "sources is null");
        if (pVarArr.length == 0) {
            return s();
        }
        if (pVarArr.length == 1) {
            return i(pVarArr[0]);
        }
        return h.a.a.l.a.a(new h.a.a.h.f.a.a(pVarArr, null));
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @SafeVarargs
    public static j b(@h.a.a.b.f p... pVarArr) {
        Objects.requireNonNull(pVarArr, "sources is null");
        if (pVarArr.length == 0) {
            return s();
        }
        if (pVarArr.length == 1) {
            return i(pVarArr[0]);
        }
        return h.a.a.l.a.a(new h.a.a.h.f.a.e(pVarArr));
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @SafeVarargs
    public static j c(@h.a.a.b.f p... pVarArr) {
        return s.b((Object[]) pVarArr).a(h.a.a.h.b.a.e(), true, 2);
    }

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

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
    public static <T> j e(@h.a.a.b.f q.i.c<T> cVar) {
        Objects.requireNonNull(cVar, "publisher is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.t(cVar));
    }

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

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

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j h(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "onSubscribe is null");
        if (!(pVar instanceof j)) {
            return h.a.a.l.a.a(new h.a.a.h.f.a.x(pVar));
        }
        throw new IllegalArgumentException("Use of unsafeCreate(Completable)!");
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
    public static j i(@h.a.a.b.f q.i.c<? extends p> cVar) {
        Objects.requireNonNull(cVar, "sources is null");
        return h.a.a.l.a.a(new h.a.a.h.f.d.i(cVar, h.a.a.h.b.a.e(), true));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j s() {
        return h.a.a.l.a.a(h.a.a.h.f.a.n.f13435a);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j t() {
        return h.a.a.l.a.a(h.a.a.h.f.a.g0.f13409a);
    }

    protected abstract void d(@h.a.a.b.f m mVar);

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j j() {
        return h.a.a.l.a.a(new h.a.a.h.f.a.j(this));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j k() {
        return e(o().D());
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j l() {
        return e(o().F());
    }

    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final h.a.a.d.f m() {
        h.a.a.h.e.p pVar = new h.a.a.h.e.p();
        a((m) pVar);
        return pVar;
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final h.a.a.j.n<Void> n() {
        h.a.a.j.n<Void> nVar = new h.a.a.j.n<>();
        a((m) nVar);
        return nVar;
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    public final <T> s<T> o() {
        if (this instanceof h.a.a.h.c.d) {
            return ((h.a.a.h.c.d) this).c();
        }
        return h.a.a.l.a.a(new h.a.a.h.f.a.q0(this));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final Future<Void> p() {
        return (Future) e((j) new h.a.a.h.e.r());
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> z<T> q() {
        if (this instanceof h.a.a.h.c.e) {
            return ((h.a.a.h.c.e) this).b();
        }
        return h.a.a.l.a.a(new h.a.a.h.f.c.l0(this));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> i0<T> r() {
        if (this instanceof h.a.a.h.c.f) {
            return ((h.a.a.h.c.f) this).a();
        }
        return h.a.a.l.a.a(new h.a.a.h.f.a.r0(this));
    }

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

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j d(@h.a.a.b.f h.a.a.g.s<?> sVar) {
        Objects.requireNonNull(sVar, "supplier is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.w(sVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j f() {
        return h.a.a.l.a.a(new h.a.a.h.f.a.c(this));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j g() {
        return h.a.a.l.a.a(new h.a.a.h.f.a.y(this));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j c(@h.a.a.b.f Iterable<? extends p> iterable) {
        return s.g((Iterable) iterable).c(h.a.a.h.b.a.e());
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @SafeVarargs
    public static j e(@h.a.a.b.f p... pVarArr) {
        Objects.requireNonNull(pVarArr, "sources is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.d0(pVarArr));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j i(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "source is null");
        if (pVar instanceof j) {
            return h.a.a.l.a.a((j) pVar);
        }
        return h.a.a.l.a.a(new h.a.a.h.f.a.x(pVar));
    }

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

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final h.a.a.d.f g(@h.a.a.b.f h.a.a.g.a aVar) {
        Objects.requireNonNull(aVar, "onComplete is null");
        h.a.a.h.e.k kVar = new h.a.a.h.e.k(aVar);
        a((m) kVar);
        return kVar;
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j c(@h.a.a.b.f h.a.a.g.s<? extends Throwable> sVar) {
        Objects.requireNonNull(sVar, "supplier is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.p(sVar));
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @SafeVarargs
    public static j d(@h.a.a.b.f p... pVarArr) {
        Objects.requireNonNull(pVarArr, "sources is null");
        if (pVarArr.length == 0) {
            return s();
        }
        if (pVarArr.length == 1) {
            return i(pVarArr[0]);
        }
        return h.a.a.l.a.a(new h.a.a.h.f.a.c0(pVarArr));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j f(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "other is null");
        return b(pVar, this);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j e(@h.a.a.b.f Iterable<? extends p> iterable) {
        Objects.requireNonNull(iterable, "sources is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.e0(iterable));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j h(@h.a.a.b.f h.a.a.g.a aVar) {
        Objects.requireNonNull(aVar, "action is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.q(aVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static <T> j c(@h.a.a.b.f f0<T> f0Var) {
        Objects.requireNonNull(f0Var, "maybe is null");
        return h.a.a.l.a.a(new h.a.a.h.f.c.s0(f0Var));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j g(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "other is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.n0(this, pVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j a(@h.a.a.b.f Iterable<? extends p> iterable) {
        Objects.requireNonNull(iterable, "sources is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.a(null, iterable));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j b(@h.a.a.b.f Iterable<? extends p> iterable) {
        Objects.requireNonNull(iterable, "sources is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.f(iterable));
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13216f)
    @h.a.a.b.f
    public static j e(long j2, @h.a.a.b.f TimeUnit timeUnit) {
        return d(j2, timeUnit, h.a.a.n.b.a());
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
    public static j h(@h.a.a.b.f q.i.c<? extends p> cVar) {
        Objects.requireNonNull(cVar, "sources is null");
        return h.a.a.l.a.a(new h.a.a.h.f.d.i(cVar, h.a.a.h.b.a.e(), false));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j i() {
        return a(h.a.a.h.b.a.b());
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static <T> j c(@h.a.a.b.f n0<T> n0Var) {
        Objects.requireNonNull(n0Var, "observable is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.s(n0Var));
    }

    @h.a.a.b.h("none")
    public final void e() {
        a(h.a.a.h.b.a.c, h.a.a.h.b.a.f13256e);
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    public static j a(@h.a.a.b.f q.i.c<? extends p> cVar, int i2) {
        Objects.requireNonNull(cVar, "sources is null");
        h.a.a.h.b.b.a(i2, "prefetch");
        return h.a.a.l.a.a(new h.a.a.h.f.a.d(cVar, i2));
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    public static j b(@h.a.a.b.f q.i.c<? extends p> cVar, int i2) {
        return s.q(cVar).a(h.a.a.h.b.a.e(), true, i2);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j e(@h.a.a.b.f h.a.a.g.a aVar) {
        h.a.a.g.g<? super h.a.a.d.f> d2 = h.a.a.h.b.a.d();
        h.a.a.g.g<? super Throwable> d3 = h.a.a.h.b.a.d();
        h.a.a.g.a aVar2 = h.a.a.h.b.a.c;
        return a(d2, d3, aVar2, aVar2, aVar2, aVar);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> r0<h0<T>> h() {
        return h.a.a.l.a.a(new h.a.a.h.f.a.a0(this));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j b(@h.a.a.b.f h.a.a.g.s<? extends p> sVar) {
        Objects.requireNonNull(sVar, "supplier is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.h(sVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static <T> j c(@h.a.a.b.f x0<T> x0Var) {
        Objects.requireNonNull(x0Var, "single is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.v(x0Var));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j d(@h.a.a.b.f Iterable<? extends p> iterable) {
        Objects.requireNonNull(iterable, "sources is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.f0(iterable));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j e(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "fallback is null");
        return a(h.a.a.h.b.a.c(pVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j a(@h.a.a.b.f n nVar) {
        Objects.requireNonNull(nVar, "source is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.g(nVar));
    }

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

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

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

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

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public static j d(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(q0Var, "scheduler is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.p0(j2, timeUnit, q0Var));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j c(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "other is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.b(this, pVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static r0<Boolean> a(@h.a.a.b.f p pVar, @h.a.a.b.f p pVar2) {
        Objects.requireNonNull(pVar, "source1 is null");
        Objects.requireNonNull(pVar2, "source2 is null");
        return e(pVar, pVar2).a((x0) r0.c(true));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j b(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "next is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.b(this, pVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13216f)
    @h.a.a.b.f
    public final j c(long j2, @h.a.a.b.f TimeUnit timeUnit) {
        return b(j2, timeUnit, h.a.a.n.b.a());
    }

    @h.a.a.b.h("none")
    public final void b(@h.a.a.b.f m mVar) {
        Objects.requireNonNull(mVar, "observer is null");
        h.a.a.h.e.f fVar = new h.a.a.h.e.f();
        mVar.onSubscribe(fVar);
        a((m) fVar);
        fVar.a(mVar);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j c(@h.a.a.b.f h.a.a.g.g<? super h.a.a.d.f> gVar) {
        h.a.a.g.g<? super Throwable> d2 = h.a.a.h.b.a.d();
        h.a.a.g.a aVar = h.a.a.h.b.a.c;
        return a(gVar, d2, aVar, aVar, aVar, aVar);
    }

    @h.a.a.b.h("none")
    public final void d() {
        h.a.a.h.e.i iVar = new h.a.a.h.e.i();
        a((m) iVar);
        iVar.a();
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j a(@h.a.a.b.f Throwable th) {
        Objects.requireNonNull(th, "throwable is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.o(th));
    }

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

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j a(@h.a.a.b.f Callable<?> callable) {
        Objects.requireNonNull(callable, "callable is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.r(callable));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j c(@h.a.a.b.f h.a.a.g.o<? super s<Object>, ? extends q.i.c<?>> oVar) {
        return e(o().C(oVar));
    }

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

    @h.a.a.b.h("none")
    public final void c(@h.a.a.b.f m mVar) {
        Objects.requireNonNull(mVar, "observer is null");
        a((m) new h.a.a.h.e.b0(mVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j d(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "other is null");
        return d(this, pVar);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j a(@h.a.a.b.f Future<?> future) {
        Objects.requireNonNull(future, "future is null");
        return h(h.a.a.h.b.a.a(future));
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13216f)
    @h.a.a.b.f
    public final j b(long j2, @h.a.a.b.f TimeUnit timeUnit) {
        return a(j2, timeUnit, h.a.a.n.b.a(), false);
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j b(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
        return d(j2, timeUnit, q0Var).b((p) this);
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j c(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
        return b(j2, timeUnit, q0Var, null);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j d(@h.a.a.b.f h.a.a.g.o<? super s<Throwable>, ? extends q.i.c<?>> oVar) {
        return e(o().E(oVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j a(@h.a.a.b.f Runnable runnable) {
        Objects.requireNonNull(runnable, "run is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.u(runnable));
    }

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

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> r0<T> c(T t) {
        Objects.requireNonNull(t, "completionValue is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.s0(this, null, t));
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13216f)
    @h.a.a.b.f
    public final j d(long j2, @h.a.a.b.f TimeUnit timeUnit) {
        return b(j2, timeUnit, h.a.a.n.b.a(), null);
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    private static j a(@h.a.a.b.f q.i.c<? extends p> cVar, int i2, boolean z) {
        Objects.requireNonNull(cVar, "sources is null");
        h.a.a.h.b.b.a(i2, "maxConcurrency");
        return h.a.a.l.a.a(new h.a.a.h.f.a.b0(cVar, i2, z));
    }

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

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j c(@h.a.a.b.f q0 q0Var) {
        Objects.requireNonNull(q0Var, "scheduler is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.k(this, q0Var));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static <R> j a(@h.a.a.b.f h.a.a.g.s<R> sVar, @h.a.a.b.f h.a.a.g.o<? super R, ? extends p> oVar, @h.a.a.b.f h.a.a.g.g<? super R> gVar) {
        return a((h.a.a.g.s) sVar, (h.a.a.g.o) oVar, (h.a.a.g.g) gVar, true);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> z<T> b(@h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends T> oVar) {
        Objects.requireNonNull(oVar, "itemSupplier is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.j0(this, oVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static <R> j a(@h.a.a.b.f h.a.a.g.s<R> sVar, @h.a.a.b.f h.a.a.g.o<? super R, ? extends p> oVar, @h.a.a.b.f h.a.a.g.g<? super R> gVar, boolean z) {
        Objects.requireNonNull(sVar, "resourceSupplier is null");
        Objects.requireNonNull(oVar, "sourceSupplier is null");
        Objects.requireNonNull(gVar, "resourceCleanup is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.t0(sVar, oVar, gVar, z));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j b(long j2) {
        return e(o().d(j2));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j b(@h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
        return e(o().f(rVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j b(@h.a.a.b.f h.a.a.g.e eVar) {
        Objects.requireNonNull(eVar, "stop is null");
        return a(k.c3.w.p0.c, h.a.a.h.b.a.a(eVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "other is null");
        return a(this, pVar);
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    public final <T> s<T> b(@h.a.a.b.f x0<T> x0Var) {
        Objects.requireNonNull(x0Var, "other is null");
        return s.a((q.i.c) r0.j(x0Var).s(), (q.i.c) o());
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> i0<T> a(@h.a.a.b.f n0<T> n0Var) {
        Objects.requireNonNull(n0Var, "next is null");
        return h.a.a.l.a.a(new h.a.a.h.f.d.a(this, n0Var));
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    public final <T> s<T> b(@h.a.a.b.f f0<T> f0Var) {
        Objects.requireNonNull(f0Var, "other is null");
        return s.a((q.i.c) z.k(f0Var).t(), (q.i.c) o());
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    public final <T> s<T> a(@h.a.a.b.f q.i.c<T> cVar) {
        Objects.requireNonNull(cVar, "next is null");
        return h.a.a.l.a.a(new h.a.a.h.f.d.b(this, cVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> i0<T> b(@h.a.a.b.f n0<T> n0Var) {
        Objects.requireNonNull(n0Var, "other is null");
        return i0.wrap(n0Var).concatWith(r());
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> r0<T> a(@h.a.a.b.f x0<T> x0Var) {
        Objects.requireNonNull(x0Var, "next is null");
        return h.a.a.l.a.a(new h.a.a.h.f.g.g(x0Var, this));
    }

    @h.a.a.b.d
    @h.a.a.b.f
    @h.a.a.b.h("none")
    @h.a.a.b.b(h.a.a.b.a.FULL)
    public final <T> s<T> b(@h.a.a.b.f q.i.c<T> cVar) {
        Objects.requireNonNull(cVar, "other is null");
        return o().i((q.i.c) cVar);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> z<T> a(@h.a.a.b.f f0<T> f0Var) {
        Objects.requireNonNull(f0Var, "next is null");
        return h.a.a.l.a.a(new h.a.a.h.f.c.o(f0Var, this));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final h.a.a.d.f b(@h.a.a.b.f h.a.a.g.a aVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
        Objects.requireNonNull(gVar, "onError is null");
        Objects.requireNonNull(aVar, "onComplete is null");
        h.a.a.h.e.k kVar = new h.a.a.h.e.k(gVar, aVar);
        a((m) kVar);
        return kVar;
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    public final boolean a(long j2, @h.a.a.b.f TimeUnit timeUnit) {
        Objects.requireNonNull(timeUnit, "unit is null");
        h.a.a.h.e.i iVar = new h.a.a.h.e.i();
        a((m) iVar);
        return iVar.a(j2, timeUnit);
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j b(@h.a.a.b.f q0 q0Var) {
        Objects.requireNonNull(q0Var, "scheduler is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.m0(this, q0Var));
    }

    @h.a.a.b.h("none")
    public final void a(@h.a.a.b.f h.a.a.g.a aVar) {
        a(aVar, h.a.a.h.b.a.f13256e);
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    private j b(long j2, TimeUnit timeUnit, q0 q0Var, p pVar) {
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(q0Var, "scheduler is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.o0(this, j2, timeUnit, q0Var, pVar));
    }

    @h.a.a.b.h("none")
    public final void a(@h.a.a.b.f h.a.a.g.a aVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
        Objects.requireNonNull(aVar, "onComplete is null");
        Objects.requireNonNull(gVar, "onError is null");
        h.a.a.h.e.i iVar = new h.a.a.h.e.i();
        a((m) iVar);
        iVar.a(h.a.a.h.b.a.d(), gVar, aVar);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> CompletionStage<T> b(@h.a.a.b.g T t) {
        return (CompletionStage) e((j) new h.a.a.h.d.b(true, t));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f q qVar) {
        return i(((q) Objects.requireNonNull(qVar, "transformer is null")).a(this));
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
        return a(j2, timeUnit, q0Var, false);
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(q0Var, "scheduler is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.i(this, j2, timeUnit, q0Var, z));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
        h.a.a.g.g<? super h.a.a.d.f> d2 = h.a.a.h.b.a.d();
        h.a.a.g.a aVar = h.a.a.h.b.a.c;
        return a(d2, gVar, aVar, aVar, aVar, aVar);
    }

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

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    private j a(h.a.a.g.g<? super h.a.a.d.f> gVar, h.a.a.g.g<? super Throwable> gVar2, h.a.a.g.a aVar, h.a.a.g.a aVar2, h.a.a.g.a aVar3, h.a.a.g.a aVar4) {
        Objects.requireNonNull(gVar, "onSubscribe is null");
        Objects.requireNonNull(gVar2, "onError is null");
        Objects.requireNonNull(aVar, "onComplete is null");
        Objects.requireNonNull(aVar2, "onTerminate is null");
        Objects.requireNonNull(aVar3, "onAfterTerminate is null");
        Objects.requireNonNull(aVar4, "onDispose is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.k0(this, gVar, gVar2, aVar, aVar2, aVar3, aVar4));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f o oVar) {
        Objects.requireNonNull(oVar, "onLift is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.z(this, oVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j a(@h.a.a.b.f q0 q0Var) {
        Objects.requireNonNull(q0Var, "scheduler is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.h0(this, q0Var));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
        Objects.requireNonNull(rVar, "predicate is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.i0(this, rVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends p> oVar) {
        Objects.requireNonNull(oVar, "fallbackSupplier is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.l0(this, oVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> z<T> a(@h.a.a.b.f T t) {
        Objects.requireNonNull(t, "item is null");
        return b((h.a.a.g.o) h.a.a.h.b.a.c(t));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(long j2) {
        return e(o().c(j2));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f h.a.a.g.e eVar) {
        return e(o().a(eVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(@h.a.a.b.f h.a.a.g.d<? super Integer, ? super Throwable> dVar) {
        return e(o().b(dVar));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final j a(long j2, @h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
        return e(o().a(j2, rVar));
    }

    @Override
    @h.a.a.b.h("none")
    public final void a(@h.a.a.b.f m mVar) {
        Objects.requireNonNull(mVar, "observer is null");
        try {
            m a2 = h.a.a.l.a.a(this, mVar);
            Objects.requireNonNull(a2, "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");
            d(a2);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            h.a.a.e.b.b(th);
            h.a.a.l.a.b(th);
            throw b(th);
        }
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13216f)
    @h.a.a.b.f
    public final j a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "fallback is null");
        return b(j2, timeUnit, h.a.a.n.b.a(), pVar);
    }

    @h.a.a.b.d
    @h.a.a.b.h(h.a.a.b.h.f13215e)
    @h.a.a.b.f
    public final j a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, @h.a.a.b.f p pVar) {
        Objects.requireNonNull(pVar, "fallback is null");
        return b(j2, timeUnit, q0Var, pVar);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    public final <R> R a(@h.a.a.b.f k<? extends R> kVar) {
        return (R) ((k) Objects.requireNonNull(kVar, "converter is null")).a(this);
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final <T> r0<T> a(@h.a.a.b.f h.a.a.g.s<? extends T> sVar) {
        Objects.requireNonNull(sVar, "completionValueSupplier is null");
        return h.a.a.l.a.a(new h.a.a.h.f.a.s0(this, sVar, null));
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public final h.a.a.j.n<Void> a(boolean z) {
        h.a.a.j.n<Void> nVar = new h.a.a.j.n<>();
        if (z) {
            nVar.dispose();
        }
        a((m) nVar);
        return nVar;
    }

    @h.a.a.b.d
    @h.a.a.b.h("none")
    @h.a.a.b.f
    public static j a(@h.a.a.b.f CompletionStage<?> completionStage) {
        Objects.requireNonNull(completionStage, "stage is null");
        return h.a.a.l.a.a(new h.a.a.h.d.a(completionStage));
    }
}