Sunbit v2.4.4版本的 MD5 值为：a5021e5e2a58eb1d6741b432fe7533c4
以下内容为反编译后的 z.java 源代码，内容仅作参考
package h.a.a.c;
import h.a.a.h.f.c.a1;
import h.a.a.h.f.c.b1;
import h.a.a.h.f.c.c1;
import h.a.a.h.f.c.d1;
import h.a.a.h.f.c.e1;
import h.a.a.h.f.c.f1;
import h.a.a.h.f.c.g1;
import h.a.a.h.f.c.h1;
import h.a.a.h.f.c.i1;
import h.a.a.h.f.c.j1;
import h.a.a.h.f.c.k1;
import h.a.a.h.f.c.l1;
import h.a.a.h.f.c.m1;
import h.a.a.h.f.c.n1;
import h.a.a.h.f.c.o1;
import h.a.a.h.f.c.p1;
import h.a.a.h.f.c.q1;
import h.a.a.h.f.c.r1;
import h.a.a.h.f.c.s1;
import h.a.a.h.f.c.t1;
import h.a.a.h.f.c.u1;
import h.a.a.h.f.c.v1;
import h.a.a.h.f.c.w1;
import h.a.a.h.f.c.x1;
import h.a.a.h.f.c.z0;
import java.util.Objects;
import java.util.Optional;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Stream;
public abstract class z<T> implements f0<T> {
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> a(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.b(null, iterable));
}
@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 <T> s<T> b(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.g(iterable));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f f0<? extends T>... f0VarArr) {
Objects.requireNonNull(f0VarArr, "sources is null");
if (f0VarArr.length == 0) {
return s.V();
}
if (f0VarArr.length == 1) {
return h.a.a.l.a.a(new p1(f0VarArr[0]));
}
return h.a.a.l.a.a(new h.a.a.h.f.c.f(f0VarArr));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f f0<? extends T>... f0VarArr) {
return s.b((Object[]) f0VarArr).e(r1.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> e(@h.a.a.b.f f0<? extends T>... f0VarArr) {
return s.b((Object[]) f0VarArr).b(r1.a(), true);
}
@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 <T> s<T> f(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
return a(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.FULL)
public static <T> s<T> g(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
return s.q(cVar).h(h.a.a.h.b.a.e());
}
@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 <T> s<T> h(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
return s.q(cVar).e(r1.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.FULL)
public static <T> s<T> i(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
return s.q(cVar).b(r1.a(), true);
}
@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> z<T> j(@h.a.a.b.f q.i.c<T> cVar) {
Objects.requireNonNull(cVar, "source is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.u0(cVar, 0L));
}
@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 <T> s<T> k(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
return e(cVar, Integer.MAX_VALUE);
}
@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 <T> s<T> l(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
return f(cVar, Integer.MAX_VALUE);
}
@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> s<T> m(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
Objects.requireNonNull(cVar, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.k(cVar, h.a.a.h.b.a.e(), 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 <T> s<T> n(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar) {
Objects.requireNonNull(cVar, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.k(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 <T> z<T> x() {
return h.a.a.l.a.a((z) h.a.a.h.f.c.w.f13913a);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> y() {
return h.a.a.l.a.a(a1.f13830a);
}
protected abstract void d(@h.a.a.b.f c0<? super T> c0Var);
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f o() {
return b(h.a.a.h.b.a.d(), h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> p(@h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends f0<? extends T>> oVar) {
Objects.requireNonNull(oVar, "fallbackSupplier is null");
return h.a.a.l.a.a(new d1(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> q(@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 e1(this, oVar));
}
@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 s<T> r(@h.a.a.b.f h.a.a.g.o<? super s<Object>, ? extends q.i.c<?>> oVar) {
return t().C(oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> s(@h.a.a.b.f h.a.a.g.o<? super s<Throwable>, ? extends q.i.c<?>> oVar) {
return t().E(oVar).I();
}
@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 s<T> t() {
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 p1(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Future<T> u() {
return (Future) e((z<T>) 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 i0<T> v() {
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 q1(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> w() {
return h.a.a.l.a.a(new s1(this, 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)
public static <T> s<T> d(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable) {
return s.g((Iterable) iterable).b(r1.a(), 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 <T> s<T> e(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable) {
return s.g((Iterable) iterable).b(r1.a(), true);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> f(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "action is null");
return h.a.a.l.a.a((z) new h.a.a.h.f.c.j0(aVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> g(@h.a.a.b.f f0<? extends T>... f0VarArr) {
Objects.requireNonNull(f0VarArr, "sources is null");
return s.b((Object[]) f0VarArr).g(h.a.a.h.b.a.e(), true, Math.max(1, f0VarArr.length));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> i(@h.a.a.b.f f0<? extends f0<? extends T>> f0Var) {
Objects.requireNonNull(f0Var, "source is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.i0(f0Var, h.a.a.h.b.a.e()));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> k(@h.a.a.b.f f0<T> f0Var) {
if (f0Var instanceof z) {
return h.a.a.l.a.a((z) f0Var);
}
Objects.requireNonNull(f0Var, "source is null");
return h.a.a.l.a.a(new t1(f0Var));
}
@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 <R> s<R> h(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.p(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> l() {
return h.a.a.l.a.a(new h.a.a.h.f.c.q(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> o(@h.a.a.b.f h.a.a.g.o<? super T, Optional<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.d.p(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> r() {
return b(TimeUnit.MILLISECONDS, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> s() {
return (CompletionStage) e((z<T>) new h.a.a.h.d.b(false, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> z<T> a(@h.a.a.b.f f0<? extends T>... f0VarArr) {
Objects.requireNonNull(f0VarArr, "sources is null");
if (f0VarArr.length == 0) {
return x();
}
if (f0VarArr.length == 1) {
return k(f0VarArr[0]);
}
return h.a.a.l.a.a(new h.a.a.h.f.c.b(f0VarArr, 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)
public static <T> s<T> b(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
return b(f0Var, f0Var2);
}
@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 <T> s<T> d(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar, int i2) {
return s.q(cVar).a(r1.a(), true, i2, 1);
}
@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 <T> s<T> e(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar, int i2) {
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.b.d1(cVar, h.a.a.h.b.a.e(), false, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> j(@h.a.a.b.f f0<T> f0Var) {
if (!(f0Var instanceof z)) {
Objects.requireNonNull(f0Var, "onSubscribe is null");
return h.a.a.l.a.a(new t1(f0Var));
}
throw new IllegalArgumentException("unsafeCreate(Maybe) should be upgraded");
}
@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 <R> s<R> l(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.d.m(this, oVar));
}
@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 s<T> m() {
return a((long) k.c3.w.p0.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> n(@h.a.a.b.f h.a.a.g.o<? super T, ? extends R> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.x0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.j.n<T> p() {
h.a.a.j.n<T> nVar = new h.a.a.j.n<>();
a((c0) nVar);
return nVar;
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> q() {
return a(TimeUnit.MILLISECONDS, 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.FULL)
public static <T> s<T> d(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
return g(f0Var, f0Var2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> f(T t) {
Objects.requireNonNull(t, "item is null");
return h.a.a.l.a.a((z) new h.a.a.h.f.c.v0(t));
}
@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 <T> s<T> g(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable) {
return s.g((Iterable) iterable).g(h.a.a.h.b.a.e(), true, Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j h() {
return h.a.a.l.a.a(new h.a.a.h.f.c.s0(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> i(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.h0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> m(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.d.n(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> g(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.o(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> z<T> h(@h.a.a.b.f f0<U> f0Var) {
Objects.requireNonNull(f0Var, "timeoutIndicator is null");
return h.a.a.l.a.a(new m1(this, f0Var, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> n() {
return a((long) k.c3.w.p0.c, h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f f0<? extends T>... f0VarArr) {
Objects.requireNonNull(f0VarArr, "sources is null");
if (f0VarArr.length == 0) {
return s.V();
}
if (f0VarArr.length == 1) {
return h.a.a.l.a.a(new p1(f0VarArr[0]));
}
return h.a.a.l.a.a(new h.a.a.h.f.c.e(f0VarArr));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> r0<Boolean> e(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2) {
return a(f0Var, f0Var2, h.a.a.h.b.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.FULL)
public static <T> s<T> f(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable) {
return s.g((Iterable) iterable).g(h.a.a.h.b.a.e(), false, Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Boolean> i() {
return h.a.a.l.a.a(new h.a.a.h.f.c.u0(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<U> k(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.f0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public static z<Long> d(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")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> f(f0<? extends T>... f0VarArr) {
Objects.requireNonNull(f0VarArr, "sources is null");
if (f0VarArr.length == 0) {
return s.V();
}
if (f0VarArr.length == 1) {
return h.a.a.l.a.a(new p1(f0VarArr[0]));
}
return h.a.a.l.a.a(new z0(f0VarArr));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> e() {
return h.a.a.l.a.a(new h.a.a.h.f.c.c(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> g() {
return h.a.a.l.a.a(new h.a.a.h.f.c.q0(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 <U> s<U> j(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.e0(this, oVar));
}
@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 <T> s<T> c(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable) {
return s.g((Iterable) iterable).h(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public static z<Long> 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 o1(Math.max(0L, j2), timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> e(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "onTerminate is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.v(this, aVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> z<T> g(@h.a.a.b.f f0<U> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return h.a.a.l.a.a(new j1(this, f0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> k() {
return b(h.a.a.h.b.a.b());
}
@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 <T> s<T> c(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar, int i2) {
return s.q(cVar).a(r1.a(), i2, 1);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<h0<T>> j() {
return h.a.a.l.a.a(new h.a.a.h.f.c.y0(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 <T> s<T> a(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2, @h.a.a.b.f f0<? extends T> f0Var3) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
return b(f0Var, f0Var2, f0Var3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> 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.c.o0(x0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> e(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
h.a.a.g.g d2 = h.a.a.h.b.a.d();
h.a.a.g.a aVar = h.a.a.h.b.a.c;
return h.a.a.l.a.a(new f1(this, h.a.a.h.b.a.d(), (h.a.a.g.g) Objects.requireNonNull(gVar, "onSuccess is null"), d2, aVar, aVar, aVar));
}
@h.a.a.b.h("none")
public final void d() {
a(h.a.a.h.b.a.d(), h.a.a.h.b.a.f13256e, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> c(@h.a.a.b.f h.a.a.g.s<? extends T> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a((z) new h.a.a.h.f.c.p0(sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> d(@h.a.a.b.f h.a.a.g.o<? super T, h0<R>> oVar) {
Objects.requireNonNull(oVar, "selector is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.p(this, oVar));
}
@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 <T> s<T> b(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar, int i2) {
return s.q(cVar).c(h.a.a.h.b.a.e(), true, 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 <T> s<T> a(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2, @h.a.a.b.f f0<? extends T> f0Var3, @h.a.a.b.f f0<? extends T> f0Var4) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
return b(f0Var, f0Var2, f0Var3, f0Var4);
}
@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 <T> s<T> b(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable, int i2) {
return s.g((Iterable) iterable).a(r1.a(), true, i2, 1);
}
@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 <T> s<T> c(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
return f(f0Var, f0Var2);
}
@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 <T> s<T> f(@h.a.a.b.f q.i.c<? extends f0<? extends T>> cVar, int i2) {
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.b.d1(cVar, 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 z<T> d(@h.a.a.b.f h.a.a.g.a aVar) {
h.a.a.g.g d2 = h.a.a.h.b.a.d();
h.a.a.g.g d3 = h.a.a.h.b.a.d();
h.a.a.g.g d4 = h.a.a.h.b.a.d();
h.a.a.g.a aVar2 = h.a.a.h.b.a.c;
return h.a.a.l.a.a(new f1(this, d2, d3, d4, aVar2, aVar2, (h.a.a.g.a) Objects.requireNonNull(aVar, "onDispose is null")));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> b(@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.c.z(sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> e(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.i0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> b(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "completableSource is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.l0(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 static <T> s<T> c(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2, @h.a.a.b.f f0<? extends T> f0Var3) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
return g(f0Var, f0Var2, f0Var3);
}
@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 s<T> e(@h.a.a.b.f f0<T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return s.a((q.i.c) k(f0Var).t(), (q.i.c) t());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Long> f() {
return h.a.a.l.a.a(new h.a.a.h.f.c.i(this));
}
@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.o<? super T, ? extends p> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.d0(this, oVar));
}
@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 <T> s<T> a(@h.a.a.b.f q.i.c<? extends f0<? extends T>> 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.d.e(cVar, h.a.a.h.b.a.e(), h.a.a.h.k.j.IMMEDIATE, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> b(@h.a.a.b.f n0<T> n0Var) {
Objects.requireNonNull(n0Var, "source is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.r0(n0Var, 0L));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <E extends c0<? super T>> E e(E e2) {
a((c0) e2);
return e2;
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> d(@h.a.a.b.f h.a.a.g.g<? super h.a.a.d.f> gVar) {
h.a.a.g.g d2 = h.a.a.h.b.a.d();
h.a.a.g.g d3 = h.a.a.h.b.a.d();
h.a.a.g.a aVar = h.a.a.h.b.a.c;
return h.a.a.l.a.a(new f1(this, (h.a.a.g.g) Objects.requireNonNull(gVar, "onSubscribe is null"), d2, d3, aVar, aVar, aVar));
}
@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 final <U> z<T> e(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "timeoutIndicator is null");
return h.a.a.l.a.a(new n1(this, cVar, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f f(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
return b(gVar, h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@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 <T> s<T> b(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2, @h.a.a.b.f f0<? extends T> f0Var3) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
return f(f0Var, f0Var2, f0Var3);
}
@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 <T> s<T> c(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2, @h.a.a.b.f f0<? extends T> f0Var3, @h.a.a.b.f f0<? extends T> f0Var4) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
return g(f0Var, f0Var2, f0Var3, f0Var4);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> f(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return h.a.a.l.a.a(new h1(this, f0Var));
}
@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 <T> s<T> a(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable, int i2) {
return s.g((Iterable) iterable).a(r1.a(), false, i2, 1);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<T> e(@h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new u1(this, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> a(@h.a.a.b.f d0<T> d0Var) {
Objects.requireNonNull(d0Var, "onSubscribe is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.j(d0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> e(@h.a.a.b.g T t) {
return (CompletionStage) e((z<T>) 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 static <T> z<T> a(@h.a.a.b.f h.a.a.g.s<? extends f0<? extends T>> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.k(sVar));
}
@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 <T> s<T> b(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2, @h.a.a.b.f f0<? extends T> f0Var3, @h.a.a.b.f f0<? extends T> f0Var4) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
return f(f0Var, f0Var2, f0Var3, f0Var4);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> d(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "fallback is null");
return p(h.a.a.h.b.a.c(f0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> c(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
return i(oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> 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.c.y(th));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> c(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
return h.a.a.l.a.a(new s1(this, t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> d(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "item is null");
return q(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 static <T> z<T> a(@h.a.a.b.f Callable<? extends T> callable) {
Objects.requireNonNull(callable, "callable is null");
return h.a.a.l.a.a((z) new h.a.a.h.f.c.k0(callable));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> c(@h.a.a.b.f h.a.a.g.a aVar) {
h.a.a.g.a aVar2 = h.a.a.h.b.a.c;
return h.a.a.l.a.a(new f1(this, h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), (h.a.a.g.a) Objects.requireNonNull(aVar, "onComplete is null"), aVar2, aVar2));
}
@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 final <U> z<T> d(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "other is null");
return h.a.a.l.a.a(new k1(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.g
public final T b() {
h.a.a.h.e.i iVar = new h.a.a.h.e.i();
a((c0) iVar);
return (T) iVar.a();
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> a(@h.a.a.b.f Future<? extends T> future) {
Objects.requireNonNull(future, "future is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.m0(future, 0L, null));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> d(@h.a.a.b.f q0 q0Var) {
return b(TimeUnit.MILLISECONDS, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> a(@h.a.a.b.f Future<? extends T> future, long j2, @h.a.a.b.f TimeUnit timeUnit) {
Objects.requireNonNull(future, "future is null");
Objects.requireNonNull(timeUnit, "unit is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.m0(future, j2, timeUnit));
}
@h.a.a.b.h("none")
public final void b(@h.a.a.b.f c0<? super T> c0Var) {
Objects.requireNonNull(c0Var, "observer is null");
h.a.a.h.e.f fVar = new h.a.a.h.e.f();
c0Var.onSubscribe(fVar);
a((c0) fVar);
fVar.a(c0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> c(@h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
h.a.a.g.a aVar = h.a.a.h.b.a.c;
return h.a.a.l.a.a(new f1(this, h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), (h.a.a.g.g) Objects.requireNonNull(gVar, "onError is null"), aVar, aVar, aVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> a(@h.a.a.b.f Runnable runnable) {
Objects.requireNonNull(runnable, "run is null");
return h.a.a.l.a.a((z) new h.a.a.h.f.c.n0(runnable));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> r0<Boolean> a(@h.a.a.b.f f0<? extends T> f0Var, @h.a.a.b.f f0<? extends T> f0Var2, @h.a.a.b.f h.a.a.g.d<? super T, ? super T> dVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(dVar, "isEqual is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.x(f0Var, f0Var2, dVar));
}
@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.o<? super T, ? extends p> oVar) {
return f((h.a.a.g.o) oVar);
}
@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 s<T> b(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return b(this, f0Var);
}
@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 s<T> c(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return c(this, f0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Boolean> b(@h.a.a.b.f Object obj) {
Objects.requireNonNull(obj, "item is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.h(this, obj));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, D> z<T> a(@h.a.a.b.f h.a.a.g.s<? extends D> sVar, @h.a.a.b.f h.a.a.g.o<? super D, ? extends f0<? extends T>> oVar, @h.a.a.b.f h.a.a.g.g<? super D> 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 z<T> c(@h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
return a((long) k.c3.w.p0.c, rVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, D> z<T> a(@h.a.a.b.f h.a.a.g.s<? extends D> sVar, @h.a.a.b.f h.a.a.g.o<? super D, ? extends f0<? extends T>> oVar, @h.a.a.b.f h.a.a.g.g<? super D> 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 v1(sVar, oVar, gVar, z));
}
@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 final <U> z<T> b(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "subscriptionIndicator is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.n(this, cVar));
}
@h.a.a.b.h("none")
public final void c(@h.a.a.b.f c0<? super T> c0Var) {
Objects.requireNonNull(c0Var, "observer is null");
a((c0) new h.a.a.h.e.c0(c0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<T> b(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return b(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.FULL)
public final s<T> c(@h.a.a.b.f q.i.c<T> cVar) {
Objects.requireNonNull(cVar, "other is null");
return t().i((q.i.c) cVar);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<T> b(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return b((q.i.c) s.r(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> z<R> a(@h.a.a.b.f Iterable<? extends f0<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
Objects.requireNonNull(oVar, "zipper is null");
Objects.requireNonNull(iterable, "sources is null");
return h.a.a.l.a.a(new x1(iterable, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> b(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
Objects.requireNonNull(gVar, "onAfterSuccess is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.r(this, gVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> c(@h.a.a.b.f q0 q0Var) {
return a(TimeUnit.MILLISECONDS, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<T> c(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return c(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> b(@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.c.s(this, aVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<T> c(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return h(d(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(cVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.c) cVar), f0Var, f0Var2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> z<U> b(@h.a.a.b.f Class<U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return a((h.a.a.g.r) h.a.a.h.b.a.b((Class) cls)).a((Class) cls);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> b(@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 c1(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f f0<? extends T3> f0Var3, @h.a.a.b.f h.a.a.g.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(hVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.h) hVar), f0Var, f0Var2, f0Var3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> b(long j2) {
return a(j2, h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> b(@h.a.a.b.f h.a.a.g.e eVar) {
Objects.requireNonNull(eVar, "stop is null");
return a((long) 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 h.a.a.d.f b(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2) {
return b(gVar, gVar2, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f f0<? extends T3> f0Var3, @h.a.a.b.f f0<? extends T4> f0Var4, @h.a.a.b.f h.a.a.g.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
Objects.requireNonNull(iVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.i) iVar), f0Var, f0Var2, f0Var3, f0Var4);
}
@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.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(gVar, "onSuccess is null");
Objects.requireNonNull(gVar2, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
return (h.a.a.d.f) e((z<T>) new h.a.a.h.f.c.d(gVar, gVar2, aVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<T> b(@h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new g1(this, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f f0<? extends T3> f0Var3, @h.a.a.b.f f0<? extends T4> f0Var4, @h.a.a.b.f f0<? extends T5> f0Var5, @h.a.a.b.f h.a.a.g.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
Objects.requireNonNull(f0Var5, "source5 is null");
Objects.requireNonNull(jVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.j) jVar), f0Var, f0Var2, f0Var3, f0Var4, f0Var5);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> b(@h.a.a.b.f x0<? extends T> x0Var) {
Objects.requireNonNull(x0Var, "other is null");
return h.a.a.l.a.a(new i1(this, x0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> b(@h.a.a.b.f TimeUnit timeUnit) {
return b(timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> b(@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 l1(this, timeUnit, q0Var, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f f0<? extends T3> f0Var3, @h.a.a.b.f f0<? extends T4> f0Var4, @h.a.a.b.f f0<? extends T5> f0Var5, @h.a.a.b.f f0<? extends T6> f0Var6, @h.a.a.b.f h.a.a.g.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
Objects.requireNonNull(f0Var5, "source5 is null");
Objects.requireNonNull(f0Var6, "source6 is null");
Objects.requireNonNull(kVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.k) kVar), f0Var, f0Var2, f0Var3, f0Var4, f0Var5, f0Var6);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f f0<? extends T3> f0Var3, @h.a.a.b.f f0<? extends T4> f0Var4, @h.a.a.b.f f0<? extends T5> f0Var5, @h.a.a.b.f f0<? extends T6> f0Var6, @h.a.a.b.f f0<? extends T7> f0Var7, @h.a.a.b.f h.a.a.g.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
Objects.requireNonNull(f0Var5, "source5 is null");
Objects.requireNonNull(f0Var6, "source6 is null");
Objects.requireNonNull(f0Var7, "source7 is null");
Objects.requireNonNull(lVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.l) lVar), f0Var, f0Var2, f0Var3, f0Var4, f0Var5, f0Var6, f0Var7);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f f0<? extends T3> f0Var3, @h.a.a.b.f f0<? extends T4> f0Var4, @h.a.a.b.f f0<? extends T5> f0Var5, @h.a.a.b.f f0<? extends T6> f0Var6, @h.a.a.b.f f0<? extends T7> f0Var7, @h.a.a.b.f f0<? extends T8> f0Var8, @h.a.a.b.f h.a.a.g.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
Objects.requireNonNull(f0Var5, "source5 is null");
Objects.requireNonNull(f0Var6, "source6 is null");
Objects.requireNonNull(f0Var7, "source7 is null");
Objects.requireNonNull(f0Var8, "source8 is null");
Objects.requireNonNull(mVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.m) mVar), f0Var, f0Var2, f0Var3, f0Var4, f0Var5, f0Var6, f0Var7, f0Var8);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> z<R> a(@h.a.a.b.f f0<? extends T1> f0Var, @h.a.a.b.f f0<? extends T2> f0Var2, @h.a.a.b.f f0<? extends T3> f0Var3, @h.a.a.b.f f0<? extends T4> f0Var4, @h.a.a.b.f f0<? extends T5> f0Var5, @h.a.a.b.f f0<? extends T6> f0Var6, @h.a.a.b.f f0<? extends T7> f0Var7, @h.a.a.b.f f0<? extends T8> f0Var8, @h.a.a.b.f f0<? extends T9> f0Var9, @h.a.a.b.f h.a.a.g.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
Objects.requireNonNull(f0Var, "source1 is null");
Objects.requireNonNull(f0Var2, "source2 is null");
Objects.requireNonNull(f0Var3, "source3 is null");
Objects.requireNonNull(f0Var4, "source4 is null");
Objects.requireNonNull(f0Var5, "source5 is null");
Objects.requireNonNull(f0Var6, "source6 is null");
Objects.requireNonNull(f0Var7, "source7 is null");
Objects.requireNonNull(f0Var8, "source8 is null");
Objects.requireNonNull(f0Var9, "source9 is null");
Objects.requireNonNull(nVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.n) nVar), f0Var, f0Var2, f0Var3, f0Var4, f0Var5, f0Var6, f0Var7, f0Var8, f0Var9);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T, R> z<R> a(@h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, @h.a.a.b.f f0<? extends T>... f0VarArr) {
Objects.requireNonNull(f0VarArr, "sources is null");
if (f0VarArr.length == 0) {
return x();
}
Objects.requireNonNull(oVar, "zipper is null");
return h.a.a.l.a.a(new w1(f0VarArr, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> a(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return a(this, f0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final T a(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultValue is null");
h.a.a.h.e.i iVar = new h.a.a.h.e.i();
a((c0) iVar);
return (T) iVar.a(t);
}
@h.a.a.b.h("none")
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
a(gVar, h.a.a.h.b.a.f13256e, h.a.a.h.b.a.c);
}
@h.a.a.b.h("none")
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2) {
a(gVar, gVar2, h.a.a.h.b.a.c);
}
@h.a.a.b.h("none")
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(gVar, "onSuccess is null");
Objects.requireNonNull(gVar2, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
h.a.a.h.e.i iVar = new h.a.a.h.e.i();
a((c0) iVar);
iVar.a(gVar, gVar2, aVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> z<U> a(@h.a.a.b.f Class<? extends U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return (z<U>) n(h.a.a.h.b.a.a((Class) cls));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> a(@h.a.a.b.f g0<? super T, ? extends R> g0Var) {
return k(((g0) Objects.requireNonNull(g0Var, "transformer is null")).a(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
return e((h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<T> a(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.f13216f)
@h.a.a.b.f
public final z<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return a(j2, timeUnit, h.a.a.n.b.a(), z);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<T> 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 z<T> 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.c.l(this, Math.max(0L, j2), timeUnit, q0Var, z));
}
@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 final <U> z<T> a(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "delayIndicator is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.m(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> a(@h.a.a.b.f h.a.a.g.a aVar) {
return h.a.a.l.a.a(new f1(this, h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), h.a.a.h.b.a.c, (h.a.a.g.a) Objects.requireNonNull(aVar, "onAfterTerminate is null"), h.a.a.h.b.a.c));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> a(@h.a.a.b.f h.a.a.g.b<? super T, ? super Throwable> bVar) {
Objects.requireNonNull(bVar, "onEvent is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.t(this, bVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> 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) {
Objects.requireNonNull(gVar, "onSubscribe is null");
Objects.requireNonNull(aVar, "onDispose is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.u(this, gVar, aVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> a(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.a0(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, @h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends f0<? extends R>> oVar2, @h.a.a.b.f h.a.a.g.s<? extends f0<? extends R>> sVar) {
Objects.requireNonNull(oVar, "onSuccessMapper is null");
Objects.requireNonNull(oVar2, "onErrorMapper is null");
Objects.requireNonNull(sVar, "onCompleteSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.g0(this, oVar, oVar2, sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> z<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
Objects.requireNonNull(oVar, "mapper is null");
Objects.requireNonNull(cVar, "combiner is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.c0(this, oVar, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> z<R> a(@h.a.a.b.f e0<? extends R, ? super T> e0Var) {
Objects.requireNonNull(e0Var, "lift is null");
return h.a.a.l.a.a(new h.a.a.h.f.c.w0(this, e0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<T> a(@h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new b1(this, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
public final <R> R a(@h.a.a.b.f a0<T, ? extends R> a0Var) {
return (R) ((a0) Objects.requireNonNull(a0Var, "converter is null")).a(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 s<T> a(long j2) {
return t().c(j2);
}
@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 s<T> a(@h.a.a.b.f h.a.a.g.e eVar) {
return t().a(eVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> a(@h.a.a.b.f h.a.a.g.d<? super Integer, ? super Throwable> dVar) {
return t().b(dVar).I();
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> a(long j2, @h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
return t().a(j2, rVar).I();
}
@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 s<T> a(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "other is null");
return s.a((q.i.c) j.i(pVar).o(), (q.i.c) t());
}
@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 s<T> a(@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) t());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> a(@h.a.a.b.f n0<T> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return i0.wrap(n0Var).concatWith(v());
}
@Override
@h.a.a.b.h("none")
public final void a(@h.a.a.b.f c0<? super T> c0Var) {
Objects.requireNonNull(c0Var, "observer is null");
c0<? super T> a2 = h.a.a.l.a.a(this, c0Var);
Objects.requireNonNull(a2, "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 {
d((c0) a2);
} catch (NullPointerException e2) {
throw e2;
} catch (Throwable th) {
h.a.a.e.b.b(th);
NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> a(@h.a.a.b.f TimeUnit timeUnit) {
return a(timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<h.a.a.n.d<T>> a(@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 l1(this, timeUnit, q0Var, true));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final z<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "fallback is null");
return a(j2, timeUnit, h.a.a.n.b.a(), f0Var);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final z<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, @h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "fallback is null");
return a(d(j2, timeUnit, q0Var), f0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> z<T> a(@h.a.a.b.f f0<U> f0Var, @h.a.a.b.f f0<? extends T> f0Var2) {
Objects.requireNonNull(f0Var, "timeoutIndicator is null");
Objects.requireNonNull(f0Var2, "fallback is null");
return h.a.a.l.a.a(new m1(this, f0Var, f0Var2));
}
@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 final <U> z<T> a(@h.a.a.b.f q.i.c<U> cVar, @h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(cVar, "timeoutIndicator is null");
Objects.requireNonNull(f0Var, "fallback is null");
return h.a.a.l.a.a(new n1(this, cVar, f0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> z<R> a(@h.a.a.b.f f0<? extends U> f0Var, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
Objects.requireNonNull(f0Var, "other is null");
return a(this, f0Var, cVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.j.n<T> a(boolean z) {
h.a.a.j.n<T> nVar = new h.a.a.j.n<>();
if (z) {
nVar.dispose();
}
a((c0) nVar);
return nVar;
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> a(@h.a.a.b.f Optional<T> optional) {
Objects.requireNonNull(optional, "optional is null");
return (z) optional.map(new Function() {
@Override
public final Object apply(Object obj) {
return z.f(obj);
}
}).orElseGet(new Supplier() {
@Override
public final Object get() {
return z.x();
}
});
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> z<T> a(@h.a.a.b.f CompletionStage<T> completionStage) {
Objects.requireNonNull(completionStage, "stage is null");
return h.a.a.l.a.a(new h.a.a.h.d.o(completionStage));
}
}