Sunbit v2.4.4版本的 MD5 值为：a5021e5e2a58eb1d6741b432fe7533c4
以下内容为反编译后的 s.java 源代码，内容仅作参考
package h.a.a.c;
import h.a.a.h.f.b.a2;
import h.a.a.h.f.b.a4;
import h.a.a.h.f.b.b1;
import h.a.a.h.f.b.b2;
import h.a.a.h.f.b.b3;
import h.a.a.h.f.b.b4;
import h.a.a.h.f.b.b5;
import h.a.a.h.f.b.c1;
import h.a.a.h.f.b.c2;
import h.a.a.h.f.b.c3;
import h.a.a.h.f.b.c4;
import h.a.a.h.f.b.c5;
import h.a.a.h.f.b.d2;
import h.a.a.h.f.b.d3;
import h.a.a.h.f.b.d4;
import h.a.a.h.f.b.d5;
import h.a.a.h.f.b.e1;
import h.a.a.h.f.b.e2;
import h.a.a.h.f.b.e4;
import h.a.a.h.f.b.e5;
import h.a.a.h.f.b.f2;
import h.a.a.h.f.b.f3;
import h.a.a.h.f.b.f4;
import h.a.a.h.f.b.f5;
import h.a.a.h.f.b.g1;
import h.a.a.h.f.b.g2;
import h.a.a.h.f.b.g3;
import h.a.a.h.f.b.g4;
import h.a.a.h.f.b.h1;
import h.a.a.h.f.b.h3;
import h.a.a.h.f.b.h4;
import h.a.a.h.f.b.i2;
import h.a.a.h.f.b.i3;
import h.a.a.h.f.b.i4;
import h.a.a.h.f.b.j1;
import h.a.a.h.f.b.j2;
import h.a.a.h.f.b.j3;
import h.a.a.h.f.b.k1;
import h.a.a.h.f.b.k2;
import h.a.a.h.f.b.k3;
import h.a.a.h.f.b.k4;
import h.a.a.h.f.b.l1;
import h.a.a.h.f.b.l2;
import h.a.a.h.f.b.l3;
import h.a.a.h.f.b.l4;
import h.a.a.h.f.b.m1;
import h.a.a.h.f.b.m2;
import h.a.a.h.f.b.m3;
import h.a.a.h.f.b.m4;
import h.a.a.h.f.b.n1;
import h.a.a.h.f.b.n2;
import h.a.a.h.f.b.n3;
import h.a.a.h.f.b.n4;
import h.a.a.h.f.b.o1;
import h.a.a.h.f.b.o2;
import h.a.a.h.f.b.o3;
import h.a.a.h.f.b.o4;
import h.a.a.h.f.b.p2;
import h.a.a.h.f.b.p3;
import h.a.a.h.f.b.p4;
import h.a.a.h.f.b.q1;
import h.a.a.h.f.b.q2;
import h.a.a.h.f.b.q3;
import h.a.a.h.f.b.q4;
import h.a.a.h.f.b.r1;
import h.a.a.h.f.b.r2;
import h.a.a.h.f.b.r4;
import h.a.a.h.f.b.s1;
import h.a.a.h.f.b.s2;
import h.a.a.h.f.b.s3;
import h.a.a.h.f.b.s4;
import h.a.a.h.f.b.t1;
import h.a.a.h.f.b.t2;
import h.a.a.h.f.b.t3;
import h.a.a.h.f.b.u1;
import h.a.a.h.f.b.u2;
import h.a.a.h.f.b.u4;
import h.a.a.h.f.b.v1;
import h.a.a.h.f.b.v2;
import h.a.a.h.f.b.v3;
import h.a.a.h.f.b.v4;
import h.a.a.h.f.b.w1;
import h.a.a.h.f.b.w2;
import h.a.a.h.f.b.w3;
import h.a.a.h.f.b.w4;
import h.a.a.h.f.b.x1;
import h.a.a.h.f.b.x2;
import h.a.a.h.f.b.x3;
import h.a.a.h.f.b.x4;
import h.a.a.h.f.b.y1;
import h.a.a.h.f.b.y2;
import h.a.a.h.f.b.y3;
import h.a.a.h.f.b.y4;
import h.a.a.h.f.b.z0;
import h.a.a.h.f.b.z1;
import h.a.a.h.f.b.z2;
import h.a.a.h.f.b.z3;
import h.a.a.h.f.b.z4;
import h.a.a.h.f.c.p1;
import h.a.a.h.f.e.i1;
import h.a.a.h.f.g.a1;
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.Objects;
import java.util.Optional;
import java.util.Spliterators;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Collector;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
import me.leolin.shortcutbadger.impl.NewHtcHomeBadger;
public abstract class s<T> implements q.i.c<T> {
static final int f13244a = Math.max(1, Integer.getInteger("rx3.buffer-size", 128).intValue());
static class a {
static final int[] f13245a;
static {
int[] iArr = new int[i.values().length];
f13245a = iArr;
try {
iArr[i.DROP.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
f13245a[i.LATEST.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
try {
f13245a[i.MISSING.ordinal()] = 3;
} catch (NoSuchFieldError unused3) {
}
try {
f13245a[i.ERROR.ordinal()] = 4;
} catch (NoSuchFieldError unused4) {
}
}
}
@h.a.a.b.d
public static int U() {
return f13244a;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> V() {
return h.a.a.l.a.a(h.a.a.h.f.b.w0.b);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> W() {
return h.a.a.l.a.a(m2.b);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> a(@h.a.a.b.f q.i.c<? extends T>... cVarArr) {
Objects.requireNonNull(cVarArr, "sources is null");
int length = cVarArr.length;
if (length == 0) {
return V();
}
if (length == 1) {
return q(cVarArr[0]);
}
return h.a.a.l.a.a(new h.a.a.h.f.b.h(cVarArr, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> b(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.h(null, iterable));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> c(@h.a.a.b.f q.i.c<? extends T>[] cVarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return b(cVarArr, oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f q.i.c<? extends T>... cVarArr) {
return a(U(), U(), cVarArr);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> e(@h.a.a.b.f q.i.c<? extends T>... cVarArr) {
return b(U(), U(), cVarArr);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> f(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable) {
return b(iterable, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> g(@h.a.a.b.f Iterable<? extends T> iterable) {
Objects.requireNonNull(iterable, "source is null");
return h.a.a.l.a.a(new m1(iterable));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> h(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable) {
return g((Iterable) iterable).q(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> i(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable) {
return g((Iterable) iterable).e(h.a.a.h.b.a.e(), true);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> k(@h.a.a.b.f h.a.a.g.g<r<T>> gVar) {
Objects.requireNonNull(gVar, "generator is null");
return a(h.a.a.h.b.a.g(), x1.a(gVar), h.a.a.h.b.a.d());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> m(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return c(cVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> n(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return a((q.i.c) cVar, U(), true);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> o(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return a(cVar, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> p(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return b(cVar, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> q(@h.a.a.b.f q.i.c<? extends T> cVar) {
if (cVar instanceof s) {
return h.a.a.l.a.a((s) cVar);
}
Objects.requireNonNull(cVar, "publisher is null");
return h.a.a.l.a.a(new o1(cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> r(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return d(cVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> s(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return e(cVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> t(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return q(cVar).F(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> u(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar) {
return g(cVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.NONE)
public static <T> s<T> v(@h.a.a.b.f q.i.c<T> cVar) {
Objects.requireNonNull(cVar, "onSubscribe is null");
if (!(cVar instanceof s)) {
return h.a.a.l.a.a(new o1(cVar));
}
throw new IllegalArgumentException("unsafeCreate(Flowable) should be upgraded");
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> A(@h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends T> oVar) {
Objects.requireNonNull(oVar, "itemSupplier is null");
return h.a.a.l.a.a(new v2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.k.b<T> B() {
return h.a.a.k.b.a(this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> C() {
return g(U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> D() {
return c((long) k.c3.w.p0.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> E() {
return i3.a((s) this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> F() {
return a((long) k.c3.w.p0.c, h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> G() {
return h.a.a.l.a.a(new t3(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> H() {
return C().Z();
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final z<T> I() {
return h.a.a.l.a.a(new v3(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<T> J() {
return h.a.a.l.a.a(new w3(this, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> K(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.j(this, oVar, true));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> L() {
return R().s().x(h.a.a.h.b.a.a(h.a.a.h.b.a.f())).s(h.a.a.h.b.a.e());
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
@h.a.a.b.f
public final h.a.a.d.f M() {
return b(h.a.a.h.b.a.d(), h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <V> s<T> N(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<V>> oVar) {
return b((q.i.c) null, oVar, (q.i.c) null);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> O() {
return a(TimeUnit.MILLISECONDS, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> P() {
return b(TimeUnit.MILLISECONDS, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final Future<T> Q() {
return (Future) f((s<T>) new h.a.a.h.i.j());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<List<T>> R() {
return h.a.a.l.a.a(new u4(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final i0<T> S() {
return h.a.a.l.a.a(new i1(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<List<T>> T() {
return b((Comparator) h.a.a.h.b.a.f());
}
protected abstract void e(@h.a.a.b.f q.i.d<? super T> dVar);
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> j(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
return d((h.a.a.g.o) oVar, true, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <U> s<T> l(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<U>> oVar) {
Objects.requireNonNull(oVar, "debounceIndicator is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.f0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <K> s<h.a.a.f.b<K, T>> w(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar) {
return (s<h.a.a.f.b<K, T>>) a((h.a.a.g.o) oVar, (h.a.a.g.o) h.a.a.h.b.a.e(), false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <R> s<R> x(@h.a.a.b.f h.a.a.g.o<? super T, ? extends R> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new f2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> y() {
return h.a.a.l.a.a(new s2(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> z() {
return e(h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> c(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return b(iterable, oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return g((Iterable) iterable).d(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> e(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable) {
return a(iterable, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> f(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "action is null");
return h.a.a.l.a.a((s) new h1(aVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> p(T t) {
Objects.requireNonNull(t, "item is null");
return h.a.a.l.a.a((s) new b2(t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> r(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return r(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> B(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar) {
return j(oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> C(@h.a.a.b.f h.a.a.g.o<? super s<Object>, ? extends q.i.c<?>> oVar) {
Objects.requireNonNull(oVar, "handler is null");
return h.a.a.l.a.a(new h3(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> D(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar) {
Objects.requireNonNull(oVar, "selector is null");
return i3.a(x1.a(this), (h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> E(@h.a.a.b.f h.a.a.g.o<? super s<Throwable>, ? extends q.i.c<?>> oVar) {
Objects.requireNonNull(oVar, "handler is null");
return h.a.a.l.a.a(new l3(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> F(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar) {
return l(oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final j G(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.h(this, oVar, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final j H(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.h(this, oVar, true));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final <R> s<R> I(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar) {
return m(oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> J(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.j(this, oVar, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> L(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.l(this, oVar, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> M(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.l(this, oVar, true));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final h.a.a.p.f<T> N() {
h.a.a.p.f<T> fVar = new h.a.a.p.f<>();
a((x) fVar);
return fVar;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <K> r0<Map<K, T>> O(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar) {
Objects.requireNonNull(oVar, "keySelector is null");
return (r0<Map<K, T>>) a((h.a.a.g.s) h.a.a.h.k.m.a(), (h.a.a.g.b) h.a.a.h.b.a.a((h.a.a.g.o) oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <K> r0<Map<K, Collection<T>>> P(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar) {
return (r0<Map<K, Collection<T>>>) a((h.a.a.g.o) oVar, (h.a.a.g.o) h.a.a.h.b.a.e(), (h.a.a.g.s) h.a.a.h.k.m.a(), (h.a.a.g.o) h.a.a.h.k.b.a());
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final void h() {
h.a.a.h.f.b.l.a(this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> i() {
return d(16);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<Long> j() {
return h.a.a.l.a.a(new h.a.a.h.f.b.d0(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U> s<T> m(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<U>> oVar) {
Objects.requireNonNull(oVar, "itemDelayIndicator is null");
return (s<T>) q(x1.b(oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <R> s<R> n(@h.a.a.b.f h.a.a.g.o<? super T, h0<R>> oVar) {
Objects.requireNonNull(oVar, "selector is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.k0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <K> s<T> o(@h.a.a.b.f h.a.a.g.o<? super T, K> oVar) {
return a((h.a.a.g.o) oVar, (h.a.a.g.s) h.a.a.h.b.a.c());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U> s<U> s(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar) {
return h(oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> t(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
return g((h.a.a.g.o) oVar, false, Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> u(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
return h((h.a.a.g.o) oVar, false, Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> w() {
return a(U(), false, true);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> y(@h.a.a.b.f h.a.a.g.o<? super T, Optional<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.d.j(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> z(@h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends q.i.c<? extends T>> oVar) {
Objects.requireNonNull(oVar, "fallbackSupplier is null");
return h.a.a.l.a.a(new u2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> b(@h.a.a.b.f q.i.c<? extends T>[] cVarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return a(cVarArr, oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return g((Iterable) iterable).b(h.a.a.h.b.a.e(), false, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> e(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2) {
return q(cVar).e(h.a.a.h.b.a.e(), true, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> g(@h.a.a.b.f q.i.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).e(h.a.a.h.b.a.e(), true, cVarArr.length);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> r(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new s4(Math.max(0L, j2), timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> A() {
return h.a.a.l.a.a(new h.a.a.h.f.b.l0(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final CompletionStage<T> K() {
return (CompletionStage) f((s<T>) new h.a.a.h.d.k(false, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> h(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
return c((h.a.a.g.o) oVar, true, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> i(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
return e(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<T> j(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
return h.a.a.l.a.a(new d2(this, t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> l() {
return p((h.a.a.g.o) h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> o(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "item is null");
return b(p(t), this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final z<T> s() {
return h.a.a.l.a.a(new c2(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<T> t() {
return h.a.a.l.a.a(new d2(this, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final CompletionStage<T> u() {
return (CompletionStage) f((s<T>) new h.a.a.h.d.i(false, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> x() {
return h.a.a.l.a.a((s) new q2(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> b(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return a(iterable, oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> d(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "completableSource is null");
return h.a.a.l.a.a(new k1(pVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> f(@h.a.a.b.f q.i.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).g(h.a.a.h.b.a.e(), cVarArr.length);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> g(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2) {
return q(cVar).m(h.a.a.h.b.a.e(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final Iterable<T> e() {
return new h.a.a.h.f.b.e(this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final r0<T> h(@h.a.a.b.f T t) {
return a(0L, (long) t);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> i(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
Objects.requireNonNull(gVar, "onDrop is null");
return h.a.a.l.a.a((s) new q2(this, gVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> l(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "item is null");
return A(h.a.a.h.b.a.c(t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final z<T> m() {
return a(0L);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final r0<T> n() {
return b(0L);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <K> s<T> p(@h.a.a.b.f h.a.a.g.o<? super T, K> oVar) {
Objects.requireNonNull(oVar, "keySelector is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.n0(this, oVar, h.a.a.h.b.b.a()));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> b(@h.a.a.b.f q.i.c<? extends T>[] cVarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(cVarArr, "sources is null");
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (cVarArr.length == 0) {
return V();
}
return h.a.a.l.a.a(new h.a.a.h.f.b.t((q.i.c[]) cVarArr, (h.a.a.g.o) oVar, i2, true));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2) {
return q(cVar).a(h.a.a.h.b.a.e(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> f(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2) {
return q(cVar).l(h.a.a.h.b.a.e(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> q(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return d(j2, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final T e(@h.a.a.b.f T t) {
return m((s<T>) t).d();
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> g(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
return d(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U> s<U> h(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new g1(this, oVar, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> j(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "selector is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new x2(this, oVar, i2, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<T> m(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
return h.a.a.l.a.a(new w3(this, t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> n(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return b(j2, timeUnit);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> o(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, timeUnit, (q.i.c) null, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<h0<T>> v() {
return h.a.a.l.a.a(new i2(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> a(@h.a.a.b.f q.i.c<? extends T>[] cVarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(cVarArr, "sources is null");
if (cVarArr.length == 0) {
return V();
}
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.b.t((q.i.c[]) cVarArr, (h.a.a.g.o) oVar, i2, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f q.i.c<? extends T>... cVarArr) {
Objects.requireNonNull(cVarArr, "sources is null");
if (cVarArr.length == 0) {
return V();
}
if (cVarArr.length == 1) {
return q(cVarArr[0]);
}
return h.a.a.l.a.a(new h.a.a.h.f.b.u(cVarArr, true));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f f0<T> f0Var) {
Objects.requireNonNull(f0Var, "maybe is null");
return h.a.a.l.a.a(new p1(f0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> q(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return d(j2, j2, timeUnit, q0Var);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> e(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar) {
return a(oVar, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final T f() {
return J().d();
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> g(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
return j((q.i.c) p(t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> i(int i2) {
h.a.a.h.b.b.a(i2, "bufferSize");
return i3.a((s) this, i2, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> k() {
return a((h.a.a.g.o) h.a.a.h.b.a.e(), (h.a.a.g.s) h.a.a.h.b.a.c());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> l(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, int i2) {
return b((h.a.a.g.o) oVar, i2, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> n(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return b(j2, timeUnit, q0Var);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> o(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return a(j2, timeUnit, (q.i.c) null, q0Var);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> p() {
return h.a.a.l.a.a(new u1(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final j r(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
return f((h.a.a.g.o) oVar, false, Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> v(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar) {
return i(oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> e(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.d.f(this, oVar, h.a.a.h.k.j.IMMEDIATE, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U> s<U> f(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar) {
return c(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> k(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, int i2) {
Objects.requireNonNull(oVar, "selector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return i3.a(x1.a(this, i2, false), (h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> l(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return f(j2, timeUnit);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final <R> s<R> m(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, int i2) {
return b((h.a.a.g.o) oVar, i2, true);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final CompletionStage<T> n(@h.a.a.b.g T t) {
return (CompletionStage) f((s<T>) new h.a.a.h.d.k(true, t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final CompletionStage<T> o() {
return (CompletionStage) f((s<T>) new h.a.a.h.d.e(false, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> p(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, timeUnit, h.a.a.n.b.a(), (long) k.c3.w.p0.c, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> q(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar) {
return b((h.a.a.g.o) oVar, false, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<Boolean> r() {
return a(h.a.a.h.b.a.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f x0<T> x0Var) {
Objects.requireNonNull(x0Var, "source is null");
return h.a.a.l.a.a(new a1(x0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<Boolean> f(@h.a.a.b.f Object obj) {
Objects.requireNonNull(obj, "item is null");
return b((h.a.a.g.r) h.a.a.h.b.a.a(obj));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> g(@h.a.a.b.f h.a.a.g.g<? super q.i.e> gVar) {
return a(gVar, h.a.a.h.b.a.f13258g, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> h(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
return h.a.a.l.a.a(new e1(this, oVar, z, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> i(@h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "other is null");
return b(cVar, this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> j(int i2) {
if (i2 >= 0) {
if (i2 == 0) {
return h.a.a.l.a.a(this);
}
return h.a.a.l.a.a(new y3(this, i2));
}
throw new IllegalArgumentException("count >= 0 required but it was " + i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> l(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return f(j2, timeUnit, q0Var);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> m(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return f(j2, timeUnit, h.a.a.n.b.a(), false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> p(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return a(j2, timeUnit, q0Var, (long) k.c3.w.p0.c, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final j q() {
return h.a.a.l.a.a(new w1(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> g(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, int i2) {
return b((h.a.a.g.o) oVar, false, i2, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<List<T>> l(int i2) {
h.a.a.h.b.b.a(i2, "capacityHint");
return h.a.a.l.a.a(new u4(this, h.a.a.h.b.a.b(i2)));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> m(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return f(j2, timeUnit, q0Var, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f h.a.a.g.s<? extends T> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a((s) new q1(sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> e(@h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
h.a.a.g.g<? super T> d2 = h.a.a.h.b.a.d();
h.a.a.g.a aVar = h.a.a.h.b.a.c;
return a((h.a.a.g.g) d2, gVar, aVar, aVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> f(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
h.a.a.g.g<? super Throwable> d2 = h.a.a.h.b.a.d();
h.a.a.g.a aVar = h.a.a.h.b.a.c;
return a((h.a.a.g.g) gVar, d2, aVar, aVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> s<R> g(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
return h.a.a.l.a.a(new c1(this, oVar, z, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> i(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return k((q.i.c) r(j2, timeUnit));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> k(int i2) {
if (i2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + i2);
} else if (i2 == 0) {
return h.a.a.l.a.a(new v1(this));
} else {
if (i2 == 1) {
return h.a.a.l.a.a(new h4(this));
}
return h.a.a.l.a.a(new g4(this, i2));
}
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<List<T>> m(int i2) {
return a(h.a.a.h.b.a.f(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> b(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(iterable, "sources is null");
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.b.t((Iterable) iterable, (h.a.a.g.o) oVar, i2, true));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> e(@h.a.a.b.f h.a.a.g.a aVar) {
return a((h.a.a.g.g) h.a.a.h.b.a.d(), h.a.a.h.b.a.a(aVar), aVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final j f(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
return h.a.a.l.a.a(new b1(this, oVar, z, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.NONE)
public final h.a.a.d.f h(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
return j((h.a.a.g.g) gVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> i(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return k((q.i.c) r(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final h.a.a.d.f j(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
return b(gVar, h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <B> s<s<T>> l(@h.a.a.b.f q.i.c<B> cVar) {
return b(cVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> a(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(iterable, "sources is null");
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.b.t((Iterable) iterable, (h.a.a.g.o) oVar, i2, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> c(@h.a.a.b.f h.a.a.g.s<? extends Throwable> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.x0(sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> d(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return d(j2, j3, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> e(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, boolean z) {
return b(oVar, z, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> h(int i2) {
return a(h.a.a.h.h.e.b, true, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> i(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new m4(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> j(@h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "other is null");
return h.a.a.l.a.a(new d4(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> d(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new y1(Math.max(0L, j2), Math.max(0L, j3), timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> e(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, boolean z, int i2) {
return b(oVar, z, i2, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> g(int i2) {
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a((h.a.a.f.a) new w2(this, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> h(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, timeUnit, h.a.a.n.b.a(), false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, S> s<T> c(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.c<S, r<T>, S> cVar) {
return a((h.a.a.g.s) sVar, (h.a.a.g.c) cVar, h.a.a.h.b.a.d());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> e(@h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "other is null");
return b(this, cVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <K> s<h.a.a.f.b<K, T>> f(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, boolean z) {
return (s<h.a.a.f.b<K, T>>) a(oVar, h.a.a.h.b.a.e(), z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> h(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return a(j2, timeUnit, q0Var, false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final CompletionStage<T> i(@h.a.a.b.g T t) {
return (CompletionStage) f((s<T>) new h.a.a.h.d.e(true, t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> j(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return b(j2, timeUnit, h.a.a.n.b.a(), false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <U> s<T> k(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "other is null");
return h.a.a.l.a.a(new k4(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f q.i.c<? extends T>... cVarArr) {
Objects.requireNonNull(cVarArr, "sources is null");
if (cVarArr.length == 0) {
return V();
}
if (cVarArr.length == 1) {
return q(cVarArr[0]);
}
return h.a.a.l.a.a(new h.a.a.h.f.b.u(cVarArr, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, int i2, int i3) {
return g((Iterable) iterable).b(h.a.a.h.b.a.e(), false, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> f(@h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "fallback is null");
return z(h.a.a.h.b.a.c(cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <U> s<T> g(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "sampler is null");
return h.a.a.l.a.a(new m3(this, cVar, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U> s<T> h(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "other is null");
return h.a.a.l.a.a(new a4(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> i(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.d.f(this, oVar, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> j(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return b(j2, timeUnit, q0Var, false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar3) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "combiner is null");
return a(new q.i.c[]{cVar, cVar2}, h.a.a.h.b.a.a((h.a.a.g.c) cVar3), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(int i2, int i3, @h.a.a.b.f q.i.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).b(h.a.a.h.b.a.e(), false, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2) {
return q(cVar).g(h.a.a.h.b.a.e(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> e(int i2) {
return a(i2, false, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> k(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return k(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
return b((Object[]) new q.i.c[]{cVar, cVar2}).e(h.a.a.h.b.a.e(), true, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, int i2, int i3) {
return g((Iterable) iterable).b(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> e(@h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new t2(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.k.b<T> f(int i2) {
return h.a.a.k.b.a(this, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> g(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return h((q.i.c) r(j2, timeUnit));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> h(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "stopPredicate is null");
return h.a.a.l.a.a(new l4(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> k(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new n4(this, j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> d(int i2, int i3, @h.a.a.b.f q.i.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).b(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> f(@h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
return a((long) k.c3.w.p0.c, rVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> g(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return h((q.i.c) r(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> r0<Boolean> d(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2) {
return a(cVar, cVar2, h.a.a.h.b.b.a(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> e(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return e(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> f(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return f(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> g(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new b4(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<s<T>> h(long j2) {
return a(j2, j2, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f h.a.a.g.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(hVar, "combiner is null");
return a(new q.i.c[]{cVar, cVar2, cVar3}, h.a.a.h.b.a.a((h.a.a.g.h) hVar), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f q.i.c<? extends T> cVar3) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
return b((Object[]) new q.i.c[]{cVar, cVar2, cVar3}).e(h.a.a.h.b.a.e(), true, 3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> d(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
Objects.requireNonNull(oVar, "zipper is null");
Objects.requireNonNull(iterable, "sources is null");
return h.a.a.l.a.a(new e5(null, iterable, oVar, U(), false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> e(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return i3.a((s) this, j2, timeUnit, q0Var, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> f(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new n3(this, j2, timeUnit, q0Var, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final CompletionStage<T> k(@h.a.a.b.g T t) {
return (CompletionStage) f((s<T>) new h.a.a.h.d.i(true, t));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(int i2, int i3, @h.a.a.b.f q.i.c<? extends T>... cVarArr) {
return b((Object[]) cVarArr).a(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.p.f<T> g(long j2) {
h.a.a.p.f<T> fVar = new h.a.a.p.f<>(j2);
a((x) fVar);
return fVar;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> k(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar) {
return i(oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, int i2, int i3) {
Objects.requireNonNull(iterable, "sources is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.b.w(new m1(iterable), h.a.a.h.b.a.e(), i2, i3, h.a.a.h.k.j.END));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final Iterable<T> d() {
return new h.a.a.h.f.b.c(this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> e(long j2) {
int i2 = (j2 > 0L ? 1 : (j2 == 0L ? 0 : -1));
if (i2 >= 0) {
if (i2 == 0) {
return h.a.a.l.a.a(this);
}
return h.a.a.l.a.a(new x3(this, j2));
}
throw new IllegalArgumentException("count >= 0 expected but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final <E extends q.i.d<? super T>> E f(E e2) {
a(e2);
return e2;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final Stream<T> g() {
return b(U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> c(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f q.i.c<? extends T> cVar3, @h.a.a.b.f q.i.c<? extends T> cVar4) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
return b((Object[]) new q.i.c[]{cVar, cVar2, cVar3, cVar4}).e(h.a.a.h.b.a.e(), true, 4);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final Iterable<T> d(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "initialItem is null");
return new h.a.a.h.f.b.d(this, t);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> f(long j2) {
if (j2 >= 0) {
return h.a.a.l.a.a(new f4(this, j2));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f h.a.a.g.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(iVar, "combiner is null");
return a(new q.i.c[]{cVar, cVar2, cVar3, cVar4}, h.a.a.h.b.a.a((h.a.a.g.i) iVar), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2, int i3) {
Objects.requireNonNull(cVar, "sources is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.b.x(cVar, h.a.a.h.b.a.e(), i2, i3, h.a.a.h.k.j.END));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> d(int i2) {
h.a.a.h.b.b.a(i2, "initialCapacity");
return h.a.a.l.a.a(new h.a.a.h.f.b.q(this, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> e(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
return b(j2, timeUnit, q0Var, z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> f(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new o4(this, j2, timeUnit, q0Var, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> e(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return f(j2, timeUnit, h.a.a.n.b.a(), z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> d(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar) {
return b((h.a.a.g.o) oVar, true, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> e(@h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new v4(this, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static s<Integer> c(int i2, int i3) {
if (i3 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + i3);
} else if (i3 == 0) {
return V();
} else {
if (i3 == 1) {
return p(Integer.valueOf(i2));
}
if (i2 + (i3 - 1) <= 2147483647L) {
return h.a.a.l.a.a(new y2(i2, i3));
}
throw new IllegalArgumentException("Integer overflow");
}
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> d(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.d.d(this, oVar, h.a.a.h.k.j.IMMEDIATE, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> f(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.d.f(this, oVar, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> b(@h.a.a.b.f h.a.a.g.s<? extends q.i.c<? extends T>> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.h0(sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f h.a.a.g.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(jVar, "combiner is null");
return a(new q.i.c[]{cVar, cVar2, cVar3, cVar4, cVar5}, h.a.a.h.b.a.a((h.a.a.g.j) jVar), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f T... tArr) {
Objects.requireNonNull(tArr, "items is null");
if (tArr.length == 0) {
return V();
}
if (tArr.length == 1) {
return p(tArr[0]);
}
return h.a.a.l.a.a(new h.a.a.h.f.b.i1(tArr));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> d(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, boolean z) {
return d(oVar, z, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> d(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.d.f(this, oVar, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final T c() {
h.a.a.h.i.e eVar = new h.a.a.h.i.e();
a((x) eVar);
T a2 = eVar.a();
if (a2 != null) {
return a2;
}
throw new NoSuchElementException();
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U> s<T> d(@h.a.a.b.f q.i.c<U> cVar) {
Objects.requireNonNull(cVar, "subscriptionIndicator is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.j0(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f h.a.a.g.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(kVar, "combiner is null");
return a(new q.i.c[]{cVar, cVar2, cVar3, cVar4, cVar5, cVar6}, h.a.a.h.b.a.a((h.a.a.g.k) kVar), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, S> s<T> b(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.b<S, r<T>> bVar) {
Objects.requireNonNull(bVar, "generator is null");
return a((h.a.a.g.s) sVar, x1.a(bVar), h.a.a.h.b.a.d());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final T c(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
h.a.a.h.i.e eVar = new h.a.a.h.i.e();
a((x) eVar);
T a2 = eVar.a();
return a2 != null ? a2 : t;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> d(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return d(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> d(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return d((q.i.c) r(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> d(@h.a.a.b.f h.a.a.g.a aVar) {
return a((h.a.a.g.g) h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), aVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> d(@h.a.a.b.f h.a.a.g.g<? super h0<T>> gVar) {
Objects.requireNonNull(gVar, "onNotification is null");
return a((h.a.a.g.g) h.a.a.h.b.a.c((h.a.a.g.g) gVar), (h.a.a.g.g<? super Throwable>) h.a.a.h.b.a.b((h.a.a.g.g) gVar), h.a.a.h.b.a.a((h.a.a.g.g) gVar), h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
return b((Object[]) new q.i.c[]{cVar, cVar2}).e(h.a.a.h.b.a.e(), false, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<List<T>> c(int i2) {
return a(i2, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final j c(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
return a((h.a.a.g.o) oVar, true, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U> s<U> c(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new g1(this, oVar, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f q.i.c<? extends T> cVar3) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
return b((Object[]) new q.i.c[]{cVar, cVar2, cVar3}).e(h.a.a.h.b.a.e(), false, 3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f q.i.c<? extends T7> cVar7, @h.a.a.b.f h.a.a.g.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(cVar7, "source7 is null");
Objects.requireNonNull(lVar, "combiner is null");
return a(new q.i.c[]{cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7}, h.a.a.h.b.a.a((h.a.a.g.l) lVar), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.NONE)
public final h.a.a.d.f d(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
return a((h.a.a.g.r) rVar, (h.a.a.g.g<? super Throwable>) h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> c(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, boolean z) {
return c(oVar, z, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> d(long j2) {
return a(j2, h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> c(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.d.d(this, oVar, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, i2));
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final void d(@h.a.a.b.f q.i.d<? super T> dVar) {
Objects.requireNonNull(dVar, "subscriber is null");
if (dVar instanceof h.a.a.p.d) {
a((x) ((h.a.a.p.d) dVar));
} else {
a((x) new h.a.a.p.d(dVar));
}
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f q.i.c<? extends T> cVar3, @h.a.a.b.f q.i.c<? extends T> cVar4) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
return b((Object[]) new q.i.c[]{cVar, cVar2, cVar3, cVar4}).e(h.a.a.h.b.a.e(), false, 4);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> c(@h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "other is null");
return a((q.i.c) this, (q.i.c) cVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> d(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
return a(j2, timeUnit, q0Var, z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> c(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, timeUnit, h.a.a.n.b.a(), false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> d(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return b(j2, timeUnit, h.a.a.n.b.a(), z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> b(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, int i2) {
return g((Iterable) iterable).e(h.a.a.h.b.a.e(), true, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> c(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return a(j2, timeUnit, q0Var, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> d(@h.a.a.b.f q0 q0Var) {
return b(TimeUnit.MILLISECONDS, q0Var);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f q.i.c<? extends T7> cVar7, @h.a.a.b.f q.i.c<? extends T8> cVar8, @h.a.a.b.f h.a.a.g.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(cVar7, "source7 is null");
Objects.requireNonNull(cVar8, "source8 is null");
Objects.requireNonNull(mVar, "combiner is null");
return a(new q.i.c[]{cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8}, h.a.a.h.b.a.a((h.a.a.g.m) mVar), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static s<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 V();
} else {
if (j3 == 1) {
return p(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 h.a.a.l.a.a(new z2(j2, j3));
}
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> c(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
Objects.requireNonNull(gVar, "onAfterNext is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.o0(this, gVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <U, V> s<s<T>> d(@h.a.a.b.f q.i.c<U> cVar, @h.a.a.b.f h.a.a.g.o<? super U, ? extends q.i.c<V>> oVar) {
return a(cVar, oVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> c(@h.a.a.b.f h.a.a.g.a aVar) {
return a(h.a.a.h.b.a.d(), h.a.a.h.b.a.f13258g, aVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> c(@h.a.a.b.f q.i.d<? super T> dVar) {
Objects.requireNonNull(dVar, "subscriber is null");
return a((h.a.a.g.g) x1.c(dVar), (h.a.a.g.g<? super Throwable>) x1.b(dVar), x1.a(dVar), h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar3) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.c) cVar3), false, U(), cVar, cVar2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> c(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.y0(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f h.a.a.g.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(hVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.h) hVar), false, U(), cVar, cVar2, cVar3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f q.i.c<? extends T7> cVar7, @h.a.a.b.f q.i.c<? extends T8> cVar8, @h.a.a.b.f q.i.c<? extends T9> cVar9, @h.a.a.b.f h.a.a.g.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(cVar7, "source7 is null");
Objects.requireNonNull(cVar8, "source8 is null");
Objects.requireNonNull(cVar9, "source9 is null");
Objects.requireNonNull(nVar, "combiner is null");
return a(new q.i.c[]{cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8, cVar9}, h.a.a.h.b.a.a((h.a.a.g.n) nVar), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> c(long j2) {
int i2 = (j2 > 0L ? 1 : (j2 == 0L ? 0 : -1));
if (i2 >= 0) {
if (i2 == 0) {
return V();
}
return h.a.a.l.a.a(new f3(this, j2));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> c(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new n3(this, j2, timeUnit, q0Var, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f h.a.a.g.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(iVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.i) iVar), false, U(), cVar, cVar2, cVar3, cVar4);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> c(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return a(j2, timeUnit, h.a.a.n.b.a(), z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> c(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "other is null");
return a((q.i.c) j.i(pVar).o(), (q.i.c) this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> c(@h.a.a.b.f x0<T> x0Var) {
Objects.requireNonNull(x0Var, "other is null");
return a((q.i.c) r0.j(x0Var).s(), (q.i.c) this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f h.a.a.g.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(jVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.j) jVar), false, U(), cVar, cVar2, cVar3, cVar4, cVar5);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
return b(cVar, cVar2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> c(@h.a.a.b.f f0<T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return a((q.i.c) z.k(f0Var).t(), (q.i.c) this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> c(@h.a.a.b.f q0 q0Var) {
return a(TimeUnit.MILLISECONDS, q0Var);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f q.i.c<? extends T> cVar3) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
return b(cVar, cVar2, cVar3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <U, V> s<T> c(@h.a.a.b.f q.i.c<U> cVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<V>> oVar) {
Objects.requireNonNull(cVar, "firstTimeoutIndicator is null");
return b(cVar, oVar, (q.i.c) null);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <K, V> r0<Map<K, Collection<V>>> c(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2) {
return a((h.a.a.g.o) oVar, (h.a.a.g.o) oVar2, (h.a.a.g.s) h.a.a.h.k.m.a(), (h.a.a.g.o) h.a.a.h.k.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f h.a.a.g.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(kVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.k) kVar), false, U(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f q.i.c<? extends T> cVar3, @h.a.a.b.f q.i.c<? extends T> cVar4) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
return b(cVar, cVar2, cVar3, cVar4);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <K, V> r0<Map<K, Collection<V>>> c(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, @h.a.a.b.f h.a.a.g.s<Map<K, Collection<V>>> sVar) {
return a((h.a.a.g.o) oVar, (h.a.a.g.o) oVar2, (h.a.a.g.s) sVar, (h.a.a.g.o) h.a.a.h.k.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> c(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, j3, timeUnit, h.a.a.n.b.a(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> c(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return a(j2, j3, timeUnit, q0Var, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(int i2, int i3, @h.a.a.b.f q.i.c<? extends T>... cVarArr) {
Objects.requireNonNull(cVarArr, "sources is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.b.w(new h.a.a.h.f.b.i1(cVarArr), h.a.a.h.b.a.e(), i2, i3, h.a.a.h.k.j.IMMEDIATE));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f q.i.c<? extends T7> cVar7, @h.a.a.b.f h.a.a.g.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(cVar7, "source7 is null");
Objects.requireNonNull(lVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.l) lVar), false, U(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2, boolean z) {
return q(cVar).b(h.a.a.h.b.a.e(), z, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, int i2, int i3) {
Objects.requireNonNull(iterable, "sources is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.b.w(new m1(iterable), h.a.a.h.b.a.e(), i2, i3, h.a.a.h.k.j.BOUNDARY));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f q.i.c<? extends q.i.c<? extends T>> cVar, int i2, int i3) {
Objects.requireNonNull(cVar, "sources is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.b.x(cVar, h.a.a.h.b.a.e(), i2, i3, h.a.a.h.k.j.IMMEDIATE));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f q.i.c<? extends T7> cVar7, @h.a.a.b.f q.i.c<? extends T8> cVar8, @h.a.a.b.f h.a.a.g.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(cVar7, "source7 is null");
Objects.requireNonNull(cVar8, "source8 is null");
Objects.requireNonNull(mVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.m) mVar), false, U(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public static <T> s<T> a(@h.a.a.b.f v<T> vVar, @h.a.a.b.f i iVar) {
Objects.requireNonNull(vVar, "source is null");
Objects.requireNonNull(iVar, "mode is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.e0(vVar, iVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> a(@h.a.a.b.f Throwable th) {
Objects.requireNonNull(th, "throwable is null");
return c((h.a.a.g.s<? extends Throwable>) h.a.a.h.b.a.d(th));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f Callable<? extends T> callable) {
Objects.requireNonNull(callable, "callable is null");
return h.a.a.l.a.a((s) new j1(callable));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f Future<? extends T> future) {
Objects.requireNonNull(future, "future is null");
return h.a.a.l.a.a(new l1(future, 0L, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> s<R> b(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f q.i.c<? extends T3> cVar3, @h.a.a.b.f q.i.c<? extends T4> cVar4, @h.a.a.b.f q.i.c<? extends T5> cVar5, @h.a.a.b.f q.i.c<? extends T6> cVar6, @h.a.a.b.f q.i.c<? extends T7> cVar7, @h.a.a.b.f q.i.c<? extends T8> cVar8, @h.a.a.b.f q.i.c<? extends T9> cVar9, @h.a.a.b.f h.a.a.g.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(cVar5, "source5 is null");
Objects.requireNonNull(cVar6, "source6 is null");
Objects.requireNonNull(cVar7, "source7 is null");
Objects.requireNonNull(cVar8, "source8 is null");
Objects.requireNonNull(cVar9, "source9 is null");
Objects.requireNonNull(nVar, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.n) nVar), false, U(), cVar, cVar2, cVar3, cVar4, cVar5, cVar6, cVar7, cVar8, cVar9);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f Future<? extends T> future, long j2, @h.a.a.b.f TimeUnit timeUnit) {
Objects.requireNonNull(future, "future is null");
Objects.requireNonNull(timeUnit, "unit is null");
return h.a.a.l.a.a(new l1(future, j2, timeUnit));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public static <T> s<T> a(@h.a.a.b.f n0<T> n0Var, @h.a.a.b.f i iVar) {
Objects.requireNonNull(n0Var, "source is null");
Objects.requireNonNull(iVar, "strategy is null");
n1 n1Var = new n1(n0Var);
int i2 = a.f13245a[iVar.ordinal()];
if (i2 != 1) {
if (i2 != 2) {
if (i2 != 3) {
if (i2 != 4) {
return n1Var.w();
}
return h.a.a.l.a.a(new r2(n1Var));
}
return n1Var;
}
return n1Var.y();
}
return n1Var.x();
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<Boolean> b(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.j(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T> s<T> a(@h.a.a.b.f Runnable runnable) {
Objects.requireNonNull(runnable, "run is null");
return h.a.a.l.a.a((s) new h.a.a.h.f.b.p1(runnable));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final T b(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
h.a.a.h.i.d dVar = new h.a.a.h.i.d();
a((x) dVar);
T a2 = dVar.a();
return a2 != null ? a2 : t;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, S> s<T> a(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.b<S, r<T>> bVar, @h.a.a.b.f h.a.a.g.g<? super S> gVar) {
Objects.requireNonNull(bVar, "generator is null");
return a((h.a.a.g.s) sVar, x1.a(bVar), (h.a.a.g.g) gVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, S> s<T> a(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.c<S, r<T>, S> cVar, @h.a.a.b.f h.a.a.g.g<? super S> gVar) {
Objects.requireNonNull(sVar, "initialState is null");
Objects.requireNonNull(cVar, "generator is null");
Objects.requireNonNull(gVar, "disposeState is null");
return h.a.a.l.a.a(new r1(sVar, cVar, gVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final Iterable<T> b() {
return a(U());
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final void b(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
h.a.a.h.f.b.l.a(this, gVar, h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final void b(@h.a.a.b.f h.a.a.g.g<? super T> gVar, int i2) {
h.a.a.h.f.b.l.a(this, gVar, h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> a(long j2, long j3, long j4, long j5, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, j3, j4, j5, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final void b(@h.a.a.b.f q.i.d<? super T> dVar) {
Objects.requireNonNull(dVar, "subscriber is null");
h.a.a.h.f.b.l.a(this, dVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public static s<Long> a(long j2, long j3, long j4, long j5, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
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 V().c(j4, timeUnit, q0Var);
} else {
long j6 = j2 + (j3 - 1);
if (j2 > 0 && j6 < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new z1(j2, j6, Math.max(0L, j4), Math.max(0L, j5), timeUnit, q0Var));
}
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <B> s<List<T>> b(@h.a.a.b.f q.i.c<B> cVar) {
return (s<List<T>>) a((q.i.c) cVar, (h.a.a.g.s) h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final j b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
return b(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final j b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.d.c(this, oVar, h.a.a.h.k.j.IMMEDIATE, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
return b(t, t2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return V();
}
return o3.a(obj, oVar);
}
return h.a.a.l.a.a(new h.a.a.h.f.b.v(this, oVar, i2, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
return b(t, t2, t3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3, T t4) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
return b(t, t2, t3, t4);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, boolean z) {
return a(oVar, z, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> b(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return b(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> b(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.g0(this, j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3, T t4, T t5) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
return b(t, t2, t3, t4, t5);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, V> s<T> b(@h.a.a.b.f q.i.c<U> cVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<V>> oVar) {
return d((q.i.c) cVar).m((h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> b(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "onFinally is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.p0(this, aVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final r0<T> b(long j2) {
if (j2 >= 0) {
return h.a.a.l.a.a(new h.a.a.h.f.b.v0(this, j2, null));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, boolean z, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "bufferSize");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return V();
}
return o3.a(obj, oVar);
}
return h.a.a.l.a.a(new z0(this, oVar, z, i2, i3));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3, T t4, T t5, T t6) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
return b(t, t2, t3, t4, t5, t6);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3, T t4, T t5, T t6, T t7) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
return b(t, t2, t3, t4, t5, t6, t7);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, V> s<V> b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends V> cVar) {
Objects.requireNonNull(oVar, "mapper is null");
Objects.requireNonNull(cVar, "combiner is null");
return (s<V>) a((h.a.a.g.o) x1.a(oVar), (h.a.a.g.c) cVar, false, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, V> s<V> b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends V> cVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
Objects.requireNonNull(cVar, "combiner is null");
return (s<V>) a((h.a.a.g.o) x1.a(oVar), (h.a.a.g.c) cVar, false, U(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <TRight, TLeftEnd, TRightEnd, R> s<R> b(@h.a.a.b.f q.i.c<? extends TRight> cVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<TLeftEnd>> oVar, @h.a.a.b.f h.a.a.g.o<? super TRight, ? extends q.i.c<TRightEnd>> oVar2, @h.a.a.b.f h.a.a.g.c<? super T, ? super TRight, ? extends R> cVar2) {
Objects.requireNonNull(cVar, "other is null");
Objects.requireNonNull(oVar, "leftEnd is null");
Objects.requireNonNull(oVar2, "rightEnd is null");
Objects.requireNonNull(cVar2, "resultSelector is null");
return h.a.a.l.a.a(new a2(this, cVar, oVar, oVar2, cVar2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3, T t4, T t5, T t6, T t7, T t8) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
return b(t, t2, t3, t4, t5, t6, t7, t8);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(@h.a.a.b.f x0<? extends T> x0Var) {
Objects.requireNonNull(x0Var, "other is null");
return h.a.a.l.a.a(new l2(this, x0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return h.a.a.l.a.a(new k2(this, f0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> b(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "other is null");
return h.a.a.l.a.a(new j2(this, pVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
Objects.requireNonNull(t9, "item9 is null");
return b(t, t2, t3, t4, t5, t6, t7, t8, t9);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <U> s<U> b(@h.a.a.b.f Class<U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return c((h.a.a.g.r) h.a.a.h.b.a.b((Class) cls)).a(cls);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.k.b<T> b(int i2, int i3) {
return h.a.a.k.b.a(this, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> b(int i2, boolean z) {
h.a.a.h.b.b.a(i2, "bufferSize");
return i3.a((s) this, i2, z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> b(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return i3.a(this, j2, timeUnit, q0Var, z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(@h.a.a.b.f h.a.a.g.d<? super Integer, ? super Throwable> dVar) {
Objects.requireNonNull(dVar, "predicate is null");
return h.a.a.l.a.a(new j3(this, dVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(T t, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
Objects.requireNonNull(t9, "item9 is null");
Objects.requireNonNull(t10, "item10 is null");
return b(t, t2, t3, t4, t5, t6, t7, t8, t9, t10);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(@h.a.a.b.f h.a.a.g.e eVar) {
Objects.requireNonNull(eVar, "stop is null");
return a((long) k.c3.w.p0.c, h.a.a.h.b.a.a(eVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> b(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return c(j2, timeUnit, h.a.a.n.b.a(), z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(@h.a.a.b.f h.a.a.g.c<T, T, T> cVar) {
Objects.requireNonNull(cVar, "accumulator is null");
return h.a.a.l.a.a(new p3(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> b(R r2, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(r2, "initialValue is null");
return b((h.a.a.g.s) h.a.a.h.b.a.d(r2), (h.a.a.g.c) cVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> b(@h.a.a.b.f h.a.a.g.s<R> sVar, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(sVar, "seedSupplier is null");
Objects.requireNonNull(cVar, "accumulator is null");
return h.a.a.l.a.a(new q3(this, sVar, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final h.a.a.d.f b(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2) {
return b(gVar, gVar2, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, int i2) {
return g((Iterable) iterable).g(h.a.a.h.b.a.e(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final h.a.a.d.f b(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(gVar, "onNext is null");
Objects.requireNonNull(gVar2, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
h.a.a.h.i.m mVar = new h.a.a.h.i.m(gVar, gVar2, aVar, x1.h.INSTANCE);
a((x) mVar);
return mVar;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> r0<Boolean> a(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f h.a.a.g.d<? super T, ? super T> dVar) {
return a(cVar, cVar2, dVar, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> r0<Boolean> a(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, @h.a.a.b.f h.a.a.g.d<? super T, ? super T> dVar, int i2) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(dVar, "isEqual is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new s3(cVar, cVar2, dVar, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> b(@h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(q0Var, "scheduler is null");
return b(q0Var, !(this instanceof h.a.a.h.f.b.e0));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> r0<Boolean> a(@h.a.a.b.f q.i.c<? extends T> cVar, @h.a.a.b.f q.i.c<? extends T> cVar2, int i2) {
return a(cVar, cVar2, h.a.a.h.b.b.a(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> b(@h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new c4(this, q0Var, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T, D> s<T> a(@h.a.a.b.f h.a.a.g.s<? extends D> sVar, @h.a.a.b.f h.a.a.g.o<? super D, ? extends q.i.c<? extends T>> oVar, @h.a.a.b.f h.a.a.g.g<? super D> gVar) {
return a((h.a.a.g.s) sVar, (h.a.a.g.o) oVar, (h.a.a.g.g) gVar, true);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public static <T, D> s<T> a(@h.a.a.b.f h.a.a.g.s<? extends D> sVar, @h.a.a.b.f h.a.a.g.o<? super D, ? extends q.i.c<? extends T>> oVar, @h.a.a.b.f h.a.a.g.g<? super D> gVar, boolean z) {
Objects.requireNonNull(sVar, "resourceSupplier is null");
Objects.requireNonNull(oVar, "sourceSupplier is null");
Objects.requireNonNull(gVar, "resourceCleanup is null");
return h.a.a.l.a.a(new w4(sVar, oVar, gVar, z));
}
<R> s<R> b(h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, int i2, boolean z) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return V();
}
return o3.a(obj, oVar);
}
return h.a.a.l.a.a(new e4(this, oVar, i2, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> a(@h.a.a.b.f Iterable<? extends q.i.c<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "zipper is null");
Objects.requireNonNull(iterable, "sources is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new e5(null, iterable, oVar, i2, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, j3, timeUnit, h.a.a.n.b.a(), false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar3, boolean z) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.c) cVar3), z, U(), cVar, cVar2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return a(j2, j3, timeUnit, q0Var, false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> b(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z, int i2) {
return a((long) k.c3.w.p0.c, j2, timeUnit, q0Var, z, i2);
}
private <U, V> s<T> b(q.i.c<U> cVar, h.a.a.g.o<? super T, ? extends q.i.c<V>> oVar, q.i.c<? extends T> cVar2) {
Objects.requireNonNull(oVar, "itemTimeoutIndicator is null");
return h.a.a.l.a.a(new q4(this, cVar, oVar, cVar2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T1, T2, R> s<R> a(@h.a.a.b.f q.i.c<? extends T1> cVar, @h.a.a.b.f q.i.c<? extends T2> cVar2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar3, boolean z, int i2) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "zipper is null");
return a(h.a.a.h.b.a.a((h.a.a.g.c) cVar3), z, i2, cVar, cVar2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> b(@h.a.a.b.f TimeUnit timeUnit) {
return b(timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> b(@h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return (s<h.a.a.n.d<T>>) x(h.a.a.h.b.a.a(timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T, R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, boolean z, int i2, @h.a.a.b.f q.i.c<? extends T>... cVarArr) {
Objects.requireNonNull(cVarArr, "sources is null");
if (cVarArr.length == 0) {
return V();
}
Objects.requireNonNull(oVar, "zipper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new e5(cVarArr, null, oVar, i2, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <K, V> r0<Map<K, V>> b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
return (r0<Map<K, V>>) a((h.a.a.g.s) h.a.a.h.k.m.a(), (h.a.a.g.b) h.a.a.h.b.a.a(oVar, oVar2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <K, V> r0<Map<K, V>> b(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, @h.a.a.b.f h.a.a.g.s<? extends Map<K, V>> sVar) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
return (r0<Map<K, V>>) a((h.a.a.g.s) sVar, (h.a.a.g.b) h.a.a.h.b.a.a(oVar, oVar2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<Boolean> a(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.g(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<List<T>> b(@h.a.a.b.f Comparator<? super T> comparator) {
Objects.requireNonNull(comparator, "comparator is null");
return (r0<List<T>>) R().n(h.a.a.h.b.a.a((Comparator) comparator));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "other is null");
return a(this, cVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <B> s<s<T>> b(@h.a.a.b.f q.i.c<B> cVar, int i2) {
Objects.requireNonNull(cVar, "boundaryIndicator is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new y4(this, cVar, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final T a() {
h.a.a.h.i.d dVar = new h.a.a.h.i.d();
a((x) dVar);
T a2 = dVar.a();
if (a2 != null) {
return a2;
}
throw new NoSuchElementException();
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> b(@h.a.a.b.f q.i.c<? extends U> cVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar2) {
Objects.requireNonNull(cVar, "other is null");
return b(this, cVar, cVar2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final Stream<T> b(int i2) {
Iterator<T> it = a(i2).iterator();
Stream stream = StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, 0), false);
h.a.a.d.f fVar = (h.a.a.d.f) it;
fVar.getClass();
return (Stream) stream.onClose(new f(fVar));
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
a(gVar, U());
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, int i2) {
Objects.requireNonNull(gVar, "onNext is null");
Iterator<T> it = a(i2).iterator();
while (it.hasNext()) {
try {
gVar.accept(it.next());
} catch (Throwable th) {
h.a.a.e.b.b(th);
((h.a.a.d.f) it).dispose();
throw h.a.a.h.k.k.c(th);
}
}
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final Iterable<T> a(int i2) {
h.a.a.h.b.b.a(i2, "bufferSize");
return new h.a.a.h.f.b.b(this, i2);
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2) {
h.a.a.h.f.b.l.a(this, gVar, gVar2, h.a.a.h.b.a.c);
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, int i2) {
h.a.a.h.f.b.l.a(this, gVar, gVar2, h.a.a.h.b.a.c, i2);
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar) {
h.a.a.h.f.b.l.a(this, gVar, gVar2, aVar);
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final void a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar, int i2) {
h.a.a.h.f.b.l.a(this, gVar, gVar2, aVar, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<List<T>> a(int i2, int i3) {
return (s<List<T>>) a(i2, i3, h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U extends Collection<? super T>> s<U> a(int i2, int i3, @h.a.a.b.f h.a.a.g.s<U> sVar) {
h.a.a.h.b.b.a(i2, NewHtcHomeBadger.f20939d);
h.a.a.h.b.b.a(i3, "skip");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.m(this, i2, i3, sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U extends Collection<? super T>> s<U> a(int i2, @h.a.a.b.f h.a.a.g.s<U> sVar) {
return a(i2, i2, sVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<List<T>> a(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return (s<List<T>>) a(j2, j3, timeUnit, h.a.a.n.b.a(), h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<List<T>> a(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return (s<List<T>>) a(j2, j3, timeUnit, q0Var, h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <U extends Collection<? super T>> s<U> a(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, @h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.p(this, j2, j3, timeUnit, q0Var, sVar, Integer.MAX_VALUE, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<List<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(j2, timeUnit, h.a.a.n.b.a(), Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<List<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, int i2) {
return a(j2, timeUnit, h.a.a.n.b.a(), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<List<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, int i2) {
return (s<List<T>>) a(j2, timeUnit, q0Var, i2, (h.a.a.g.s) h.a.a.h.k.b.b(), false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <U extends Collection<? super T>> s<U> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, int i2, @h.a.a.b.f h.a.a.g.s<U> sVar, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
h.a.a.h.b.b.a(i2, NewHtcHomeBadger.f20939d);
return h.a.a.l.a.a(new h.a.a.h.f.b.p(this, j2, j2, timeUnit, q0Var, sVar, i2, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<List<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return (s<List<T>>) a(j2, timeUnit, q0Var, Integer.MAX_VALUE, (h.a.a.g.s) h.a.a.h.k.b.b(), false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <TOpening, TClosing> s<List<T>> a(@h.a.a.b.f q.i.c<? extends TOpening> cVar, @h.a.a.b.f h.a.a.g.o<? super TOpening, ? extends q.i.c<? extends TClosing>> oVar) {
return (s<List<T>>) a((q.i.c) cVar, (h.a.a.g.o) oVar, (h.a.a.g.s) h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <TOpening, TClosing, U extends Collection<? super T>> s<U> a(@h.a.a.b.f q.i.c<? extends TOpening> cVar, @h.a.a.b.f h.a.a.g.o<? super TOpening, ? extends q.i.c<? extends TClosing>> oVar, @h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(cVar, "openingIndicator is null");
Objects.requireNonNull(oVar, "closingIndicator is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.n(this, cVar, oVar, sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <B> s<List<T>> a(@h.a.a.b.f q.i.c<B> cVar, int i2) {
h.a.a.h.b.b.a(i2, "initialCapacity");
return (s<List<T>>) a((q.i.c) cVar, (h.a.a.g.s) h.a.a.h.b.a.b(i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <B, U extends Collection<? super T>> s<U> a(@h.a.a.b.f q.i.c<B> cVar, @h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(cVar, "boundaryIndicator is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.o(this, cVar, sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <U> s<U> a(@h.a.a.b.f Class<U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return (s<U>) x(h.a.a.h.b.a.a((Class) cls));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <U> r0<U> a(@h.a.a.b.f h.a.a.g.s<? extends U> sVar, @h.a.a.b.f h.a.a.g.b<? super U, ? super T> bVar) {
Objects.requireNonNull(sVar, "initialItemSupplier is null");
Objects.requireNonNull(bVar, "collector is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.s(this, sVar, bVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <U> r0<U> a(U u, @h.a.a.b.f h.a.a.g.b<? super U, ? super T> bVar) {
Objects.requireNonNull(u, "initialItem is null");
return a((h.a.a.g.s) h.a.a.h.b.a.d(u), (h.a.a.g.b) bVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <R> s<R> a(@h.a.a.b.f y<? super T, ? extends R> yVar) {
return q(((y) Objects.requireNonNull(yVar, "composer is null")).a(this));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar) {
return a(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return V();
}
return o3.a(obj, oVar);
}
return h.a.a.l.a.a(new h.a.a.h.f.b.v(this, oVar, i2, h.a.a.h.k.j.IMMEDIATE));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, int i2, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.y(this, oVar, i2, h.a.a.h.k.j.IMMEDIATE, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final j a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, boolean z) {
return a(oVar, z, 2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final j a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.d.c(this, oVar, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, boolean z, int i2, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "prefetch");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.y(this, oVar, i2, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.b.w(this, oVar, i2, i3, h.a.a.h.k.j.IMMEDIATE));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, boolean z, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "prefetch");
return h.a.a.l.a.a(new h.a.a.h.f.b.w(this, oVar, i2, i3, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f x0<? extends T> x0Var) {
Objects.requireNonNull(x0Var, "other is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.b0(this, x0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.a0(this, f0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> a(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "other is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.z(this, pVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return a(j2, timeUnit, h.a.a.n.b.a(), z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.i0(this, Math.max(0L, j2), timeUnit, q0Var, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <K> s<T> a(@h.a.a.b.f h.a.a.g.o<? super T, K> oVar, @h.a.a.b.f h.a.a.g.s<? extends Collection<? super K>> sVar) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(sVar, "collectionSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.m0(this, oVar, sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f h.a.a.g.d<? super T, ? super T> dVar) {
Objects.requireNonNull(dVar, "comparer is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.n0(this, h.a.a.h.b.a.e(), dVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> a(@h.a.a.b.f h.a.a.g.a aVar) {
return a((h.a.a.g.g) h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), h.a.a.h.b.a.c, aVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
private s<T> a(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, h.a.a.g.a aVar, h.a.a.g.a aVar2) {
Objects.requireNonNull(gVar, "onNext is null");
Objects.requireNonNull(gVar2, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
Objects.requireNonNull(aVar2, "onAfterTerminate is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.q0(this, gVar, gVar2, aVar, aVar2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> a(@h.a.a.b.f h.a.a.g.g<? super q.i.e> gVar, @h.a.a.b.f h.a.a.g.q qVar, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(gVar, "onSubscribe is null");
Objects.requireNonNull(qVar, "onRequest is null");
Objects.requireNonNull(aVar, "onCancel is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.r0(this, gVar, qVar, aVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<T> a(@h.a.a.b.f h.a.a.g.q qVar) {
return a(h.a.a.h.b.a.d(), qVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final z<T> a(long j2) {
if (j2 >= 0) {
return h.a.a.l.a.a(new h.a.a.h.f.b.t0(this, j2));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final r0<T> a(long j2, @h.a.a.b.f T t) {
if (j2 >= 0) {
Objects.requireNonNull(t, "defaultItem is null");
return h.a.a.l.a.a(new h.a.a.h.f.b.v0(this, j2, t));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, @h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends q.i.c<? extends R>> oVar2, @h.a.a.b.f h.a.a.g.s<? extends q.i.c<? extends R>> sVar) {
Objects.requireNonNull(oVar, "onNextMapper is null");
Objects.requireNonNull(oVar2, "onErrorMapper is null");
Objects.requireNonNull(sVar, "onCompleteSupplier is null");
return r(new g2(this, oVar, oVar2, sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends R>> oVar, @h.a.a.b.f h.a.a.g.o<Throwable, ? extends q.i.c<? extends R>> oVar2, @h.a.a.b.f h.a.a.g.s<? extends q.i.c<? extends R>> sVar, int i2) {
Objects.requireNonNull(oVar, "onNextMapper is null");
Objects.requireNonNull(oVar2, "onErrorMapper is null");
Objects.requireNonNull(sVar, "onCompleteSupplier is null");
return d(new g2(this, oVar, oVar2, sVar), i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
return a((h.a.a.g.o) oVar, (h.a.a.g.c) cVar, false, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z) {
return a(oVar, cVar, z, U(), U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z, int i2) {
return a(oVar, cVar, z, i2, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
Objects.requireNonNull(cVar, "combiner is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "bufferSize");
return b(x1.a(oVar, cVar), z, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, int i2) {
return a((h.a.a.g.o) oVar, (h.a.a.g.c) cVar, false, i2, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.NONE)
public final h.a.a.d.f a(@h.a.a.b.f h.a.a.g.r<? super T> rVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
return a((h.a.a.g.r) rVar, gVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.NONE)
public final h.a.a.d.f a(@h.a.a.b.f h.a.a.g.r<? super T> rVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(rVar, "onNext is null");
Objects.requireNonNull(gVar, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
h.a.a.h.i.i iVar = new h.a.a.h.i.i(rVar, gVar, aVar);
a((x) iVar);
return iVar;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <K, V> s<h.a.a.f.b<K, V>> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2) {
return a((h.a.a.g.o) oVar, (h.a.a.g.o) oVar2, false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <K, V> s<h.a.a.f.b<K, V>> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, boolean z) {
return a(oVar, oVar2, z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final <K, V> s<h.a.a.f.b<K, V>> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, boolean z, int i2) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new s1(this, oVar, oVar2, i2, z, null));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final <K, V> s<h.a.a.f.b<K, V>> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, boolean z, int i2, @h.a.a.b.f h.a.a.g.o<? super h.a.a.g.g<Object>, ? extends Map<K, Object>> oVar3) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(oVar3, "evictingMapFactory is null");
return h.a.a.l.a.a(new s1(this, oVar, oVar2, i2, z, oVar3));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <TRight, TLeftEnd, TRightEnd, R> s<R> a(@h.a.a.b.f q.i.c<? extends TRight> cVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<TLeftEnd>> oVar, @h.a.a.b.f h.a.a.g.o<? super TRight, ? extends q.i.c<TRightEnd>> oVar2, @h.a.a.b.f h.a.a.g.c<? super T, ? super s<TRight>, ? extends R> cVar2) {
Objects.requireNonNull(cVar, "other is null");
Objects.requireNonNull(oVar, "leftEnd is null");
Objects.requireNonNull(oVar2, "rightEnd is null");
Objects.requireNonNull(cVar2, "resultSelector is null");
return h.a.a.l.a.a(new t1(this, cVar, oVar, oVar2, cVar2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final <R> s<R> a(@h.a.a.b.f w<? extends R, ? super T> wVar) {
Objects.requireNonNull(wVar, "lifter is null");
return h.a.a.l.a.a(new e2(this, wVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f q0 q0Var) {
return a(q0Var, false, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f q0 q0Var, boolean z) {
return a(q0Var, z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f q0 q0Var, boolean z, int i2) {
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new n2(this, q0Var, z, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> a(boolean z) {
return a(U(), z, true);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> a(int i2, boolean z) {
return a(i2, z, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final s<T> a(int i2, boolean z, boolean z2) {
h.a.a.h.b.b.a(i2, "capacity");
return h.a.a.l.a.a(new o2(this, i2, z2, z, h.a.a.h.b.a.c));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final s<T> a(int i2, boolean z, boolean z2, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "onOverflow is null");
h.a.a.h.b.b.a(i2, "capacity");
return h.a.a.l.a.a(new o2(this, i2, z2, z, aVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<T> a(int i2, @h.a.a.b.f h.a.a.g.a aVar) {
return a(i2, false, false, aVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final s<T> a(long j2, @h.a.a.b.g h.a.a.g.a aVar, @h.a.a.b.f h hVar) {
Objects.requireNonNull(hVar, "overflowStrategy is null");
h.a.a.h.b.b.a(j2, "capacity");
return h.a.a.l.a.a(new p2(this, j2, aVar, hVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final z<T> a(@h.a.a.b.f h.a.a.g.c<T, T, T> cVar) {
Objects.requireNonNull(cVar, "reducer is null");
return h.a.a.l.a.a(new b3(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> r0<R> a(R r2, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(r2, "seed is null");
Objects.requireNonNull(cVar, "reducer is null");
return h.a.a.l.a.a(new c3(this, r2, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R> r0<R> a(@h.a.a.b.f h.a.a.g.s<R> sVar, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(sVar, "seedSupplier is null");
Objects.requireNonNull(cVar, "reducer is null");
return h.a.a.l.a.a(new d3(this, sVar, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f h.a.a.g.e eVar) {
Objects.requireNonNull(eVar, "stop is null");
return h.a.a.l.a.a(new g3(this, eVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, int i2, boolean z) {
Objects.requireNonNull(oVar, "selector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return i3.a(x1.a(this, i2, z), (h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, int i2, long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(oVar, i2, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(q0Var, "scheduler is null");
return i3.a(x1.a(this, i2, j2, timeUnit, q0Var, false), (h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(oVar, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(q0Var, "scheduler is null");
return i3.a(x1.a(this, i2, j2, timeUnit, q0Var, z), (h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(oVar, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return i3.a(x1.a(this, j2, timeUnit, q0Var, false), (h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <R> s<R> a(@h.a.a.b.f h.a.a.g.o<? super s<T>, ? extends q.i.c<R>> oVar, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(oVar, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return i3.a(x1.a(this, j2, timeUnit, q0Var, z), (h.a.a.g.o) oVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> a(int i2, long j2, @h.a.a.b.f TimeUnit timeUnit) {
return a(i2, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> a(int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return i3.a((s) this, j2, timeUnit, q0Var, i2, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.f.a<T> a(int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return i3.a(this, j2, timeUnit, q0Var, i2, z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(long j2, @h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
if (j2 >= 0) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new k3(this, j2, rVar));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <U> s<T> a(@h.a.a.b.f q.i.c<U> cVar, boolean z) {
Objects.requireNonNull(cVar, "sampler is null");
return h.a.a.l.a.a(new m3(this, cVar, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final s<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z, int i2) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new z3(this, j2, timeUnit, q0Var, i2 << 1, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f Comparator<? super T> comparator) {
Objects.requireNonNull(comparator, "comparator is null");
return R().s().x(h.a.a.h.b.a.a((Comparator) comparator)).s(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f Iterable<? extends T> iterable) {
return b(g((Iterable) iterable), this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(@h.a.a.b.f T... tArr) {
s b = b((Object[]) tArr);
if (b == V()) {
return h.a.a.l.a.a(this);
}
return b(b, this);
}
@Override
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final void a(@h.a.a.b.f q.i.d<? super T> dVar) {
if (dVar instanceof x) {
a((x) ((x) dVar));
return;
}
Objects.requireNonNull(dVar, "subscriber is null");
a((x) new h.a.a.h.i.u(dVar));
}
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final void a(@h.a.a.b.f x<? super T> xVar) {
Objects.requireNonNull(xVar, "subscriber is null");
try {
q.i.d<? super T> a2 = h.a.a.l.a.a(this, xVar);
Objects.requireNonNull(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((q.i.d) a2);
} catch (NullPointerException e2) {
throw e2;
} catch (Throwable th) {
h.a.a.e.b.b(th);
h.a.a.l.a.b(th);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z, int i2) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (j2 >= 0) {
return h.a.a.l.a.a(new i4(this, j2, j3, timeUnit, q0Var, i2, z));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> a(@h.a.a.b.f TimeUnit timeUnit) {
return a(timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final s<h.a.a.n.d<T>> a(@h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new p4(this, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <V> s<T> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<V>> oVar, @h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "fallback is null");
return b((q.i.c) null, oVar, cVar);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "fallback is null");
return a(j2, timeUnit, cVar, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<T> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, @h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "fallback is null");
return a(j2, timeUnit, cVar, q0Var);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, V> s<T> a(@h.a.a.b.f q.i.c<U> cVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends q.i.c<V>> oVar, @h.a.a.b.f q.i.c<? extends T> cVar2) {
Objects.requireNonNull(cVar, "firstTimeoutIndicator is null");
Objects.requireNonNull(cVar2, "fallback is null");
return b(cVar, oVar, cVar2);
}
private s<T> a(long j2, TimeUnit timeUnit, q.i.c<? extends T> cVar, q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new r4(this, j2, timeUnit, q0Var, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final <R> R a(@h.a.a.b.f t<T, ? extends R> tVar) {
return (R) ((t) Objects.requireNonNull(tVar, "converter is null")).a(this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <U extends Collection<? super T>> r0<U> a(@h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(sVar, "collectionSupplier is null");
return h.a.a.l.a.a(new u4(this, sVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <K, V> r0<Map<K, Collection<V>>> a(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, @h.a.a.b.f h.a.a.g.s<? extends Map<K, Collection<V>>> sVar, @h.a.a.b.f h.a.a.g.o<? super K, ? extends Collection<? super V>> oVar3) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
Objects.requireNonNull(sVar, "mapSupplier is null");
Objects.requireNonNull(oVar3, "collectionFactory is null");
return (r0<Map<K, Collection<V>>>) a((h.a.a.g.s) sVar, (h.a.a.g.b) h.a.a.h.b.a.a(oVar, oVar2, oVar3));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final r0<List<T>> a(@h.a.a.b.f Comparator<? super T> comparator, int i2) {
Objects.requireNonNull(comparator, "comparator is null");
return (r0<List<T>>) l(i2).n(h.a.a.h.b.a.a((Comparator) comparator));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<s<T>> a(long j2, long j3) {
return a(j2, j3, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final s<s<T>> a(long j2, long j3, int i2) {
h.a.a.h.b.b.a(j3, "skip");
h.a.a.h.b.b.a(j2, NewHtcHomeBadger.f20939d);
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new x4(this, j2, j3, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> a(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, int i2) {
h.a.a.h.b.b.a(i2, "bufferSize");
h.a.a.h.b.b.a(j2, "timespan");
h.a.a.h.b.b.a(j3, "timeskip");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(timeUnit, "unit is null");
return h.a.a.l.a.a(new b5(this, j2, j3, timeUnit, q0Var, k.c3.w.p0.c, i2, false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, long j3) {
return a(j2, timeUnit, h.a.a.n.b.a(), j3, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, long j3, boolean z) {
return a(j2, timeUnit, h.a.a.n.b.a(), j3, z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, long j3) {
return a(j2, timeUnit, q0Var, j3, false);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, long j3, boolean z) {
return a(j2, timeUnit, q0Var, j3, z, U());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final s<s<T>> a(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, long j3, boolean z, int i2) {
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(timeUnit, "unit is null");
h.a.a.h.b.b.a(j3, NewHtcHomeBadger.f20939d);
return h.a.a.l.a.a(new b5(this, j2, j2, timeUnit, q0Var, j3, i2, z));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.ERROR)
public final <U, V> s<s<T>> a(@h.a.a.b.f q.i.c<U> cVar, @h.a.a.b.f h.a.a.g.o<? super U, ? extends q.i.c<V>> oVar, int i2) {
Objects.requireNonNull(cVar, "openingIndicator is null");
Objects.requireNonNull(oVar, "closingIndicator is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new z4(this, cVar, oVar, i2));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <U, R> s<R> a(@h.a.a.b.f q.i.c<? extends U> cVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar2) {
Objects.requireNonNull(cVar, "other is null");
Objects.requireNonNull(cVar2, "combiner is null");
return h.a.a.l.a.a(new c5(this, cVar2, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <T1, T2, R> s<R> a(@h.a.a.b.f q.i.c<T1> cVar, @h.a.a.b.f q.i.c<T2> cVar2, @h.a.a.b.f h.a.a.g.h<? super T, ? super T1, ? super T2, R> hVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(hVar, "combiner is null");
return a((q.i.c<?>[]) new q.i.c[]{cVar, cVar2}, h.a.a.h.b.a.a((h.a.a.g.h) hVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <T1, T2, T3, R> s<R> a(@h.a.a.b.f q.i.c<T1> cVar, @h.a.a.b.f q.i.c<T2> cVar2, @h.a.a.b.f q.i.c<T3> cVar3, @h.a.a.b.f h.a.a.g.i<? super T, ? super T1, ? super T2, ? super T3, R> iVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(iVar, "combiner is null");
return a((q.i.c<?>[]) new q.i.c[]{cVar, cVar2, cVar3}, h.a.a.h.b.a.a((h.a.a.g.i) iVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <T1, T2, T3, T4, R> s<R> a(@h.a.a.b.f q.i.c<T1> cVar, @h.a.a.b.f q.i.c<T2> cVar2, @h.a.a.b.f q.i.c<T3> cVar3, @h.a.a.b.f q.i.c<T4> cVar4, @h.a.a.b.f h.a.a.g.j<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> jVar) {
Objects.requireNonNull(cVar, "source1 is null");
Objects.requireNonNull(cVar2, "source2 is null");
Objects.requireNonNull(cVar3, "source3 is null");
Objects.requireNonNull(cVar4, "source4 is null");
Objects.requireNonNull(jVar, "combiner is null");
return a((q.i.c<?>[]) new q.i.c[]{cVar, cVar2, cVar3, cVar4}, h.a.a.h.b.a.a((h.a.a.g.j) jVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <R> s<R> a(@h.a.a.b.f q.i.c<?>[] cVarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], R> oVar) {
Objects.requireNonNull(cVarArr, "others is null");
Objects.requireNonNull(oVar, "combiner is null");
return h.a.a.l.a.a(new d5(this, cVarArr, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.PASS_THROUGH)
public final <R> s<R> a(@h.a.a.b.f Iterable<? extends q.i.c<?>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], R> oVar) {
Objects.requireNonNull(iterable, "others is null");
Objects.requireNonNull(oVar, "combiner is null");
return h.a.a.l.a.a(new d5(this, iterable, oVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f Iterable<U> iterable, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
Objects.requireNonNull(iterable, "other is null");
Objects.requireNonNull(cVar, "zipper is null");
return h.a.a.l.a.a(new f5(this, iterable, cVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f q.i.c<? extends U> cVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar2, boolean z) {
return a(this, cVar, cVar2, z);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final <U, R> s<R> a(@h.a.a.b.f q.i.c<? extends U> cVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar2, boolean z, int i2) {
return a(this, cVar, cVar2, z, i2);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public final h.a.a.p.f<T> a(long j2, boolean z) {
h.a.a.p.f<T> fVar = new h.a.a.p.f<>(j2);
if (z) {
fVar.cancel();
}
a((x) fVar);
return fVar;
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f Optional<T> optional) {
Objects.requireNonNull(optional, "optional is null");
return (s) optional.map(new Function() {
@Override
public final Object apply(Object obj) {
return s.p(obj);
}
}).orElseGet(new Supplier() {
@Override
public final Object get() {
return s.V();
}
});
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f CompletionStage<T> completionStage) {
Objects.requireNonNull(completionStage, "stage is null");
return h.a.a.l.a.a(new h.a.a.h.d.g(completionStage));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.FULL)
public static <T> s<T> a(@h.a.a.b.f Stream<T> stream) {
Objects.requireNonNull(stream, "stream is null");
return h.a.a.l.a.a(new h.a.a.h.d.h(stream));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public final <R, A> r0<R> a(@h.a.a.b.f Collector<T, A, R> collector) {
Objects.requireNonNull(collector, "collector is null");
return h.a.a.l.a.a(new h.a.a.h.d.d(this, collector));
}
}