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