Aqara Home v2.4.1版本的 MD5 值为：529779ac2bc0131db52a1fc3098d2b35
以下内容为反编译后的 l.java 源代码，内容仅作参考
package p.a;
import java.util.Collection;
import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.NoSuchElementException;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import p.a.y0.e.b.a2;
import p.a.y0.e.b.a3;
import p.a.y0.e.b.a4;
import p.a.y0.e.b.a5;
import p.a.y0.e.b.b1;
import p.a.y0.e.b.b2;
import p.a.y0.e.b.b3;
import p.a.y0.e.b.b4;
import p.a.y0.e.b.c1;
import p.a.y0.e.b.c2;
import p.a.y0.e.b.c3;
import p.a.y0.e.b.c4;
import p.a.y0.e.b.d3;
import p.a.y0.e.b.d4;
import p.a.y0.e.b.e1;
import p.a.y0.e.b.e2;
import p.a.y0.e.b.e3;
import p.a.y0.e.b.f1;
import p.a.y0.e.b.f2;
import p.a.y0.e.b.f3;
import p.a.y0.e.b.f4;
import p.a.y0.e.b.g2;
import p.a.y0.e.b.g3;
import p.a.y0.e.b.g4;
import p.a.y0.e.b.h1;
import p.a.y0.e.b.h2;
import p.a.y0.e.b.h3;
import p.a.y0.e.b.h4;
import p.a.y0.e.b.i1;
import p.a.y0.e.b.i2;
import p.a.y0.e.b.i3;
import p.a.y0.e.b.i4;
import p.a.y0.e.b.j1;
import p.a.y0.e.b.j2;
import p.a.y0.e.b.j3;
import p.a.y0.e.b.j4;
import p.a.y0.e.b.k2;
import p.a.y0.e.b.k3;
import p.a.y0.e.b.k4;
import p.a.y0.e.b.l1;
import p.a.y0.e.b.l2;
import p.a.y0.e.b.l3;
import p.a.y0.e.b.l4;
import p.a.y0.e.b.m1;
import p.a.y0.e.b.m2;
import p.a.y0.e.b.m4;
import p.a.y0.e.b.n1;
import p.a.y0.e.b.n3;
import p.a.y0.e.b.n4;
import p.a.y0.e.b.o1;
import p.a.y0.e.b.o2;
import p.a.y0.e.b.o3;
import p.a.y0.e.b.p1;
import p.a.y0.e.b.p2;
import p.a.y0.e.b.p4;
import p.a.y0.e.b.q1;
import p.a.y0.e.b.q2;
import p.a.y0.e.b.q3;
import p.a.y0.e.b.q4;
import p.a.y0.e.b.r1;
import p.a.y0.e.b.r2;
import p.a.y0.e.b.r3;
import p.a.y0.e.b.r4;
import p.a.y0.e.b.s0;
import p.a.y0.e.b.s1;
import p.a.y0.e.b.s2;
import p.a.y0.e.b.s3;
import p.a.y0.e.b.s4;
import p.a.y0.e.b.t1;
import p.a.y0.e.b.t2;
import p.a.y0.e.b.t3;
import p.a.y0.e.b.t4;
import p.a.y0.e.b.u0;
import p.a.y0.e.b.u1;
import p.a.y0.e.b.u2;
import p.a.y0.e.b.u3;
import p.a.y0.e.b.u4;
import p.a.y0.e.b.v0;
import p.a.y0.e.b.v1;
import p.a.y0.e.b.v3;
import p.a.y0.e.b.v4;
import p.a.y0.e.b.w0;
import p.a.y0.e.b.w1;
import p.a.y0.e.b.w2;
import p.a.y0.e.b.w3;
import p.a.y0.e.b.w4;
import p.a.y0.e.b.x0;
import p.a.y0.e.b.x1;
import p.a.y0.e.b.x2;
import p.a.y0.e.b.x3;
import p.a.y0.e.b.x4;
import p.a.y0.e.b.y0;
import p.a.y0.e.b.y1;
import p.a.y0.e.b.y2;
import p.a.y0.e.b.y3;
import p.a.y0.e.b.y4;
import p.a.y0.e.b.z0;
import p.a.y0.e.b.z1;
import p.a.y0.e.b.z3;
import p.a.y0.e.b.z4;
import p.a.y0.e.e.g1;
public abstract class l<T> implements x.g.c<T> {
public static final int a = Math.max(1, Integer.getInteger("rx2.buffer-size", 128).intValue());
public static int Q() {
return a;
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> R() {
return p.a.c1.a.a(w0.b);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> S() {
return p.a.c1.a.a(i2.b);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public static <T> l<T> a(x.g.c<? extends T>... cVarArr) {
p.a.y0.b.b.a(cVarArr, "sources is null");
int length = cVarArr.length;
if (length == 0) {
return R();
}
if (length == 1) {
return q(cVarArr[0]);
}
return p.a.c1.a.a(new p.a.y0.e.b.h(cVarArr, null));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public static <T> l<T> b(Iterable<? extends x.g.c<? extends T>> iterable) {
p.a.y0.b.b.a(iterable, "sources is null");
return p.a.c1.a.a(new p.a.y0.e.b.h(null, iterable));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> c(x.g.c<? extends T>[] cVarArr, p.a.x0.o<? super Object[], ? extends R> oVar) {
return b(cVarArr, oVar, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> d(x.g.c<? extends T>... cVarArr) {
return a(Q(), Q(), cVarArr);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> e(x.g.c<? extends T>... cVarArr) {
return b(Q(), Q(), cVarArr);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> f(Callable<? extends T> callable) {
p.a.y0.b.b.a(callable, "supplier is null");
return p.a.c1.a.a((l) new h1(callable));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> g(Iterable<? extends x.g.c<? extends T>> iterable) {
return f((Iterable) iterable).p(p.a.y0.b.a.e());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> h(Iterable<? extends x.g.c<? extends T>> iterable) {
return f((Iterable) iterable).e(p.a.y0.b.a.e(), true);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> j(p.a.x0.g<k<T>> gVar) {
p.a.y0.b.b.a(gVar, "generator is null");
return a(p.a.y0.b.a.h(), s1.a(gVar), p.a.y0.b.a.d());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> m(T t2) {
p.a.y0.b.b.a((Object) t2, "item is null");
return p.a.c1.a.a((l) new w1(t2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> n(x.g.c<? extends x.g.c<? extends T>> cVar) {
return c(cVar, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> o(x.g.c<? extends x.g.c<? extends T>> cVar) {
return a((x.g.c) cVar, Q(), true);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> p(x.g.c<? extends x.g.c<? extends T>> cVar) {
return a(cVar, Q(), Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public static <T> l<T> q(x.g.c<? extends T> cVar) {
if (cVar instanceof l) {
return p.a.c1.a.a((l) cVar);
}
p.a.y0.b.b.a(cVar, "source is null");
return p.a.c1.a.a(new l1(cVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> r(x.g.c<? extends x.g.c<? extends T>> cVar) {
return d(cVar, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> s(x.g.c<? extends x.g.c<? extends T>> cVar) {
return e(cVar, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> t(x.g.c<? extends x.g.c<? extends T>> cVar) {
return q(cVar).C(p.a.y0.b.a.e());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> u(x.g.c<? extends x.g.c<? extends T>> cVar) {
return g(cVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.NONE)
@p.a.t0.d
public static <T> l<T> v(x.g.c<T> cVar) {
p.a.y0.b.b.a(cVar, "onSubscribe is null");
if (!(cVar instanceof l)) {
return p.a.c1.a.a(new l1(cVar));
}
throw new IllegalArgumentException("unsafeCreate(Flowable) should be upgraded");
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.b1.b<T> A() {
return p.a.b1.b.a(this);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.w0.a<T> B() {
return f(Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> C() {
return e(Long.MAX_VALUE);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.w0.a<T> D() {
return d3.a((l) this);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> E() {
return a(Long.MAX_VALUE, p.a.y0.b.a.b());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> F() {
return p.a.c1.a.a(new o3(this));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> G() {
return B().V();
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> H() {
return p.a.c1.a.a(new q3(this));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> I() {
return p.a.c1.a.a(new r3(this, null));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> J() {
return N().n().v(p.a.y0.b.a.a(p.a.y0.b.a.f())).r(p.a.y0.b.a.e());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<p.a.e1.d<T>> K() {
return a(TimeUnit.MILLISECONDS, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<p.a.e1.d<T>> L() {
return b(TimeUnit.MILLISECONDS, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final Future<T> M() {
return (Future) a((l<T>) new p.a.y0.h.j());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> N() {
return p.a.c1.a.a(new p4(this));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> O() {
return p.a.c1.a.a(new g1(this));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> P() {
return b((Comparator) p.a.y0.b.a.f());
}
public abstract void e(x.g.d<? super T> dVar);
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.h("none")
public final void i() {
p.a.y0.e.b.l.a(this);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Long> k() {
return p.a.c1.a.a(new p.a.y0.e.b.e0(this));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U> l<T> l(p.a.x0.o<? super T, ? extends x.g.c<U>> oVar) {
p.a.y0.b.b.a(oVar, "itemDelayIndicator is null");
return (l<T>) p(s1.b(oVar));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.h("none")
public final p.a.u0.c subscribe() {
return subscribe(p.a.y0.b.a.d(), p.a.y0.b.a.f29916f, p.a.y0.b.a.c, s1.i.INSTANCE);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.g1.f<T> test() {
p.a.g1.f<T> fVar = new p.a.g1.f<>();
a((q) fVar);
return fVar;
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> w() {
return a(Q(), false, true);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> x() {
return p.a.c1.a.a((l) new m2(this));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> y() {
return p.a.c1.a.a(new o2(this));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> z() {
return p.a.c1.a.a(new p.a.y0.e.b.m0(this));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> c(Iterable<? extends x.g.c<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar) {
return b(iterable, oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> d(Iterable<? extends x.g.c<? extends T>> iterable) {
p.a.y0.b.b.a(iterable, "sources is null");
return f((Iterable) iterable).d(p.a.y0.b.a.e());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> e(Iterable<? extends x.g.c<? extends T>> iterable) {
return a(iterable, Q(), Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> g(x.g.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).d(p.a.y0.b.a.e(), true, cVarArr.length);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static l<Long> r(long j2, TimeUnit timeUnit) {
return r(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> A(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar) {
p.a.y0.b.b.a(oVar, "selector is null");
return d3.a(s1.a(this), (p.a.x0.o) oVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> B(p.a.x0.o<? super l<Throwable>, ? extends x.g.c<?>> oVar) {
p.a.y0.b.b.a(oVar, "handler is null");
return p.a.c1.a.a(new g3(this, oVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> C(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar) {
return j(oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final c D(@p.a.t0.f p.a.x0.o<? super T, ? extends i> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.f(this, oVar, false));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final c E(@p.a.t0.f p.a.x0.o<? super T, ? extends i> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.f(this, oVar, true));
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> F(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar) {
return k(oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> l<R> G(@p.a.t0.f p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.g(this, oVar, false));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> l<R> H(@p.a.t0.f p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.g(this, oVar, true));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> l<R> I(@p.a.t0.f p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.h(this, oVar, false));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> l<R> J(@p.a.t0.f p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.h(this, oVar, true));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final <V> l<T> K(p.a.x0.o<? super T, ? extends x.g.c<V>> oVar) {
return b((x.g.c) null, oVar, (x.g.c) null);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> R L(p.a.x0.o<? super l<T>, R> oVar) {
try {
return (R) ((p.a.x0.o) p.a.y0.b.b.a(oVar, "converter is null")).apply(this);
} catch (Throwable th) {
p.a.v0.b.b(th);
throw p.a.y0.j.k.c(th);
}
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <K> k0<Map<K, T>> M(p.a.x0.o<? super T, ? extends K> oVar) {
p.a.y0.b.b.a(oVar, "keySelector is null");
return (k0<Map<K, T>>) a((Callable) p.a.y0.j.m.asCallable(), (p.a.x0.b) p.a.y0.b.a.a((p.a.x0.o) oVar));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final <K> k0<Map<K, Collection<T>>> N(p.a.x0.o<? super T, ? extends K> oVar) {
return (k0<Map<K, Collection<T>>>) a((p.a.x0.o) oVar, (p.a.x0.o) p.a.y0.b.a.e(), (Callable) p.a.y0.j.m.asCallable(), (p.a.x0.o) p.a.y0.j.b.asFunction());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final T h() {
return I().e();
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> i(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
return e(oVar, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <U> l<T> k(p.a.x0.o<? super T, ? extends x.g.c<U>> oVar) {
p.a.y0.b.b.a(oVar, "debounceIndicator is null");
return p.a.c1.a.a(new p.a.y0.e.b.g0(this, oVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <K> l<T> n(p.a.x0.o<? super T, K> oVar) {
return a((p.a.x0.o) oVar, (Callable) p.a.y0.b.a.c());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <K> l<T> o(p.a.x0.o<? super T, K> oVar) {
p.a.y0.b.b.a(oVar, "keySelector is null");
return p.a.c1.a.a(new p.a.y0.e.b.o0(this, oVar, p.a.y0.b.b.a()));
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> p() {
return c(0L);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> s(p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
return f((p.a.x0.o) oVar, false, Integer.MAX_VALUE);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar) {
return subscribe(gVar, p.a.y0.b.a.f29916f, p.a.y0.b.a.c, s1.i.INSTANCE);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> t(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
return g((p.a.x0.o) oVar, false, Integer.MAX_VALUE);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <K> l<p.a.w0.b<K, T>> u(p.a.x0.o<? super T, ? extends K> oVar) {
return (l<p.a.w0.b<K, T>>) a((p.a.x0.o) oVar, (p.a.x0.o) p.a.y0.b.a.e(), false, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> w(p.a.x0.o<? super Throwable, ? extends x.g.c<? extends T>> oVar) {
p.a.y0.b.b.a(oVar, "resumeFunction is null");
return p.a.c1.a.a(new p2(this, oVar, false));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> x(p.a.x0.o<? super Throwable, ? extends T> oVar) {
p.a.y0.b.b.a(oVar, "valueSupplier is null");
return p.a.c1.a.a(new q2(this, oVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> y(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar) {
return h(oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> z(p.a.x0.o<? super l<Object>, ? extends x.g.c<?>> oVar) {
p.a.y0.b.b.a(oVar, "handler is null");
return p.a.c1.a.a(new c3(this, oVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> b(x.g.c<? extends T>[] cVarArr, p.a.x0.o<? super Object[], ? extends R> oVar) {
return a(cVarArr, oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(Iterable<? extends x.g.c<? extends T>> iterable) {
p.a.y0.b.b.a(iterable, "sources is null");
return f((Iterable) iterable).a(p.a.y0.b.a.e(), 2, false);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public static <T> l<T> e(Callable<? extends Throwable> callable) {
p.a.y0.b.b.a(callable, "supplier is null");
return p.a.c1.a.a(new x0(callable));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> f(Iterable<? extends T> iterable) {
p.a.y0.b.b.a(iterable, "source is null");
return p.a.c1.a.a(new j1(iterable));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> g(x.g.c<? extends x.g.c<? extends T>> cVar, int i2) {
return q(cVar).k(p.a.y0.b.a.e(), i2);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public static l<Long> r(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new n4(Math.max(0L, j2), timeUnit, j0Var));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> h(p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
return b((p.a.x0.o) oVar, true, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<T> i(T t2) {
p.a.y0.b.b.a((Object) t2, "defaultItem");
return p.a.c1.a.a(new y1(this, t2));
}
@Deprecated
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <T2> l<T2> l() {
return p.a.c1.a.a(new p.a.y0.e.b.l0(this, p.a.y0.b.a.e()));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.e
@p.a.t0.d
public final <R> l<R> m(p.a.x0.o<? super T, a0<R>> oVar) {
p.a.y0.b.b.a(oVar, "selector is null");
return p.a.c1.a.a(new p.a.y0.e.b.l0(this, oVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> n() {
return o(p.a.y0.b.a.e());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> p(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar) {
return a((p.a.x0.o) oVar, false, Q(), Q());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Boolean> s() {
return a(p.a.y0.b.a.a());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2) {
return subscribe(gVar, gVar2, p.a.y0.b.a.c, s1.i.INSTANCE);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> t() {
return p.a.c1.a.a(new x1(this));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> u() {
return p.a.c1.a.a(new y1(this, null));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> b(Iterable<? extends x.g.c<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar) {
return a(iterable, oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public static <T> l<T> d(Callable<? extends x.g.c<? extends T>> callable) {
p.a.y0.b.b.a(callable, "supplier is null");
return p.a.c1.a.a(new p.a.y0.e.b.i0(callable));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> g() {
return new p.a.y0.e.b.e(this);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> h(T t2) {
return a(0L, (long) t2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<T> k(T t2) {
p.a.y0.b.b.a((Object) t2, "defaultItem is null");
return p.a.c1.a.a(new r3(this, t2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> l(T t2) {
p.a.y0.b.b.a((Object) t2, "value is null");
return b(m(t2), this);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> n(long j2, TimeUnit timeUnit) {
return b(j2, timeUnit);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> o() {
return b(0L);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<l<T>> p(long j2, TimeUnit timeUnit) {
return a(j2, timeUnit, p.a.e1.b.a(), Long.MAX_VALUE, false);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar) {
return subscribe(gVar, gVar2, aVar, s1.i.INSTANCE);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> b(p.a.x0.o<? super Object[], ? extends R> oVar, x.g.c<? extends T>... cVarArr) {
return b(cVarArr, oVar, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> c(x.g.c<? extends x.g.c<? extends T>> cVar, int i2) {
return q(cVar).a(p.a.y0.b.a.e(), i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> e(x.g.c<? extends x.g.c<? extends T>> cVar, int i2) {
return q(cVar).d(p.a.y0.b.a.e(), true, i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> f(x.g.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).f(p.a.y0.b.a.e(), cVarArr.length);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static l<Long> q(long j2, TimeUnit timeUnit) {
return d(j2, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> g(p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
return d(oVar, 2);
}
@p.a.t0.b(p.a.t0.a.NONE)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c h(p.a.x0.g<? super T> gVar) {
return subscribe(gVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final l<T> i(p.a.x0.g<? super T> gVar) {
p.a.y0.b.b.a(gVar, "onDrop is null");
return p.a.c1.a.a((l) new m2(this, gVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> m() {
return a((p.a.x0.o) p.a.y0.b.a.e(), (Callable) p.a.y0.b.a.c());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> n(long j2, TimeUnit timeUnit, j0 j0Var) {
return b(j2, timeUnit, j0Var);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> o(long j2, TimeUnit timeUnit) {
return a(j2, timeUnit, (x.g.c) null, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<l<T>> p(long j2, TimeUnit timeUnit, j0 j0Var) {
return a(j2, timeUnit, j0Var, Long.MAX_VALUE, false);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar, p.a.x0.g<? super x.g.e> gVar3) {
p.a.y0.b.b.a(gVar, "onNext is null");
p.a.y0.b.b.a(gVar2, "onError is null");
p.a.y0.b.b.a(aVar, "onComplete is null");
p.a.y0.b.b.a(gVar3, "onSubscribe is null");
p.a.y0.h.m mVar = new p.a.y0.h.m(gVar, gVar2, aVar, gVar3);
a((q) mVar);
return mVar;
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <R> l<R> v(p.a.x0.o<? super T, ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new b2(this, oVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> a(p.a.x0.o<? super Object[], ? extends R> oVar, x.g.c<? extends T>... cVarArr) {
return a(cVarArr, oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, R> l<R> b(x.g.c<? extends T>[] cVarArr, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(cVarArr, "sources is null");
p.a.y0.b.b.a(oVar, "combiner is null");
p.a.y0.b.b.a(i2, "bufferSize");
if (cVarArr.length == 0) {
return R();
}
return p.a.c1.a.a(new p.a.y0.e.b.u((x.g.c[]) cVarArr, (p.a.x0.o) oVar, i2, true));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> c(x.g.c<? extends T>... cVarArr) {
if (cVarArr.length == 0) {
return R();
}
if (cVarArr.length == 1) {
return q(cVarArr[0]);
}
return p.a.c1.a.a(new p.a.y0.e.b.v(cVarArr, true));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static l<Long> d(long j2, long j3, TimeUnit timeUnit) {
return d(j2, j3, timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> f(x.g.c<? extends x.g.c<? extends T>> cVar, int i2) {
return q(cVar).j(p.a.y0.b.a.e(), i2);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static l<Long> q(long j2, TimeUnit timeUnit, j0 j0Var) {
return d(j2, j2, timeUnit, j0Var);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> e() {
return new p.a.y0.e.b.c(this);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> g(T t2) {
p.a.y0.b.b.a((Object) t2, "defaultItem is null");
return k((x.g.c) m(t2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> h(p.a.x0.o<? super l<T>, ? extends x.g.c<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new s2(this, oVar, i2, false));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> j() {
return c(16);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> k(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return p.a.c1.a.a(new y3(this, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <U> l<T> l(x.g.c<U> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return p.a.c1.a.a(new f4(this, cVar));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> m(long j2, TimeUnit timeUnit) {
return e(j2, timeUnit, p.a.e1.b.a(), false);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> o(long j2, TimeUnit timeUnit, j0 j0Var) {
return a(j2, timeUnit, (x.g.c) null, j0Var);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U> l<U> r(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar) {
return g(oVar, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, R> l<R> a(x.g.c<? extends T>[] cVarArr, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(cVarArr, "sources is null");
if (cVarArr.length == 0) {
return R();
}
p.a.y0.b.b.a(oVar, "combiner is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new p.a.y0.e.b.u((x.g.c[]) cVarArr, (p.a.x0.o) oVar, i2, false));
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public static l<Long> d(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new t1(Math.max(0L, j2), Math.max(0L, j3), timeUnit, j0Var));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final T e(T t2) {
return k((l<T>) t2).e();
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U> l<U> f(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar) {
return c(oVar, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> i(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(i2, "bufferSize");
return d3.a(s1.a(this, i2), (p.a.x0.o) oVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> j(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
return c((p.a.x0.o) oVar, true, 2);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> m(long j2, TimeUnit timeUnit, j0 j0Var) {
return e(j2, timeUnit, j0Var, false);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final c q(p.a.x0.o<? super T, ? extends i> oVar) {
return e((p.a.x0.o) oVar, false, Integer.MAX_VALUE);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final c r() {
return p.a.c1.a.a(new r1(this));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<a0<T>> v() {
return p.a.c1.a.a(new e2(this));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> e(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar) {
return a(oVar, Q(), Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<Boolean> f(Object obj) {
p.a.y0.b.b.a(obj, "item is null");
return b((p.a.x0.r) p.a.y0.b.a.a(obj));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> g(p.a.x0.g<? super x.g.e> gVar) {
return a(gVar, p.a.y0.b.a.f29917g, p.a.y0.b.a.c);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> j(T t2) {
p.a.y0.b.b.a((Object) t2, "item is null");
return x(p.a.y0.b.a.c(t2));
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> k(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2) {
return b((p.a.x0.o) oVar, i2, true);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> l(long j2, TimeUnit timeUnit) {
return f(j2, timeUnit);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <B> l<l<T>> m(x.g.c<B> cVar) {
return b(cVar, Q());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> q() {
return p.a.c1.a.a(new p1(this));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> e(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.e(this, oVar, p.a.y0.j.j.IMMEDIATE, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U> l<U> g(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new f1(this, oVar, i2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.w0.a<T> h(int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
return d3.a((l) this, i2);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> k(long j2, TimeUnit timeUnit) {
return k(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> l(long j2, TimeUnit timeUnit, j0 j0Var) {
return f(j2, timeUnit, j0Var);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> d(x.g.c<? extends x.g.c<? extends T>> cVar, int i2) {
return q(cVar).f(p.a.y0.b.a.e(), i2);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> f(p.a.x0.g<? super T> gVar) {
p.a.x0.g<? super Throwable> d = p.a.y0.b.a.d();
p.a.x0.a aVar = p.a.y0.b.a.c;
return a((p.a.x0.g) gVar, d, aVar, aVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> i(int i2) {
if (i2 >= 0) {
if (i2 == 0) {
return p.a.c1.a.a(this);
}
return p.a.c1.a.a(new t3(this, i2));
}
throw new IndexOutOfBoundsException("count >= 0 required but it was " + i2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> j(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return b(cVar, this);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final l<T> k(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new i4(this, j2, timeUnit, j0Var));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> l(int i2) {
return a(p.a.y0.b.a.f(), i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, S> l<T> c(Callable<S> callable, p.a.x0.c<S, k<T>, S> cVar) {
return a((Callable) callable, (p.a.x0.c) cVar, p.a.y0.b.a.d());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> d(int i2, int i3, x.g.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).a(p.a.y0.b.a.e(), true, i2, i3);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> f(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2) {
return a((p.a.x0.o) oVar, false, i2, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <U> l<T> h(x.g.c<U> cVar) {
p.a.y0.b.b.a(cVar, "sampler is null");
return p.a.c1.a.a(new h3(this, cVar, false));
}
@Override
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.h("none")
public final void subscribe(x.g.d<? super T> dVar) {
if (dVar instanceof q) {
a((q) ((q) dVar));
return;
}
p.a.y0.b.b.a(dVar, "s is null");
a((q) new p.a.y0.h.u(dVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> b(Iterable<? extends x.g.c<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(iterable, "sources is null");
p.a.y0.b.b.a(oVar, "combiner is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new p.a.y0.e.b.u((Iterable) iterable, (p.a.x0.o) oVar, i2, true));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> c(int i2, int i3, x.g.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).a(p.a.y0.b.a.e(), false, i2, i3);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> d(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2) {
return a(cVar, cVar2, p.a.y0.b.b.a(), Q());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> e(p.a.x0.g<? super Throwable> gVar) {
p.a.x0.g<? super T> d = p.a.y0.b.a.d();
p.a.x0.a aVar = p.a.y0.b.a.c;
return a((p.a.x0.g) d, gVar, aVar, aVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> l<R> f(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
return p.a.c1.a.a(new c1(this, oVar, z2, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> l<R> g(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
return p.a.c1.a.a(new e1(this, oVar, z2, i2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> j(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2) {
return b((p.a.x0.o) oVar, i2, false);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, R> l<R> a(Iterable<? extends x.g.c<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(iterable, "sources is null");
p.a.y0.b.b.a(oVar, "combiner is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new p.a.y0.e.b.u((Iterable) iterable, (p.a.x0.o) oVar, i2, false));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> c(Iterable<? extends x.g.c<? extends T>> iterable, int i2, int i3) {
return f((Iterable) iterable).a(p.a.y0.b.a.e(), true, i2, i3);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, R> l<R> d(Iterable<? extends x.g.c<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(iterable, "sources is null");
return p.a.c1.a.a(new z4(null, iterable, oVar, Q(), false));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> e(p.a.x0.a aVar) {
return a((p.a.x0.g) p.a.y0.b.a.d(), p.a.y0.b.a.a(aVar), aVar, p.a.y0.b.a.c);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> h(long j2, TimeUnit timeUnit) {
return a(j2, timeUnit, p.a.e1.b.a(), false, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U> l<T> i(x.g.c<U> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return p.a.c1.a.a(new v3(this, cVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> j(int i2) {
if (i2 < 0) {
throw new IndexOutOfBoundsException("count >= 0 required but it was " + i2);
} else if (i2 == 0) {
return p.a.c1.a.a(new q1(this));
} else {
if (i2 == 1) {
return p.a.c1.a.a(new c4(this));
}
return p.a.c1.a.a(new b4(this, i2));
}
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> k(int i2) {
p.a.y0.b.b.a(i2, "capacityHint");
return p.a.c1.a.a(new p4(this, p.a.y0.b.a.b(i2)));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return b((Object[]) new x.g.c[]{cVar, cVar2}).d(p.a.y0.b.a.e(), true, 2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> e(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, boolean z2) {
return a(oVar, z2, Q(), Q());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> h(long j2, TimeUnit timeUnit, j0 j0Var) {
return a(j2, timeUnit, j0Var, false, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final c e(p.a.x0.o<? super T, ? extends i> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
return p.a.c1.a.a(new b1(this, oVar, z2, i2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <K> l<p.a.w0.b<K, T>> f(p.a.x0.o<? super T, ? extends K> oVar, boolean z2) {
return (l<p.a.w0.b<K, T>>) a(oVar, p.a.y0.b.a.e(), z2, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> g(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "next is null");
return p.a.c1.a.a(new p2(this, p.a.y0.b.a.c(cVar), true));
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> h(long j2) {
if (j2 >= 0) {
return p.a.c1.a.a(new a4(this, j2));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j2);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> i(long j2, TimeUnit timeUnit) {
return l((x.g.c) r(j2, timeUnit));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> b(x.g.c<? extends T>... cVarArr) {
if (cVarArr.length == 0) {
return R();
}
if (cVarArr.length == 1) {
return q(cVarArr[0]);
}
return p.a.c1.a.a(new p.a.y0.e.b.v(cVarArr, false));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, R> l<R> d(x.g.c<? extends x.g.c<? extends T>> cVar, p.a.x0.o<? super Object[], ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "zipper is null");
return q(cVar).N().f(s1.c(oVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> f(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "next is null");
return w(p.a.y0.b.a.c(cVar));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> i(long j2, TimeUnit timeUnit, j0 j0Var) {
return l((x.g.c) r(j2, timeUnit, j0Var));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> l<R> a(p.a.x0.o<? super Object[], ? extends R> oVar, int i2, x.g.c<? extends T>... cVarArr) {
return b(cVarArr, oVar, i2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, x.g.c<? extends T> cVar3) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
return b((Object[]) new x.g.c[]{cVar, cVar2, cVar3}).d(p.a.y0.b.a.e(), true, 3);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> g(int i2) {
return a(p.a.y0.g.e.b, true, i2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> h(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new h4(this, rVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<l<T>> i(long j2) {
return a(j2, j2, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> j(long j2, TimeUnit timeUnit) {
return b(j2, timeUnit, p.a.e1.b.a(), false, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar3) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return a(p.a.y0.b.a.a((p.a.x0.c) cVar3), cVar, cVar2);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final T d() {
p.a.y0.h.e eVar = new p.a.y0.h.e();
a((q) eVar);
T a2 = eVar.a();
if (a2 != null) {
return a2;
}
throw new NoSuchElementException();
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> e(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return b(this, cVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.w0.a<T> f(int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
return r2.a((l) this, i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> g(long j2) {
if (j2 <= 0) {
return p.a.c1.a.a(this);
}
return p.a.c1.a.a(new s3(this, j2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> j(long j2, TimeUnit timeUnit, j0 j0Var) {
return b(j2, timeUnit, j0Var, false, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.b1.b<T> e(int i2) {
p.a.y0.b.b.a(i2, "parallelism");
return p.a.b1.b.a(this, i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> f(long j2) {
return a(j2, p.a.y0.b.a.b());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> g(long j2, TimeUnit timeUnit) {
return i((x.g.c) r(j2, timeUnit));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> b(int i2, int i3, x.g.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).a(p.a.y0.b.a.e(), i2, i3, true);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> c(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, x.g.c<? extends T> cVar3, x.g.c<? extends T> cVar4) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
return b((Object[]) new x.g.c[]{cVar, cVar2, cVar3, cVar4}).d(p.a.y0.b.a.e(), true, 4);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> f(long j2, TimeUnit timeUnit) {
return f(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> g(long j2, TimeUnit timeUnit, j0 j0Var) {
return i((x.g.c) r(j2, timeUnit, j0Var));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, p.a.x0.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
return a(p.a.y0.b.a.a((p.a.x0.h) hVar), cVar, cVar2, cVar3);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> b(T... tArr) {
p.a.y0.b.b.a(tArr, "items is null");
if (tArr.length == 0) {
return R();
}
if (tArr.length == 1) {
return m(tArr[0]);
}
return p.a.c1.a.a(new p.a.y0.e.b.g1(tArr));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> d(T t2) {
return new p.a.y0.e.b.d(this, t2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> e(long j2) {
int i2 = (j2 > 0L ? 1 : (j2 == 0L ? 0 : -1));
if (i2 >= 0) {
if (i2 == 0) {
return R();
}
return p.a.c1.a.a(new a3(this, j2));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final l<T> f(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new i3(this, j2, timeUnit, j0Var, false));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> g(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "stopPredicate is null");
return p.a.c1.a.a(new g4(this, rVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> d(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar) {
return a((p.a.x0.o) oVar, 2, true);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> d(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.d(this, oVar, p.a.y0.j.j.IMMEDIATE, i2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final p.a.w0.a<T> e(long j2, TimeUnit timeUnit) {
return e(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> f(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new w3(this, rVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, p.a.x0.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
return a(p.a.y0.b.a.a((p.a.x0.i) iVar), cVar, cVar2, cVar3, cVar4);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static l<Integer> c(int i2, int i3) {
if (i3 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + i3);
} else if (i3 == 0) {
return R();
} else {
if (i3 == 1) {
return m(Integer.valueOf(i2));
}
if (i2 + (i3 - 1) <= 2147483647L) {
return p.a.c1.a.a(new t2(i2, i3));
}
throw new IllegalArgumentException("Integer overflow");
}
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.w0.a<T> e(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return d3.a(this, j2, timeUnit, j0Var);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> d(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, boolean z2) {
return c(oVar, z2, 2);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> f(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new q4(this, j0Var));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, S> l<T> b(Callable<S> callable, p.a.x0.b<S, k<T>> bVar) {
p.a.y0.b.b.a(bVar, "generator is null");
return a((Callable) callable, s1.a(bVar), p.a.y0.b.a.d());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U> l<T> d(x.g.c<U> cVar) {
p.a.y0.b.b.a(cVar, "subscriptionIndicator is null");
return p.a.c1.a.a(new p.a.y0.e.b.k0(this, cVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> e(p.a.x0.r<? super Throwable> rVar) {
return a(Long.MAX_VALUE, rVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> d(long j2, TimeUnit timeUnit) {
return d(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> e(long j2, TimeUnit timeUnit, boolean z2) {
return e(j2, timeUnit, p.a.e1.b.a(), z2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, p.a.x0.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
return a(p.a.y0.b.a.a((p.a.x0.j) jVar), cVar, cVar2, cVar3, cVar4, cVar5);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> c() {
return a(Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> d(long j2, TimeUnit timeUnit, j0 j0Var) {
return d((x.g.c) r(j2, timeUnit, j0Var));
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final l<T> e(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new j4(this, j2, timeUnit, j0Var, z2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> b(Iterable<? extends x.g.c<? extends T>> iterable, int i2, int i3) {
return f((Iterable) iterable).a(p.a.y0.b.a.e(), false, i2, i3);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final T c(T t2) {
p.a.y0.h.e eVar = new p.a.y0.h.e();
a((q) eVar);
T a2 = eVar.a();
return a2 != null ? a2 : t2;
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> d(p.a.x0.a aVar) {
return a((p.a.x0.g) p.a.y0.b.a.d(), p.a.y0.b.a.d(), aVar, p.a.y0.b.a.c);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> b(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return b((Object[]) new x.g.c[]{cVar, cVar2}).d(p.a.y0.b.a.e(), false, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> d(p.a.x0.g<? super a0<T>> gVar) {
p.a.y0.b.b.a(gVar, "onNotification is null");
return a((p.a.x0.g) p.a.y0.b.a.c((p.a.x0.g) gVar), (p.a.x0.g<? super Throwable>) p.a.y0.b.a.b((p.a.x0.g) gVar), p.a.y0.b.a.a((p.a.x0.g) gVar), p.a.y0.b.a.c);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<p.a.e1.d<T>> e(j0 j0Var) {
return b(TimeUnit.MILLISECONDS, j0Var);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> c(int i2) {
p.a.y0.b.b.a(i2, "initialCapacity");
return p.a.c1.a.a(new p.a.y0.e.b.r(this, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> b(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, x.g.c<? extends T> cVar3) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
return b((Object[]) new x.g.c[]{cVar, cVar2, cVar3}).d(p.a.y0.b.a.e(), false, 3);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, p.a.x0.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
return a(p.a.y0.b.a.a((p.a.x0.k) kVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final c c(p.a.x0.o<? super T, ? extends i> oVar) {
return a((p.a.x0.o) oVar, true, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U> l<U> c(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new f1(this, oVar, i2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> d(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, boolean z2, int i2) {
return a(oVar, z2, i2, Q());
}
@p.a.t0.b(p.a.t0.a.NONE)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c d(p.a.x0.r<? super T> rVar) {
return a((p.a.x0.r) rVar, (p.a.x0.g<? super Throwable>) p.a.y0.b.a.f29916f, p.a.y0.b.a.c);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> b(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, x.g.c<? extends T> cVar3, x.g.c<? extends T> cVar4) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
return b((Object[]) new x.g.c[]{cVar, cVar2, cVar3, cVar4}).d(p.a.y0.b.a.e(), false, 4);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> d(long j2) {
if (j2 >= 0) {
return p.a.c1.a.a(new a2(this, j2));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> c(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, boolean z2) {
return b(oVar, z2, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> c(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.e(this, oVar, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY, i2));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> d(int i2) {
return a(i2, false, false);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.h("none")
public final void d(x.g.d<? super T> dVar) {
p.a.y0.b.b.a(dVar, "s is null");
if (dVar instanceof p.a.g1.d) {
a((q) ((p.a.g1.d) dVar));
} else {
a((q) new p.a.g1.d(dVar));
}
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, T7, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, x.g.c<? extends T7> cVar7, p.a.x0.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
p.a.y0.b.b.a(cVar7, "source7 is null");
return a(p.a.y0.b.a.a((p.a.x0.l) lVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> b(Iterable<? extends x.g.c<? extends T>> iterable, int i2) {
return f((Iterable) iterable).d(p.a.y0.b.a.e(), true, i2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> c(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return a((x.g.c) this, (x.g.c) cVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static l<Long> b(long j2, long j3) {
int i2 = (j3 > 0L ? 1 : (j3 == 0L ? 0 : -1));
if (i2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + j3);
} else if (i2 == 0) {
return R();
} else {
if (j3 == 1) {
return m(Long.valueOf(j2));
}
long j4 = (j3 - 1) + j2;
if (j2 > 0 && j4 < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
return p.a.c1.a.a(new u2(j2, j3));
}
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> c(long j2, TimeUnit timeUnit) {
return a(j2, timeUnit, p.a.e1.b.a(), false);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> d(long j2, TimeUnit timeUnit, boolean z2) {
return b(j2, timeUnit, p.a.e1.b.a(), z2, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> c(long j2, TimeUnit timeUnit, j0 j0Var) {
return a(j2, timeUnit, j0Var, false);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> d(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
return b(j2, timeUnit, j0Var, z2, Q());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> c(p.a.x0.g<? super T> gVar) {
p.a.y0.b.b.a(gVar, "onAfterNext is null");
return p.a.c1.a.a(new p.a.y0.e.b.p0(this, gVar));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<p.a.e1.d<T>> d(j0 j0Var) {
return a(TimeUnit.MILLISECONDS, j0Var);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar3) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return a(p.a.y0.b.a.a((p.a.x0.c) cVar3), false, Q(), cVar, cVar2);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> c(p.a.x0.a aVar) {
return a(p.a.y0.b.a.d(), p.a.y0.b.a.f29917g, aVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, x.g.c<? extends T7> cVar7, x.g.c<? extends T8> cVar8, p.a.x0.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
p.a.y0.b.b.a(cVar7, "source7 is null");
p.a.y0.b.b.a(cVar8, "source8 is null");
return a(p.a.y0.b.a.a((p.a.x0.m) mVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> c(x.g.d<? super T> dVar) {
p.a.y0.b.b.a(dVar, "subscriber is null");
return a((p.a.x0.g) s1.c(dVar), (p.a.x0.g<? super Throwable>) s1.b(dVar), s1.a(dVar), p.a.y0.b.a.c);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, p.a.x0.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
return a(p.a.y0.b.a.a((p.a.x0.h) hVar), false, Q(), cVar, cVar2, cVar3);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> c(long j2) {
if (j2 >= 0) {
return p.a.c1.a.a(new v0(this, j2, null));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, p.a.x0.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
return a(p.a.y0.b.a.a((p.a.x0.i) iVar), false, Q(), cVar, cVar2, cVar3, cVar4);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> c(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new y0(this, rVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, x.g.c<? extends T7> cVar7, x.g.c<? extends T8> cVar8, x.g.c<? extends T9> cVar9, p.a.x0.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
p.a.y0.b.b.a(cVar7, "source7 is null");
p.a.y0.b.b.a(cVar8, "source8 is null");
p.a.y0.b.b.a(cVar9, "source9 is null");
return a(p.a.y0.b.a.a((p.a.x0.n) nVar), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8, cVar9);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> c(long j2, TimeUnit timeUnit, boolean z2) {
return a(j2, timeUnit, p.a.e1.b.a(), z2, Q());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> c(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
return a(j2, timeUnit, j0Var, z2, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, p.a.x0.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
return a(p.a.y0.b.a.a((p.a.x0.j) jVar), false, Q(), cVar, cVar2, cVar3, cVar4, cVar5);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> c(@p.a.t0.f j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return b(j0Var, !(this instanceof p.a.y0.e.b.f0));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> k0<Map<K, Collection<V>>> c(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2) {
return a((p.a.x0.o) oVar, (p.a.x0.o) oVar2, (Callable) p.a.y0.j.m.asCallable(), (p.a.x0.o) p.a.y0.j.b.asFunction());
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> k0<Map<K, Collection<V>>> c(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, Callable<Map<K, Collection<V>>> callable) {
return a((p.a.x0.o) oVar, (p.a.x0.o) oVar2, (Callable) callable, (p.a.x0.o) p.a.y0.j.b.asFunction());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, p.a.x0.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
return a(p.a.y0.b.a.a((p.a.x0.k) kVar), false, Q(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<l<T>> c(long j2, long j3, TimeUnit timeUnit) {
return a(j2, j3, timeUnit, p.a.e1.b.a(), Q());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<l<T>> c(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
return a(j2, j3, timeUnit, j0Var, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return b(cVar, cVar2);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> l<l<T>> c(x.g.c<U> cVar, p.a.x0.o<? super U, ? extends x.g.c<V>> oVar) {
return a(cVar, oVar, Q());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <B> l<l<T>> c(Callable<? extends x.g.c<B>> callable) {
return a(callable, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, x.g.c<? extends T> cVar3) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
return b(cVar, cVar2, cVar3);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, T7, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, x.g.c<? extends T7> cVar7, p.a.x0.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
p.a.y0.b.b.a(cVar7, "source7 is null");
return a(p.a.y0.b.a.a((p.a.x0.l) lVar), false, Q(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, x.g.c<? extends T> cVar3, x.g.c<? extends T> cVar4) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
return b(cVar, cVar2, cVar3, cVar4);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(int i2, int i3, x.g.c<? extends T>... cVarArr) {
p.a.y0.b.b.a(cVarArr, "sources is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.b.x(new p.a.y0.e.b.g1(cVarArr), p.a.y0.b.a.e(), i2, i3, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, x.g.c<? extends T7> cVar7, x.g.c<? extends T8> cVar8, p.a.x0.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
p.a.y0.b.b.a(cVar7, "source7 is null");
p.a.y0.b.b.a(cVar8, "source8 is null");
return a(p.a.y0.b.a.a((p.a.x0.m) mVar), false, Q(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> a(x.g.c<? extends x.g.c<? extends T>> cVar, int i2, boolean z2) {
return q(cVar).a(p.a.y0.b.a.e(), i2, z2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(x.g.c<? extends x.g.c<? extends T>> cVar, int i2, int i3) {
p.a.y0.b.b.a(cVar, "sources is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.b.y(cVar, p.a.y0.b.a.e(), i2, i3, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(Iterable<? extends x.g.c<? extends T>> iterable, int i2, int i3) {
p.a.y0.b.b.a(iterable, "sources is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.b.x(new j1(iterable), p.a.y0.b.a.e(), i2, i3, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> l<R> b(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, x.g.c<? extends T3> cVar3, x.g.c<? extends T4> cVar4, x.g.c<? extends T5> cVar5, x.g.c<? extends T6> cVar6, x.g.c<? extends T7> cVar7, x.g.c<? extends T8> cVar8, x.g.c<? extends T9> cVar9, p.a.x0.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
p.a.y0.b.b.a(cVar5, "source5 is null");
p.a.y0.b.b.a(cVar6, "source6 is null");
p.a.y0.b.b.a(cVar7, "source7 is null");
p.a.y0.b.b.a(cVar8, "source8 is null");
p.a.y0.b.b.a(cVar9, "source9 is null");
return a(p.a.y0.b.a.a((p.a.x0.n) nVar), false, Q(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8, cVar9);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
public static <T> l<T> a(o<T> oVar, b bVar) {
p.a.y0.b.b.a(oVar, "source is null");
p.a.y0.b.b.a(bVar, "mode is null");
return p.a.c1.a.a(new p.a.y0.e.b.f0(oVar, bVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public static <T> l<T> a(Throwable th) {
p.a.y0.b.b.a(th, "throwable is null");
return e((Callable<? extends Throwable>) p.a.y0.b.a.b(th));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(Future<? extends T> future) {
p.a.y0.b.b.a(future, "future is null");
return p.a.c1.a.a(new i1(future, 0L, null));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(Future<? extends T> future, long j2, TimeUnit timeUnit) {
p.a.y0.b.b.a(future, "future is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
return p.a.c1.a.a(new i1(future, j2, timeUnit));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<Boolean> b(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new p.a.y0.e.b.j(this, rVar));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final T b() {
p.a.y0.h.d dVar = new p.a.y0.h.d();
a((q) dVar);
T a2 = dVar.a();
if (a2 != null) {
return a2;
}
throw new NoSuchElementException();
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(Future<? extends T> future, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return a(future, j2, timeUnit).c(j0Var);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(Future<? extends T> future, j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return a(future).c(j0Var);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final T b(T t2) {
p.a.y0.h.d dVar = new p.a.y0.h.d();
a((q) dVar);
T a2 = dVar.a();
return a2 != null ? a2 : t2;
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, S> l<T> a(Callable<S> callable, p.a.x0.b<S, k<T>> bVar, p.a.x0.g<? super S> gVar) {
p.a.y0.b.b.a(bVar, "generator is null");
return a((Callable) callable, s1.a(bVar), (p.a.x0.g) gVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, S> l<T> a(Callable<S> callable, p.a.x0.c<S, k<T>, S> cVar, p.a.x0.g<? super S> gVar) {
p.a.y0.b.b.a(callable, "initialState is null");
p.a.y0.b.b.a(cVar, "generator is null");
p.a.y0.b.b.a(gVar, "disposeState is null");
return p.a.c1.a.a(new m1(callable, cVar, gVar));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.h("none")
public final void b(p.a.x0.g<? super T> gVar) {
p.a.y0.e.b.l.a(this, gVar, p.a.y0.b.a.f29916f, p.a.y0.b.a.c);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.h("none")
public final void b(x.g.d<? super T> dVar) {
p.a.y0.e.b.l.a(this, dVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<List<T>> b(int i2) {
return a(i2, i2);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <B> l<List<T>> b(x.g.c<B> cVar) {
return (l<List<T>>) a((x.g.c) cVar, (Callable) p.a.y0.j.b.asCallable());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static l<Long> a(long j2, long j3, long j4, long j5, TimeUnit timeUnit) {
return a(j2, j3, j4, j5, timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final c b(p.a.x0.o<? super T, ? extends i> oVar) {
return b(oVar, 2);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public static l<Long> a(long j2, long j3, long j4, long j5, TimeUnit timeUnit, j0 j0Var) {
int i2 = (j3 > 0L ? 1 : (j3 == 0L ? 0 : -1));
if (i2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + j3);
} else if (i2 == 0) {
return R().c(j4, timeUnit, j0Var);
} else {
long j6 = j2 + (j3 - 1);
if (j2 > 0 && j6 < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new u1(j2, j6, Math.max(0L, j4), Math.max(0L, j5), timeUnit, j0Var));
}
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final c b(p.a.x0.o<? super T, ? extends i> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.c(this, oVar, p.a.y0.j.j.IMMEDIATE, i2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> b(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, boolean z2) {
return a(oVar, Q(), Q(), z2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> b(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.d(this, oVar, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
return b(t2, t3);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> b(long j2, TimeUnit timeUnit) {
return b(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final l<T> b(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new p.a.y0.e.b.h0(this, j2, timeUnit, j0Var));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
return b(t2, t3, t4);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> b(p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onFinally is null");
return p.a.c1.a.a(new p.a.y0.e.b.q0(this, aVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4, T t5) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
return b(t2, t3, t4, t5);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> b(long j2) {
if (j2 >= 0) {
return p.a.c1.a.a(new u0(this, j2));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U, V> l<V> b(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends V> cVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(cVar, "resultSelector is null");
return (l<V>) a((p.a.x0.o) s1.a(oVar), (p.a.x0.c) cVar, false, Q(), Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4, T t5, T t6) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
return b(t2, t3, t4, t5, t6);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U, V> l<V> b(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends V> cVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(cVar, "resultSelector is null");
return (l<V>) a((p.a.x0.o) s1.a(oVar), (p.a.x0.c) cVar, false, Q(), i2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <TRight, TLeftEnd, TRightEnd, R> l<R> b(x.g.c<? extends TRight> cVar, p.a.x0.o<? super T, ? extends x.g.c<TLeftEnd>> oVar, p.a.x0.o<? super TRight, ? extends x.g.c<TRightEnd>> oVar2, p.a.x0.c<? super T, ? super TRight, ? extends R> cVar2) {
p.a.y0.b.b.a(cVar, "other is null");
p.a.y0.b.b.a(oVar, "leftEnd is null");
p.a.y0.b.b.a(oVar2, "rightEnd is null");
p.a.y0.b.b.a(cVar2, "resultSelector is null");
return p.a.c1.a.a(new v1(this, cVar, oVar, oVar2, cVar2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4, T t5, T t6, T t7) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
return b(t2, t3, t4, t5, t6, t7);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> b(@p.a.t0.f q0<? extends T> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return p.a.c1.a.a(new h2(this, q0Var));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> b(@p.a.t0.f y<? extends T> yVar) {
p.a.y0.b.b.a(yVar, "other is null");
return p.a.c1.a.a(new g2(this, yVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> b(@p.a.t0.f i iVar) {
p.a.y0.b.b.a(iVar, "other is null");
return p.a.c1.a.a(new f2(this, iVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4, T t5, T t6, T t7, T t8) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
return b(t2, t3, t4, t5, t6, t7, t8);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <U> l<U> b(Class<U> cls) {
p.a.y0.b.b.a(cls, "clazz is null");
return c((p.a.x0.r) p.a.y0.b.a.b((Class) cls)).a(cls);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.b1.b<T> b(int i2, int i3) {
p.a.y0.b.b.a(i2, "parallelism");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.b1.b.a(this, i2, i3);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.w0.a<T> b(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return d3.a((p.a.w0.a) D(), j0Var);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
p.a.y0.b.b.a((Object) t9, "item8 is null");
return b(t2, t3, t4, t5, t6, t7, t8, t9);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> b(p.a.x0.d<? super Integer, ? super Throwable> dVar) {
p.a.y0.b.b.a(dVar, "predicate is null");
return p.a.c1.a.a(new e3(this, dVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> b(p.a.x0.e eVar) {
p.a.y0.b.b.a(eVar, "stop is null");
return a(Long.MAX_VALUE, p.a.y0.b.a.a(eVar));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> b(long j2, TimeUnit timeUnit, boolean z2) {
return b(j2, timeUnit, p.a.e1.b.a(), z2);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final l<T> b(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new i3(this, j2, timeUnit, j0Var, z2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> b(p.a.x0.c<T, T, T> cVar) {
p.a.y0.b.b.a(cVar, "accumulator is null");
return p.a.c1.a.a(new k3(this, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
p.a.y0.b.b.a((Object) t9, "item8 is null");
p.a.y0.b.b.a((Object) t10, "item9 is null");
return b(t2, t3, t4, t5, t6, t7, t8, t9, t10);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> b(R r2, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(r2, "initialValue is null");
return b((Callable) p.a.y0.b.a.b(r2), (p.a.x0.c) cVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> b(Callable<R> callable, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(callable, "seedSupplier is null");
p.a.y0.b.b.a(cVar, "accumulator is null");
return p.a.c1.a.a(new l3(this, callable, cVar));
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> b(@p.a.t0.f j0 j0Var, boolean z2) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new x3(this, j0Var, z2));
}
public <R> l<R> b(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "bufferSize");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return R();
}
return j3.a(call, oVar);
}
return p.a.c1.a.a(new z3(this, oVar, i2, z2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> l<T> a(T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10, T t11) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
p.a.y0.b.b.a((Object) t9, "item8 is null");
p.a.y0.b.b.a((Object) t10, "item9 is null");
p.a.y0.b.b.a((Object) t11, "item10 is null");
return b(t2, t3, t4, t5, t6, t7, t8, t9, t10, t11);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> b(long j2, long j3, TimeUnit timeUnit) {
return a(j2, j3, timeUnit, p.a.e1.b.a(), false, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> b(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
return a(j2, j3, timeUnit, j0Var, false, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> b(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2, int i2) {
return a(Long.MAX_VALUE, j2, timeUnit, j0Var, z2, i2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <U, V> l<T> b(x.g.c<U> cVar, p.a.x0.o<? super T, ? extends x.g.c<V>> oVar) {
p.a.y0.b.b.a(cVar, "firstTimeoutIndicator is null");
return b(cVar, oVar, (x.g.c) null);
}
private <U, V> l<T> b(x.g.c<U> cVar, p.a.x0.o<? super T, ? extends x.g.c<V>> oVar, x.g.c<? extends T> cVar2) {
p.a.y0.b.b.a(oVar, "itemTimeoutIndicator is null");
return p.a.c1.a.a(new l4(this, cVar, oVar, cVar2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> l<T> a(Iterable<? extends x.g.c<? extends T>> iterable, int i2) {
return f((Iterable) iterable).f(p.a.y0.b.a.e(), i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> a(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, p.a.x0.d<? super T, ? super T> dVar) {
return a(cVar, cVar2, dVar, Q());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<p.a.e1.d<T>> b(TimeUnit timeUnit) {
return b(timeUnit, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T> k0<Boolean> a(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, p.a.x0.d<? super T, ? super T> dVar, int i2) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(dVar, "isEqual is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new n3(cVar, cVar2, dVar, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<p.a.e1.d<T>> b(TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return (l<p.a.e1.d<T>>) v(p.a.y0.b.a.a(timeUnit, j0Var));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final <U extends Collection<? super T>> k0<U> b(Callable<U> callable) {
p.a.y0.b.b.a(callable, "collectionSupplier is null");
return p.a.c1.a.a(new p4(this, callable));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> a(x.g.c<? extends T> cVar, x.g.c<? extends T> cVar2, int i2) {
return a(cVar, cVar2, p.a.y0.b.b.a(), i2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <K, V> k0<Map<K, V>> b(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
return (k0<Map<K, V>>) a((Callable) p.a.y0.j.m.asCallable(), (p.a.x0.b) p.a.y0.b.a.a(oVar, oVar2));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public static <T, D> l<T> a(Callable<? extends D> callable, p.a.x0.o<? super D, ? extends x.g.c<? extends T>> oVar, p.a.x0.g<? super D> gVar) {
return a((Callable) callable, (p.a.x0.o) oVar, (p.a.x0.g) gVar, true);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public static <T, D> l<T> a(Callable<? extends D> callable, p.a.x0.o<? super D, ? extends x.g.c<? extends T>> oVar, p.a.x0.g<? super D> gVar, boolean z2) {
p.a.y0.b.b.a(callable, "resourceSupplier is null");
p.a.y0.b.b.a(oVar, "sourceSupplier is null");
p.a.y0.b.b.a(gVar, "resourceDisposer is null");
return p.a.c1.a.a(new r4(callable, oVar, gVar, z2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <K, V> k0<Map<K, V>> b(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, Callable<? extends Map<K, V>> callable) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
return (k0<Map<K, V>>) a((Callable) callable, (p.a.x0.b) p.a.y0.b.a.a(oVar, oVar2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar3, boolean z2) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return a(p.a.y0.b.a.a((p.a.x0.c) cVar3), z2, Q(), cVar, cVar2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<List<T>> b(Comparator<? super T> comparator) {
p.a.y0.b.b.a(comparator, "comparator is null");
return (k0<List<T>>) N().i(p.a.y0.b.a.a((Comparator) comparator));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <B> l<l<T>> b(x.g.c<B> cVar, int i2) {
p.a.y0.b.b.a(cVar, "boundaryIndicator is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new t4(this, cVar, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T1, T2, R> l<R> a(x.g.c<? extends T1> cVar, x.g.c<? extends T2> cVar2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar3, boolean z2, int i2) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return a(p.a.y0.b.a.a((p.a.x0.c) cVar3), z2, i2, cVar, cVar2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U, R> l<R> b(x.g.c<? extends U> cVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar2) {
p.a.y0.b.b.a(cVar, "other is null");
return b(this, cVar, cVar2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, R> l<R> a(p.a.x0.o<? super Object[], ? extends R> oVar, boolean z2, int i2, x.g.c<? extends T>... cVarArr) {
if (cVarArr.length == 0) {
return R();
}
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new z4(cVarArr, null, oVar, i2, z2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public static <T, R> l<R> a(Iterable<? extends x.g.c<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(iterable, "sources is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new z4(null, iterable, oVar, i2, z2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<Boolean> a(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new p.a.y0.e.b.g(this, rVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return a(this, cVar);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> R a(@p.a.t0.f m<T, ? extends R> mVar) {
return (R) ((m) p.a.y0.b.b.a(mVar, "converter is null")).apply(this);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.h("none")
public final void a(p.a.x0.g<? super T> gVar) {
Iterator<T> it = c().iterator();
while (it.hasNext()) {
try {
gVar.accept(it.next());
} catch (Throwable th) {
p.a.v0.b.b(th);
((p.a.u0.c) it).dispose();
throw p.a.y0.j.k.c(th);
}
}
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> a(int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
return new p.a.y0.e.b.b(this, i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.h("none")
public final void a(p.a.x0.g<? super T> gVar, int i2) {
p.a.y0.e.b.l.a(this, gVar, p.a.y0.b.a.f29916f, p.a.y0.b.a.c, i2);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.h("none")
public final void a(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2) {
p.a.y0.e.b.l.a(this, gVar, gVar2, p.a.y0.b.a.c);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.h("none")
public final void a(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, int i2) {
p.a.y0.e.b.l.a(this, gVar, gVar2, p.a.y0.b.a.c, i2);
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.h("none")
public final void a(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar) {
p.a.y0.e.b.l.a(this, gVar, gVar2, aVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.h("none")
public final void a(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar, int i2) {
p.a.y0.e.b.l.a(this, gVar, gVar2, aVar, i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<List<T>> a(int i2, int i3) {
return (l<List<T>>) a(i2, i3, p.a.y0.j.b.asCallable());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U extends Collection<? super T>> l<U> a(int i2, int i3, Callable<U> callable) {
p.a.y0.b.b.a(i2, "count");
p.a.y0.b.b.a(i3, "skip");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.b.m(this, i2, i3, callable));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U extends Collection<? super T>> l<U> a(int i2, Callable<U> callable) {
return a(i2, i2, callable);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<List<T>> a(long j2, long j3, TimeUnit timeUnit) {
return (l<List<T>>) a(j2, j3, timeUnit, p.a.e1.b.a(), p.a.y0.j.b.asCallable());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<List<T>> a(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
return (l<List<T>>) a(j2, j3, timeUnit, j0Var, p.a.y0.j.b.asCallable());
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <U extends Collection<? super T>> l<U> a(long j2, long j3, TimeUnit timeUnit, j0 j0Var, Callable<U> callable) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.b.q(this, j2, j3, timeUnit, j0Var, callable, Integer.MAX_VALUE, false));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<List<T>> a(long j2, TimeUnit timeUnit) {
return a(j2, timeUnit, p.a.e1.b.a(), Integer.MAX_VALUE);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<List<T>> a(long j2, TimeUnit timeUnit, int i2) {
return a(j2, timeUnit, p.a.e1.b.a(), i2);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<List<T>> a(long j2, TimeUnit timeUnit, j0 j0Var, int i2) {
return (l<List<T>>) a(j2, timeUnit, j0Var, i2, (Callable) p.a.y0.j.b.asCallable(), false);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final <U extends Collection<? super T>> l<U> a(long j2, TimeUnit timeUnit, j0 j0Var, int i2, Callable<U> callable, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
p.a.y0.b.b.a(i2, "count");
return p.a.c1.a.a(new p.a.y0.e.b.q(this, j2, j2, timeUnit, j0Var, callable, i2, z2));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<List<T>> a(long j2, TimeUnit timeUnit, j0 j0Var) {
return (l<List<T>>) a(j2, timeUnit, j0Var, Integer.MAX_VALUE, (Callable) p.a.y0.j.b.asCallable(), false);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <TOpening, TClosing> l<List<T>> a(l<? extends TOpening> lVar, p.a.x0.o<? super TOpening, ? extends x.g.c<? extends TClosing>> oVar) {
return (l<List<T>>) a((l) lVar, (p.a.x0.o) oVar, (Callable) p.a.y0.j.b.asCallable());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <TOpening, TClosing, U extends Collection<? super T>> l<U> a(l<? extends TOpening> lVar, p.a.x0.o<? super TOpening, ? extends x.g.c<? extends TClosing>> oVar, Callable<U> callable) {
p.a.y0.b.b.a(lVar, "openingIndicator is null");
p.a.y0.b.b.a(oVar, "closingIndicator is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.b.n(this, lVar, oVar, callable));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <B> l<List<T>> a(x.g.c<B> cVar, int i2) {
p.a.y0.b.b.a(i2, "initialCapacity");
return (l<List<T>>) a((x.g.c) cVar, (Callable) p.a.y0.b.a.b(i2));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <B, U extends Collection<? super T>> l<U> a(x.g.c<B> cVar, Callable<U> callable) {
p.a.y0.b.b.a(cVar, "boundaryIndicator is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.b.p(this, cVar, callable));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <B> l<List<T>> a(Callable<? extends x.g.c<B>> callable) {
return (l<List<T>>) a((Callable) callable, (Callable) p.a.y0.j.b.asCallable());
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final <B, U extends Collection<? super T>> l<U> a(Callable<? extends x.g.c<B>> callable, Callable<U> callable2) {
p.a.y0.b.b.a(callable, "boundaryIndicatorSupplier is null");
p.a.y0.b.b.a(callable2, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.b.o(this, callable, callable2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <U> l<U> a(Class<U> cls) {
p.a.y0.b.b.a(cls, "clazz is null");
return (l<U>) v(p.a.y0.b.a.a((Class) cls));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <U> k0<U> a(Callable<? extends U> callable, p.a.x0.b<? super U, ? super T> bVar) {
p.a.y0.b.b.a(callable, "initialItemSupplier is null");
p.a.y0.b.b.a(bVar, "collector is null");
return p.a.c1.a.a(new p.a.y0.e.b.t(this, callable, bVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <U> k0<U> a(U u2, p.a.x0.b<? super U, ? super T> bVar) {
p.a.y0.b.b.a(u2, "initialItem is null");
return a((Callable) p.a.y0.b.a.b(u2), (p.a.x0.b) bVar);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> a(r<? super T, ? extends R> rVar) {
return q(((r) p.a.y0.b.b.a(rVar, "composer is null")).apply(this));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar) {
return a(oVar, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return R();
}
return j3.a(call, oVar);
}
return p.a.c1.a.a(new p.a.y0.e.b.w(this, oVar, i2, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final c a(p.a.x0.o<? super T, ? extends i> oVar, boolean z2) {
return a(oVar, z2, 2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final c a(p.a.x0.o<? super T, ? extends i> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.c(this, oVar, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return R();
}
return j3.a(call, oVar);
}
return p.a.c1.a.a(new p.a.y0.e.b.w(this, oVar, i2, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2, int i3) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.b.x(this, oVar, i2, i3, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, int i2, int i3, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.b.x(this, oVar, i2, i3, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(@p.a.t0.f q0<? extends T> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return p.a.c1.a.a(new p.a.y0.e.b.c0(this, q0Var));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(@p.a.t0.f y<? extends T> yVar) {
p.a.y0.b.b.a(yVar, "other is null");
return p.a.c1.a.a(new p.a.y0.e.b.b0(this, yVar));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(@p.a.t0.f i iVar) {
p.a.y0.b.b.a(iVar, "other is null");
return p.a.c1.a.a(new p.a.y0.e.b.a0(this, iVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<T> a(long j2, TimeUnit timeUnit, boolean z2) {
return a(j2, timeUnit, p.a.e1.b.a(), z2);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new p.a.y0.e.b.j0(this, Math.max(0L, j2), timeUnit, j0Var, z2));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> l<T> a(x.g.c<U> cVar, p.a.x0.o<? super T, ? extends x.g.c<V>> oVar) {
return d((x.g.c) cVar).l((p.a.x0.o) oVar);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <K> l<T> a(p.a.x0.o<? super T, K> oVar, Callable<? extends Collection<? super K>> callable) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(callable, "collectionSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.b.n0(this, oVar, callable));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(p.a.x0.d<? super T, ? super T> dVar) {
p.a.y0.b.b.a(dVar, "comparer is null");
return p.a.c1.a.a(new p.a.y0.e.b.o0(this, p.a.y0.b.a.e(), dVar));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(p.a.x0.a aVar) {
return a((p.a.x0.g) p.a.y0.b.a.d(), p.a.y0.b.a.d(), p.a.y0.b.a.c, aVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
private l<T> a(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar, p.a.x0.a aVar2) {
p.a.y0.b.b.a(gVar, "onNext is null");
p.a.y0.b.b.a(gVar2, "onError is null");
p.a.y0.b.b.a(aVar, "onComplete is null");
p.a.y0.b.b.a(aVar2, "onAfterTerminate is null");
return p.a.c1.a.a(new p.a.y0.e.b.r0(this, gVar, gVar2, aVar, aVar2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final l<T> a(p.a.x0.g<? super x.g.e> gVar, p.a.x0.q qVar, p.a.x0.a aVar) {
p.a.y0.b.b.a(gVar, "onSubscribe is null");
p.a.y0.b.b.a(qVar, "onRequest is null");
p.a.y0.b.b.a(aVar, "onCancel is null");
return p.a.c1.a.a(new s0(this, gVar, qVar, aVar));
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(p.a.x0.q qVar) {
return a(p.a.y0.b.a.d(), qVar, p.a.y0.b.a.c);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<T> a(long j2, T t2) {
if (j2 >= 0) {
p.a.y0.b.b.a((Object) t2, "defaultItem is null");
return p.a.c1.a.a(new v0(this, j2, t2));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, boolean z2, int i2, int i3) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "bufferSize");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return R();
}
return j3.a(call, oVar);
}
return p.a.c1.a.a(new z0(this, oVar, z2, i2, i3));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, p.a.x0.o<? super Throwable, ? extends x.g.c<? extends R>> oVar2, Callable<? extends x.g.c<? extends R>> callable) {
p.a.y0.b.b.a(oVar, "onNextMapper is null");
p.a.y0.b.b.a(oVar2, "onErrorMapper is null");
p.a.y0.b.b.a(callable, "onCompleteSupplier is null");
return r(new c2(this, oVar, oVar2, callable));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends R>> oVar, p.a.x0.o<Throwable, ? extends x.g.c<? extends R>> oVar2, Callable<? extends x.g.c<? extends R>> callable, int i2) {
p.a.y0.b.b.a(oVar, "onNextMapper is null");
p.a.y0.b.b.a(oVar2, "onErrorMapper is null");
p.a.y0.b.b.a(callable, "onCompleteSupplier is null");
return d(new c2(this, oVar, oVar2, callable), i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
return a((p.a.x0.o) oVar, (p.a.x0.c) cVar, false, Q(), Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2) {
return a(oVar, cVar, z2, Q(), Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2, int i2) {
return a(oVar, cVar, z2, i2, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U, R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2, int i2, int i3) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(cVar, "combiner is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "bufferSize");
return a(s1.a(oVar, cVar), z2, i2, i3);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> l<R> a(p.a.x0.o<? super T, ? extends x.g.c<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, int i2) {
return a((p.a.x0.o) oVar, (p.a.x0.c) cVar, false, i2, Q());
}
@p.a.t0.b(p.a.t0.a.NONE)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c a(p.a.x0.r<? super T> rVar, p.a.x0.g<? super Throwable> gVar) {
return a((p.a.x0.r) rVar, gVar, p.a.y0.b.a.c);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.NONE)
@p.a.t0.d
public final p.a.u0.c a(p.a.x0.r<? super T> rVar, p.a.x0.g<? super Throwable> gVar, p.a.x0.a aVar) {
p.a.y0.b.b.a(rVar, "onNext is null");
p.a.y0.b.b.a(gVar, "onError is null");
p.a.y0.b.b.a(aVar, "onComplete is null");
p.a.y0.h.i iVar = new p.a.y0.h.i(rVar, gVar, aVar);
a((q) iVar);
return iVar;
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> l<p.a.w0.b<K, V>> a(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2) {
return a((p.a.x0.o) oVar, (p.a.x0.o) oVar2, false, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> l<p.a.w0.b<K, V>> a(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, boolean z2) {
return a(oVar, oVar2, z2, Q());
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <K, V> l<p.a.w0.b<K, V>> a(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new n1(this, oVar, oVar2, i2, z2, null));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <K, V> l<p.a.w0.b<K, V>> a(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, boolean z2, int i2, p.a.x0.o<? super p.a.x0.g<Object>, ? extends Map<K, Object>> oVar3) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(oVar3, "evictingMapFactory is null");
return p.a.c1.a.a(new n1(this, oVar, oVar2, i2, z2, oVar3));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <TRight, TLeftEnd, TRightEnd, R> l<R> a(x.g.c<? extends TRight> cVar, p.a.x0.o<? super T, ? extends x.g.c<TLeftEnd>> oVar, p.a.x0.o<? super TRight, ? extends x.g.c<TRightEnd>> oVar2, p.a.x0.c<? super T, ? super l<TRight>, ? extends R> cVar2) {
p.a.y0.b.b.a(cVar, "other is null");
p.a.y0.b.b.a(oVar, "leftEnd is null");
p.a.y0.b.b.a(oVar2, "rightEnd is null");
p.a.y0.b.b.a(cVar2, "resultSelector is null");
return p.a.c1.a.a(new o1(this, cVar, oVar, oVar2, cVar2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
public final <R> l<R> a(p<? extends R, ? super T> pVar) {
p.a.y0.b.b.a(pVar, "lifter is null");
return p.a.c1.a.a(new z1(this, pVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> a(j0 j0Var) {
return a(j0Var, false, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<T> a(j0 j0Var, boolean z2) {
return a(j0Var, z2, Q());
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(j0 j0Var, boolean z2, int i2) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new j2(this, j0Var, z2, i2));
}
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(boolean z2) {
return a(Q(), z2, true);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(int i2, boolean z2) {
return a(i2, z2, false);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(int i2, boolean z2, boolean z3) {
p.a.y0.b.b.a(i2, "capacity");
return p.a.c1.a.a(new k2(this, i2, z3, z2, p.a.y0.b.a.c));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
public final l<T> a(int i2, boolean z2, boolean z3, p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onOverflow is null");
p.a.y0.b.b.a(i2, "capacity");
return p.a.c1.a.a(new k2(this, i2, z3, z2, aVar));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(int i2, p.a.x0.a aVar) {
return a(i2, false, false, aVar);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
public final l<T> a(long j2, p.a.x0.a aVar, a aVar2) {
p.a.y0.b.b.a(aVar2, "overflowStrategy is null");
p.a.y0.b.b.b(j2, "capacity");
return p.a.c1.a.a(new l2(this, j2, aVar, aVar2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final s<T> a(p.a.x0.c<T, T, T> cVar) {
p.a.y0.b.b.a(cVar, "reducer is null");
return p.a.c1.a.a(new w2(this, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> k0<R> a(R r2, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(r2, "seed is null");
p.a.y0.b.b.a(cVar, "reducer is null");
return p.a.c1.a.a(new x2(this, r2, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <R> k0<R> a(Callable<R> callable, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(callable, "seedSupplier is null");
p.a.y0.b.b.a(cVar, "reducer is null");
return p.a.c1.a.a(new y2(this, callable, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(p.a.x0.e eVar) {
p.a.y0.b.b.a(eVar, "stop is null");
return p.a.c1.a.a(new b3(this, eVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final <R> l<R> a(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar, int i2, long j2, TimeUnit timeUnit) {
return a(oVar, i2, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar, int i2, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return d3.a(s1.a(this, i2, j2, timeUnit, j0Var), (p.a.x0.o) oVar);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar, int i2, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
return d3.a(s1.a(this, i2), s1.a(oVar, j0Var));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final <R> l<R> a(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar, long j2, TimeUnit timeUnit) {
return a(oVar, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return d3.a(s1.a(this, j2, timeUnit, j0Var), (p.a.x0.o) oVar);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <R> l<R> a(p.a.x0.o<? super l<T>, ? extends x.g.c<R>> oVar, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return d3.a(s1.a(this), s1.a(oVar, j0Var));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final p.a.w0.a<T> a(int i2, long j2, TimeUnit timeUnit) {
return a(i2, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.w0.a<T> a(int i2, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
return d3.a(this, j2, timeUnit, j0Var, i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.w0.a<T> a(int i2, j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return d3.a((p.a.w0.a) h(i2), j0Var);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(long j2, p.a.x0.r<? super Throwable> rVar) {
if (j2 >= 0) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new f3(this, j2, rVar));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <U> l<T> a(x.g.c<U> cVar, boolean z2) {
p.a.y0.b.b.a(cVar, "sampler is null");
return p.a.c1.a.a(new h3(this, cVar, z2));
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final l<T> a(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2, int i2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new u3(this, j2, timeUnit, j0Var, i2 << 1, z2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(Comparator<? super T> comparator) {
p.a.y0.b.b.a(comparator, "sortFunction");
return N().n().v(p.a.y0.b.a.a((Comparator) comparator)).r(p.a.y0.b.a.e());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(Iterable<? extends T> iterable) {
return b(f((Iterable) iterable), this);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> a(T... tArr) {
l b = b((Object[]) tArr);
if (b == R()) {
return p.a.c1.a.a(this);
}
return b(b, this);
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.h("none")
public final void a(q<? super T> qVar) {
p.a.y0.b.b.a(qVar, "s is null");
try {
x.g.d<? super T> a2 = p.a.c1.a.a(this, qVar);
p.a.y0.b.b.a(a2, "The RxJavaPlugins.onSubscribe hook returned a null FlowableSubscriber. Please check the handler provided to RxJavaPlugins.setOnFlowableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
e((x.g.d) a2);
} catch (NullPointerException e2) {
throw e2;
} catch (Throwable th) {
p.a.v0.b.b(th);
p.a.c1.a.b(th);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final <E extends x.g.d<? super T>> E a(E e2) {
subscribe(e2);
return e2;
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(long j2, long j3, TimeUnit timeUnit, j0 j0Var, boolean z2, int i2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
if (j2 >= 0) {
return p.a.c1.a.a(new d4(this, j2, j3, timeUnit, j0Var, i2, z2));
}
throw new IndexOutOfBoundsException("count >= 0 required but it was " + j2);
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<p.a.e1.d<T>> a(TimeUnit timeUnit) {
return a(timeUnit, p.a.e1.b.a());
}
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
@p.a.t0.h("none")
public final l<p.a.e1.d<T>> a(TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new k4(this, timeUnit, j0Var));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <V> l<T> a(p.a.x0.o<? super T, ? extends x.g.c<V>> oVar, l<? extends T> lVar) {
p.a.y0.b.b.a(lVar, "other is null");
return b((x.g.c) null, oVar, lVar);
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.L0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(long j2, TimeUnit timeUnit, x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return a(j2, timeUnit, cVar, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final l<T> a(long j2, TimeUnit timeUnit, j0 j0Var, x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "other is null");
return a(j2, timeUnit, cVar, j0Var);
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U, V> l<T> a(x.g.c<U> cVar, p.a.x0.o<? super T, ? extends x.g.c<V>> oVar, x.g.c<? extends T> cVar2) {
p.a.y0.b.b.a(cVar, "firstTimeoutSelector is null");
p.a.y0.b.b.a(cVar2, "other is null");
return b(cVar, oVar, cVar2);
}
private l<T> a(long j2, TimeUnit timeUnit, x.g.c<? extends T> cVar, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "timeUnit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new m4(this, j2, timeUnit, j0Var, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final <K, V> k0<Map<K, Collection<V>>> a(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, Callable<? extends Map<K, Collection<V>>> callable, p.a.x0.o<? super K, ? extends Collection<? super V>> oVar3) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
p.a.y0.b.b.a(callable, "mapSupplier is null");
p.a.y0.b.b.a(oVar3, "collectionFactory is null");
return (k0<Map<K, Collection<V>>>) a((Callable) callable, (p.a.x0.b) p.a.y0.b.a.a(oVar, oVar2, oVar3));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public final k0<List<T>> a(Comparator<? super T> comparator, int i2) {
p.a.y0.b.b.a(comparator, "comparator is null");
return (k0<List<T>>) k(i2).i(p.a.y0.b.a.a((Comparator) comparator));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<l<T>> a(long j2, long j3) {
return a(j2, j3, Q());
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<l<T>> a(long j2, long j3, int i2) {
p.a.y0.b.b.b(j3, "skip");
p.a.y0.b.b.b(j2, "count");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new s4(this, j2, j3, i2));
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final l<l<T>> a(long j2, long j3, TimeUnit timeUnit, j0 j0Var, int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.b(j2, "timespan");
p.a.y0.b.b.b(j3, "timeskip");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
return p.a.c1.a.a(new w4(this, j2, j3, timeUnit, j0Var, Long.MAX_VALUE, i2, false));
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<l<T>> a(long j2, TimeUnit timeUnit, long j3) {
return a(j2, timeUnit, p.a.e1.b.a(), j3, false);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final l<l<T>> a(long j2, TimeUnit timeUnit, long j3, boolean z2) {
return a(j2, timeUnit, p.a.e1.b.a(), j3, z2);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<l<T>> a(long j2, TimeUnit timeUnit, j0 j0Var, long j3) {
return a(j2, timeUnit, j0Var, j3, false);
}
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final l<l<T>> a(long j2, TimeUnit timeUnit, j0 j0Var, long j3, boolean z2) {
return a(j2, timeUnit, j0Var, j3, z2, Q());
}
@p.a.t0.f
@p.a.t0.h(p.a.t0.h.K0)
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final l<l<T>> a(long j2, TimeUnit timeUnit, j0 j0Var, long j3, boolean z2, int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.b(j3, "count");
return p.a.c1.a.a(new w4(this, j2, j2, timeUnit, j0Var, j3, i2, z2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <U, V> l<l<T>> a(x.g.c<U> cVar, p.a.x0.o<? super U, ? extends x.g.c<V>> oVar, int i2) {
p.a.y0.b.b.a(cVar, "openingIndicator is null");
p.a.y0.b.b.a(oVar, "closingIndicator is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new u4(this, cVar, oVar, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.ERROR)
@p.a.t0.d
public final <B> l<l<T>> a(Callable<? extends x.g.c<B>> callable, int i2) {
p.a.y0.b.b.a(callable, "boundaryIndicatorSupplier is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new v4(this, callable, i2));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <U, R> l<R> a(x.g.c<? extends U> cVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar2) {
p.a.y0.b.b.a(cVar, "other is null");
p.a.y0.b.b.a(cVar2, "combiner is null");
return p.a.c1.a.a(new x4(this, cVar2, cVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <T1, T2, R> l<R> a(x.g.c<T1> cVar, x.g.c<T2> cVar2, p.a.x0.h<? super T, ? super T1, ? super T2, R> hVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
return a((x.g.c<?>[]) new x.g.c[]{cVar, cVar2}, p.a.y0.b.a.a((p.a.x0.h) hVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <T1, T2, T3, R> l<R> a(x.g.c<T1> cVar, x.g.c<T2> cVar2, x.g.c<T3> cVar3, p.a.x0.i<? super T, ? super T1, ? super T2, ? super T3, R> iVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
return a((x.g.c<?>[]) new x.g.c[]{cVar, cVar2, cVar3}, p.a.y0.b.a.a((p.a.x0.i) iVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <T1, T2, T3, T4, R> l<R> a(x.g.c<T1> cVar, x.g.c<T2> cVar2, x.g.c<T3> cVar3, x.g.c<T4> cVar4, p.a.x0.j<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> jVar) {
p.a.y0.b.b.a(cVar, "source1 is null");
p.a.y0.b.b.a(cVar2, "source2 is null");
p.a.y0.b.b.a(cVar3, "source3 is null");
p.a.y0.b.b.a(cVar4, "source4 is null");
return a((x.g.c<?>[]) new x.g.c[]{cVar, cVar2, cVar3, cVar4}, p.a.y0.b.a.a((p.a.x0.j) jVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <R> l<R> a(x.g.c<?>[] cVarArr, p.a.x0.o<? super Object[], R> oVar) {
p.a.y0.b.b.a(cVarArr, "others is null");
p.a.y0.b.b.a(oVar, "combiner is null");
return p.a.c1.a.a(new y4(this, cVarArr, oVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.PASS_THROUGH)
@p.a.t0.d
public final <R> l<R> a(Iterable<? extends x.g.c<?>> iterable, p.a.x0.o<? super Object[], R> oVar) {
p.a.y0.b.b.a(iterable, "others is null");
p.a.y0.b.b.a(oVar, "combiner is null");
return p.a.c1.a.a(new y4(this, iterable, oVar));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
public final <U, R> l<R> a(Iterable<U> iterable, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
p.a.y0.b.b.a(iterable, "other is null");
p.a.y0.b.b.a(cVar, "zipper is null");
return p.a.c1.a.a(new a5(this, iterable, cVar));
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> l<R> a(x.g.c<? extends U> cVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar2, boolean z2) {
return a(this, cVar, cVar2, z2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> l<R> a(x.g.c<? extends U> cVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar2, boolean z2, int i2) {
return a(this, cVar, cVar2, z2, i2);
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.g1.f<T> a(long j2) {
p.a.g1.f<T> fVar = new p.a.g1.f<>(j2);
a((q) fVar);
return fVar;
}
@p.a.t0.b(p.a.t0.a.FULL)
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.g1.f<T> a(long j2, boolean z2) {
p.a.g1.f<T> fVar = new p.a.g1.f<>(j2);
if (z2) {
fVar.cancel();
}
a((q) fVar);
return fVar;
}
}