Aqara Home v2.4.1版本的 MD5 值为：529779ac2bc0131db52a1fc3098d2b35
以下内容为反编译后的 b0.java 源代码，内容仅作参考
package p.a;
import java.util.Collection;
import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.NoSuchElementException;
import java.util.concurrent.Callable;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import p.a.y0.e.b.n2;
import p.a.y0.e.e.a1;
import p.a.y0.e.e.a2;
import p.a.y0.e.e.a4;
import p.a.y0.e.e.b1;
import p.a.y0.e.e.b2;
import p.a.y0.e.e.b3;
import p.a.y0.e.e.b4;
import p.a.y0.e.e.c1;
import p.a.y0.e.e.c2;
import p.a.y0.e.e.c3;
import p.a.y0.e.e.c4;
import p.a.y0.e.e.d1;
import p.a.y0.e.e.d2;
import p.a.y0.e.e.d3;
import p.a.y0.e.e.d4;
import p.a.y0.e.e.e1;
import p.a.y0.e.e.e2;
import p.a.y0.e.e.e3;
import p.a.y0.e.e.e4;
import p.a.y0.e.e.f1;
import p.a.y0.e.e.f2;
import p.a.y0.e.e.f3;
import p.a.y0.e.e.f4;
import p.a.y0.e.e.g1;
import p.a.y0.e.e.g2;
import p.a.y0.e.e.g3;
import p.a.y0.e.e.g4;
import p.a.y0.e.e.h1;
import p.a.y0.e.e.h2;
import p.a.y0.e.e.h3;
import p.a.y0.e.e.h4;
import p.a.y0.e.e.i1;
import p.a.y0.e.e.i2;
import p.a.y0.e.e.i3;
import p.a.y0.e.e.i4;
import p.a.y0.e.e.j1;
import p.a.y0.e.e.j2;
import p.a.y0.e.e.j3;
import p.a.y0.e.e.j4;
import p.a.y0.e.e.k1;
import p.a.y0.e.e.k2;
import p.a.y0.e.e.k3;
import p.a.y0.e.e.k4;
import p.a.y0.e.e.l1;
import p.a.y0.e.e.l2;
import p.a.y0.e.e.l3;
import p.a.y0.e.e.l4;
import p.a.y0.e.e.m1;
import p.a.y0.e.e.m2;
import p.a.y0.e.e.m3;
import p.a.y0.e.e.m4;
import p.a.y0.e.e.n1;
import p.a.y0.e.e.n3;
import p.a.y0.e.e.o1;
import p.a.y0.e.e.o2;
import p.a.y0.e.e.o3;
import p.a.y0.e.e.p1;
import p.a.y0.e.e.p2;
import p.a.y0.e.e.p3;
import p.a.y0.e.e.q1;
import p.a.y0.e.e.q2;
import p.a.y0.e.e.q3;
import p.a.y0.e.e.r1;
import p.a.y0.e.e.r2;
import p.a.y0.e.e.r3;
import p.a.y0.e.e.s0;
import p.a.y0.e.e.s1;
import p.a.y0.e.e.s2;
import p.a.y0.e.e.s3;
import p.a.y0.e.e.t0;
import p.a.y0.e.e.t1;
import p.a.y0.e.e.t2;
import p.a.y0.e.e.t3;
import p.a.y0.e.e.u0;
import p.a.y0.e.e.u1;
import p.a.y0.e.e.u2;
import p.a.y0.e.e.u3;
import p.a.y0.e.e.v0;
import p.a.y0.e.e.v1;
import p.a.y0.e.e.v2;
import p.a.y0.e.e.v3;
import p.a.y0.e.e.w0;
import p.a.y0.e.e.w1;
import p.a.y0.e.e.w2;
import p.a.y0.e.e.w3;
import p.a.y0.e.e.x1;
import p.a.y0.e.e.x2;
import p.a.y0.e.e.x3;
import p.a.y0.e.e.y0;
import p.a.y0.e.e.y1;
import p.a.y0.e.e.y2;
import p.a.y0.e.e.y3;
import p.a.y0.e.e.z0;
import p.a.y0.e.e.z1;
import p.a.y0.e.e.z2;
import p.a.y0.e.e.z3;
public abstract class b0<T> implements g0<T> {
public static class a {
public static final int[] a;
static {
int[] iArr = new int[b.values().length];
a = iArr;
try {
iArr[b.DROP.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
a[b.LATEST.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
try {
a[b.MISSING.ordinal()] = 3;
} catch (NoSuchFieldError unused3) {
}
try {
a[b.ERROR.ordinal()] = 4;
} catch (NoSuchFieldError unused4) {
}
}
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> amb(Iterable<? extends g0<? extends T>> iterable) {
p.a.y0.b.b.a(iterable, "sources is null");
return p.a.c1.a.a(new p.a.y0.e.e.h(null, iterable));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> ambArray(g0<? extends T>... g0VarArr) {
p.a.y0.b.b.a(g0VarArr, "sources is null");
int length = g0VarArr.length;
if (length == 0) {
return empty();
}
if (length == 1) {
return wrap(g0VarArr[0]);
}
return p.a.c1.a.a(new p.a.y0.e.e.h(g0VarArr, null));
}
public static int bufferSize() {
return l.Q();
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatest(p.a.x0.o<? super Object[], ? extends R> oVar, int i2, g0<? extends T>... g0VarArr) {
return combineLatest(g0VarArr, oVar, i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatestDelayError(g0<? extends T>[] g0VarArr, p.a.x0.o<? super Object[], ? extends R> oVar) {
return combineLatestDelayError(g0VarArr, oVar, bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concat(Iterable<? extends g0<? extends T>> iterable) {
p.a.y0.b.b.a(iterable, "sources is null");
return fromIterable(iterable).concatMapDelayError(p.a.y0.b.a.e(), bufferSize(), false);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatArray(g0<? extends T>... g0VarArr) {
if (g0VarArr.length == 0) {
return empty();
}
if (g0VarArr.length == 1) {
return wrap(g0VarArr[0]);
}
return p.a.c1.a.a(new p.a.y0.e.e.v(fromArray(g0VarArr), p.a.y0.b.a.e(), bufferSize(), p.a.y0.j.j.BOUNDARY));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatArrayDelayError(g0<? extends T>... g0VarArr) {
if (g0VarArr.length == 0) {
return empty();
}
if (g0VarArr.length == 1) {
return wrap(g0VarArr[0]);
}
return concatDelayError(fromArray(g0VarArr));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatArrayEager(g0<? extends T>... g0VarArr) {
return concatArrayEager(bufferSize(), bufferSize(), g0VarArr);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatArrayEagerDelayError(g0<? extends T>... g0VarArr) {
return concatArrayEagerDelayError(bufferSize(), bufferSize(), g0VarArr);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatDelayError(Iterable<? extends g0<? extends T>> iterable) {
p.a.y0.b.b.a(iterable, "sources is null");
return concatDelayError(fromIterable(iterable));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatEager(g0<? extends g0<? extends T>> g0Var) {
return concatEager(g0Var, bufferSize(), bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> create(e0<T> e0Var) {
p.a.y0.b.b.a(e0Var, "source is null");
return p.a.c1.a.a(new p.a.y0.e.e.c0(e0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> defer(Callable<? extends g0<? extends T>> callable) {
p.a.y0.b.b.a(callable, "supplier is null");
return p.a.c1.a.a(new p.a.y0.e.e.f0(callable));
}
@p.a.t0.d
@p.a.t0.h("none")
private b0<T> doOnEach(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar, p.a.x0.a aVar2) {
p.a.y0.b.b.a(gVar, "onNext is null");
p.a.y0.b.b.a(gVar2, "onError is null");
p.a.y0.b.b.a(aVar, "onComplete is null");
p.a.y0.b.b.a(aVar2, "onAfterTerminate is null");
return p.a.c1.a.a(new p.a.y0.e.e.o0(this, gVar, gVar2, aVar, aVar2));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> empty() {
return p.a.c1.a.a(t0.a);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> error(Callable<? extends Throwable> callable) {
p.a.y0.b.b.a(callable, "errorSupplier is null");
return p.a.c1.a.a(new u0(callable));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> fromArray(T... tArr) {
p.a.y0.b.b.a(tArr, "items is null");
if (tArr.length == 0) {
return empty();
}
if (tArr.length == 1) {
return just(tArr[0]);
}
return p.a.c1.a.a(new c1(tArr));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> fromCallable(Callable<? extends T> callable) {
p.a.y0.b.b.a(callable, "supplier is null");
return p.a.c1.a.a((b0) new d1(callable));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> fromFuture(Future<? extends T> future) {
p.a.y0.b.b.a(future, "future is null");
return p.a.c1.a.a(new e1(future, 0L, null));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> fromIterable(Iterable<? extends T> iterable) {
p.a.y0.b.b.a(iterable, "source is null");
return p.a.c1.a.a(new f1(iterable));
}
@p.a.t0.f
@p.a.t0.h("none")
@p.a.t0.b(p.a.t0.a.UNBOUNDED_IN)
@p.a.t0.d
public static <T> b0<T> fromPublisher(x.g.c<? extends T> cVar) {
p.a.y0.b.b.a(cVar, "publisher is null");
return p.a.c1.a.a(new g1(cVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> generate(p.a.x0.g<k<T>> gVar) {
p.a.y0.b.b.a(gVar, "generator is null");
return generate(p.a.y0.b.a.h(), o1.a(gVar), p.a.y0.b.a.d());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static b0<Long> interval(long j2, long j3, TimeUnit timeUnit) {
return interval(j2, j3, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static b0<Long> intervalRange(long j2, long j3, long j4, long j5, TimeUnit timeUnit) {
return intervalRange(j2, j3, j4, j5, timeUnit, p.a.e1.b.a());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2) {
p.a.y0.b.b.a((Object) t2, "item is null");
return p.a.c1.a.a((b0) new s1(t2));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(Iterable<? extends g0<? extends T>> iterable, int i2, int i3) {
return fromIterable(iterable).flatMap(p.a.y0.b.a.e(), false, i2, i3);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeArray(int i2, int i3, g0<? extends T>... g0VarArr) {
return fromArray(g0VarArr).flatMap(p.a.y0.b.a.e(), false, i2, i3);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeArrayDelayError(int i2, int i3, g0<? extends T>... g0VarArr) {
return fromArray(g0VarArr).flatMap(p.a.y0.b.a.e(), true, i2, i3);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(Iterable<? extends g0<? extends T>> iterable) {
return fromIterable(iterable).flatMap(p.a.y0.b.a.e(), true);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> never() {
return p.a.c1.a.a(c2.a);
}
@p.a.t0.d
@p.a.t0.h("none")
public static b0<Integer> range(int i2, int i3) {
if (i3 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + i3);
} else if (i3 == 0) {
return empty();
} else {
if (i3 == 1) {
return just(Integer.valueOf(i2));
}
if (i2 + (i3 - 1) <= 2147483647L) {
return p.a.c1.a.a(new i2(i2, i3));
}
throw new IllegalArgumentException("Integer overflow");
}
}
@p.a.t0.d
@p.a.t0.h("none")
public static b0<Long> rangeLong(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 empty();
} else {
if (j3 == 1) {
return just(Long.valueOf(j2));
}
long j4 = (j3 - 1) + j2;
if (j2 > 0 && j4 < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
return p.a.c1.a.a(new j2(j2, j3));
}
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> sequenceEqual(g0<? extends T> g0Var, g0<? extends T> g0Var2) {
return sequenceEqual(g0Var, g0Var2, p.a.y0.b.b.a(), bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> switchOnNext(g0<? extends g0<? extends T>> g0Var, int i2) {
p.a.y0.b.b.a(g0Var, "sources is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new m3(g0Var, p.a.y0.b.a.e(), i2, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> switchOnNextDelayError(g0<? extends g0<? extends T>> g0Var) {
return switchOnNextDelayError(g0Var, bufferSize());
}
private b0<T> timeout0(long j2, TimeUnit timeUnit, g0<? extends T> g0Var, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "timeUnit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new y3(this, j2, timeUnit, j0Var, g0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static b0<Long> timer(long j2, TimeUnit timeUnit) {
return timer(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> unsafeCreate(g0<T> g0Var) {
p.a.y0.b.b.a(g0Var, "onSubscribe is null");
if (!(g0Var instanceof b0)) {
return p.a.c1.a.a(new h1(g0Var));
}
throw new IllegalArgumentException("unsafeCreate(Observable) should be upgraded");
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, D> b0<T> using(Callable<? extends D> callable, p.a.x0.o<? super D, ? extends g0<? extends T>> oVar, p.a.x0.g<? super D> gVar) {
return using(callable, oVar, gVar, true);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> wrap(g0<T> g0Var) {
p.a.y0.b.b.a(g0Var, "source is null");
if (g0Var instanceof b0) {
return p.a.c1.a.a((b0) g0Var);
}
return p.a.c1.a.a(new h1(g0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> zip(Iterable<? extends g0<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(iterable, "sources is null");
return p.a.c1.a.a(new l4(null, iterable, oVar, bufferSize(), false));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> zipArray(p.a.x0.o<? super Object[], ? extends R> oVar, boolean z2, int i2, g0<? extends T>... g0VarArr) {
if (g0VarArr.length == 0) {
return empty();
}
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new l4(g0VarArr, null, oVar, i2, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> zipIterable(Iterable<? extends g0<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(iterable, "sources is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new l4(null, iterable, oVar, i2, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Boolean> all(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new p.a.y0.e.e.g(this, rVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> ambWith(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return ambArray(this, g0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Boolean> any(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new p.a.y0.e.e.j(this, rVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> R as(@p.a.t0.f c0<T, ? extends R> c0Var) {
return (R) ((c0) p.a.y0.b.b.a(c0Var, "converter is null")).apply(this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final T blockingFirst() {
p.a.y0.d.f fVar = new p.a.y0.d.f();
subscribe(fVar);
T b = fVar.b();
if (b != null) {
return b;
}
throw new NoSuchElementException();
}
@p.a.t0.h("none")
public final void blockingForEach(p.a.x0.g<? super T> gVar) {
Iterator<T> it = blockingIterable().iterator();
while (it.hasNext()) {
try {
gVar.accept(it.next());
} catch (Throwable th) {
p.a.v0.b.b(th);
((p.a.u0.c) it).dispose();
throw p.a.y0.j.k.c(th);
}
}
}
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> blockingIterable() {
return blockingIterable(bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final T blockingLast() {
p.a.y0.d.g gVar = new p.a.y0.d.g();
subscribe(gVar);
T b = gVar.b();
if (b != null) {
return b;
}
throw new NoSuchElementException();
}
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> blockingLatest() {
return new p.a.y0.e.e.c(this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> blockingMostRecent(T t2) {
return new p.a.y0.e.e.d(this, t2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> blockingNext() {
return new p.a.y0.e.e.e(this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final T blockingSingle() {
T c = singleElement().c();
if (c != null) {
return c;
}
throw new NoSuchElementException();
}
@p.a.t0.h("none")
public final void blockingSubscribe() {
p.a.y0.e.e.l.a(this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<List<T>> buffer(int i2) {
return buffer(i2, i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> cache() {
return cacheWithInitialCapacity(16);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> cacheWithInitialCapacity(int i2) {
p.a.y0.b.b.a(i2, "initialCapacity");
return p.a.c1.a.a(new p.a.y0.e.e.r(this, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<U> cast(Class<U> cls) {
p.a.y0.b.b.a(cls, "clazz is null");
return (b0<U>) map(p.a.y0.b.a.a((Class) cls));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> k0<U> collect(Callable<? extends U> callable, p.a.x0.b<? super U, ? super T> bVar) {
p.a.y0.b.b.a(callable, "initialValueSupplier is null");
p.a.y0.b.b.a(bVar, "collector is null");
return p.a.c1.a.a(new p.a.y0.e.e.t(this, callable, bVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> k0<U> collectInto(U u2, p.a.x0.b<? super U, ? super T> bVar) {
p.a.y0.b.b.a(u2, "initialValue is null");
return collect(p.a.y0.b.a.b(u2), bVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> compose(h0<? super T, ? extends R> h0Var) {
return wrap(((h0) p.a.y0.b.b.a(h0Var, "composer is null")).apply(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar) {
return concatMap(oVar, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final c concatMapCompletable(p.a.x0.o<? super T, ? extends i> oVar) {
return concatMapCompletable(oVar, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final c concatMapCompletableDelayError(p.a.x0.o<? super T, ? extends i> oVar) {
return concatMapCompletableDelayError(oVar, true, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapDelayError(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar) {
return concatMapDelayError(oVar, bufferSize(), true);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapEager(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar) {
return concatMapEager(oVar, Integer.MAX_VALUE, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapEagerDelayError(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, boolean z2) {
return concatMapEagerDelayError(oVar, Integer.MAX_VALUE, bufferSize(), z2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<U> concatMapIterable(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new b1(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapMaybe(p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
return concatMapMaybe(oVar, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapMaybeDelayError(p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
return concatMapMaybeDelayError(oVar, true, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapSingle(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
return concatMapSingle(oVar, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapSingleDelayError(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
return concatMapSingleDelayError(oVar, true, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> concatWith(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return concat(this, g0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Boolean> contains(Object obj) {
p.a.y0.b.b.a(obj, "element is null");
return any(p.a.y0.b.a.a(obj));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Long> count() {
return p.a.c1.a.a(new p.a.y0.e.e.b0(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<T> debounce(p.a.x0.o<? super T, ? extends g0<U>> oVar) {
p.a.y0.b.b.a(oVar, "debounceSelector is null");
return p.a.c1.a.a(new p.a.y0.e.e.d0(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> defaultIfEmpty(T t2) {
p.a.y0.b.b.a((Object) t2, "defaultItem is null");
return switchIfEmpty(just(t2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<T> delay(p.a.x0.o<? super T, ? extends g0<U>> oVar) {
p.a.y0.b.b.a(oVar, "itemDelay is null");
return (b0<T>) flatMap(o1.b(oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<T> delaySubscription(g0<U> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return p.a.c1.a.a(new p.a.y0.e.e.h0(this, g0Var));
}
@Deprecated
@p.a.t0.d
@p.a.t0.h("none")
public final <T2> b0<T2> dematerialize() {
return p.a.c1.a.a(new p.a.y0.e.e.i0(this, p.a.y0.b.a.e()));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> distinct() {
return distinct(p.a.y0.b.a.e(), p.a.y0.b.a.c());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> distinctUntilChanged() {
return distinctUntilChanged(p.a.y0.b.a.e());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doAfterNext(p.a.x0.g<? super T> gVar) {
p.a.y0.b.b.a(gVar, "onAfterNext is null");
return p.a.c1.a.a(new p.a.y0.e.e.m0(this, gVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doAfterTerminate(p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onFinally is null");
return doOnEach(p.a.y0.b.a.d(), p.a.y0.b.a.d(), p.a.y0.b.a.c, aVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doFinally(p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onFinally is null");
return p.a.c1.a.a(new p.a.y0.e.e.n0(this, aVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnComplete(p.a.x0.a aVar) {
return doOnEach(p.a.y0.b.a.d(), p.a.y0.b.a.d(), aVar, p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnDispose(p.a.x0.a aVar) {
return doOnLifecycle(p.a.y0.b.a.d(), aVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnError(p.a.x0.g<? super Throwable> gVar) {
p.a.x0.g<? super T> d = p.a.y0.b.a.d();
p.a.x0.a aVar = p.a.y0.b.a.c;
return doOnEach(d, gVar, aVar, aVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnLifecycle(p.a.x0.g<? super p.a.u0.c> gVar, p.a.x0.a aVar) {
p.a.y0.b.b.a(gVar, "onSubscribe is null");
p.a.y0.b.b.a(aVar, "onDispose is null");
return p.a.c1.a.a(new p.a.y0.e.e.p0(this, gVar, aVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnNext(p.a.x0.g<? super T> gVar) {
p.a.x0.g<? super Throwable> d = p.a.y0.b.a.d();
p.a.x0.a aVar = p.a.y0.b.a.c;
return doOnEach(gVar, d, aVar, aVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnSubscribe(p.a.x0.g<? super p.a.u0.c> gVar) {
return doOnLifecycle(gVar, p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnTerminate(p.a.x0.a aVar) {
p.a.y0.b.b.a(aVar, "onTerminate is null");
return doOnEach(p.a.y0.b.a.d(), p.a.y0.b.a.a(aVar), aVar, p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> elementAt(long j2) {
if (j2 >= 0) {
return p.a.c1.a.a(new p.a.y0.e.e.r0(this, j2));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> elementAtOrError(long j2) {
if (j2 >= 0) {
return p.a.c1.a.a(new s0(this, j2, null));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> filter(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new v0(this, rVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> first(T t2) {
return elementAt(0L, t2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> firstElement() {
return elementAt(0L);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> firstOrError() {
return elementAtOrError(0L);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar) {
return flatMap((p.a.x0.o) oVar, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final c flatMapCompletable(p.a.x0.o<? super T, ? extends i> oVar) {
return flatMapCompletable(oVar, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<U> flatMapIterable(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new b1(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMapMaybe(p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
return flatMapMaybe(oVar, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMapSingle(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
return flatMapSingle(oVar, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c forEach(p.a.x0.g<? super T> gVar) {
return subscribe(gVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c forEachWhile(p.a.x0.r<? super T> rVar) {
return forEachWhile(rVar, p.a.y0.b.a.f29916f, p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K> b0<p.a.z0.b<K, T>> groupBy(p.a.x0.o<? super T, ? extends K> oVar) {
return (b0<p.a.z0.b<K, T>>) groupBy(oVar, p.a.y0.b.a.e(), false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <TRight, TLeftEnd, TRightEnd, R> b0<R> groupJoin(g0<? extends TRight> g0Var, p.a.x0.o<? super T, ? extends g0<TLeftEnd>> oVar, p.a.x0.o<? super TRight, ? extends g0<TRightEnd>> oVar2, p.a.x0.c<? super T, ? super b0<TRight>, ? extends R> cVar) {
p.a.y0.b.b.a(g0Var, "other is null");
p.a.y0.b.b.a(oVar, "leftEnd is null");
p.a.y0.b.b.a(oVar2, "rightEnd is null");
p.a.y0.b.b.a(cVar, "resultSelector is null");
return p.a.c1.a.a(new k1(this, g0Var, oVar, oVar2, cVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> hide() {
return p.a.c1.a.a(new l1(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final c ignoreElements() {
return p.a.c1.a.a(new n1(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<Boolean> isEmpty() {
return all(p.a.y0.b.a.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <TRight, TLeftEnd, TRightEnd, R> b0<R> join(g0<? extends TRight> g0Var, p.a.x0.o<? super T, ? extends g0<TLeftEnd>> oVar, p.a.x0.o<? super TRight, ? extends g0<TRightEnd>> oVar2, p.a.x0.c<? super T, ? super TRight, ? extends R> cVar) {
p.a.y0.b.b.a(g0Var, "other is null");
p.a.y0.b.b.a(oVar, "leftEnd is null");
p.a.y0.b.b.a(oVar2, "rightEnd is null");
p.a.y0.b.b.a(cVar, "resultSelector is null");
return p.a.c1.a.a(new r1(this, g0Var, oVar, oVar2, cVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> last(T t2) {
p.a.y0.b.b.a((Object) t2, "defaultItem is null");
return p.a.c1.a.a(new u1(this, t2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> lastElement() {
return p.a.c1.a.a(new t1(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> lastOrError() {
return p.a.c1.a.a(new u1(this, null));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> lift(f0<? extends R, ? super T> f0Var) {
p.a.y0.b.b.a(f0Var, "lifter is null");
return p.a.c1.a.a(new v1(this, f0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> map(p.a.x0.o<? super T, ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new w1(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<a0<T>> materialize() {
return p.a.c1.a.a(new y1(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> mergeWith(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return merge(this, g0Var);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> observeOn(j0 j0Var) {
return observeOn(j0Var, false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<U> ofType(Class<U> cls) {
p.a.y0.b.b.a(cls, "clazz is null");
return filter(p.a.y0.b.a.b((Class) cls)).cast(cls);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> onErrorResumeNext(p.a.x0.o<? super Throwable, ? extends g0<? extends T>> oVar) {
p.a.y0.b.b.a(oVar, "resumeFunction is null");
return p.a.c1.a.a(new e2(this, oVar, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> onErrorReturn(p.a.x0.o<? super Throwable, ? extends T> oVar) {
p.a.y0.b.b.a(oVar, "valueSupplier is null");
return p.a.c1.a.a(new f2(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> onErrorReturnItem(T t2) {
p.a.y0.b.b.a((Object) t2, "item is null");
return onErrorReturn(p.a.y0.b.a.c(t2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> onExceptionResumeNext(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "next is null");
return p.a.c1.a.a(new e2(this, p.a.y0.b.a.c(g0Var), true));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> onTerminateDetach() {
return p.a.c1.a.a(new p.a.y0.e.e.j0(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.z0.a<T> publish() {
return g2.a(this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> reduce(p.a.x0.c<T, T, T> cVar) {
p.a.y0.b.b.a(cVar, "reducer is null");
return p.a.c1.a.a(new k2(this, cVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> k0<R> reduceWith(Callable<R> callable, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(callable, "seedSupplier is null");
p.a.y0.b.b.a(cVar, "reducer is null");
return p.a.c1.a.a(new m2(this, callable, cVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> repeat() {
return repeat(Long.MAX_VALUE);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> repeatUntil(p.a.x0.e eVar) {
p.a.y0.b.b.a(eVar, "stop is null");
return p.a.c1.a.a(new p2(this, eVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> repeatWhen(p.a.x0.o<? super b0<Object>, ? extends g0<?>> oVar) {
p.a.y0.b.b.a(oVar, "handler is null");
return p.a.c1.a.a(new q2(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.z0.a<T> replay() {
return r2.a(this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> retry() {
return retry(Long.MAX_VALUE, p.a.y0.b.a.b());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> retryUntil(p.a.x0.e eVar) {
p.a.y0.b.b.a(eVar, "stop is null");
return retry(Long.MAX_VALUE, p.a.y0.b.a.a(eVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> retryWhen(p.a.x0.o<? super b0<Throwable>, ? extends g0<?>> oVar) {
p.a.y0.b.b.a(oVar, "handler is null");
return p.a.c1.a.a(new u2(this, oVar));
}
@p.a.t0.h("none")
public final void safeSubscribe(i0<? super T> i0Var) {
p.a.y0.b.b.a(i0Var, "observer is null");
if (i0Var instanceof p.a.a1.l) {
subscribe(i0Var);
} else {
subscribe(new p.a.a1.l(i0Var));
}
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> sample(long j2, TimeUnit timeUnit) {
return sample(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> scan(p.a.x0.c<T, T, T> cVar) {
p.a.y0.b.b.a(cVar, "accumulator is null");
return p.a.c1.a.a(new y2(this, cVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> scanWith(Callable<R> callable, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(callable, "seedSupplier is null");
p.a.y0.b.b.a(cVar, "accumulator is null");
return p.a.c1.a.a(new z2(this, callable, cVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> serialize() {
return p.a.c1.a.a(new c3(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> share() {
return publish().d();
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> single(T t2) {
p.a.y0.b.b.a((Object) t2, "defaultItem is null");
return p.a.c1.a.a(new e3(this, t2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final s<T> singleElement() {
return p.a.c1.a.a(new d3(this));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> singleOrError() {
return p.a.c1.a.a(new e3(this, null));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> skip(long j2) {
if (j2 <= 0) {
return p.a.c1.a.a(this);
}
return p.a.c1.a.a(new f3(this, j2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> skipLast(int i2) {
if (i2 >= 0) {
if (i2 == 0) {
return p.a.c1.a.a(this);
}
return p.a.c1.a.a(new g3(this, i2));
}
throw new IndexOutOfBoundsException("count >= 0 required but it was " + i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<T> skipUntil(g0<U> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return p.a.c1.a.a(new i3(this, g0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> skipWhile(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new j3(this, rVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> sorted() {
return toList().q().map(p.a.y0.b.a.a(p.a.y0.b.a.f())).flatMapIterable(p.a.y0.b.a.e());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> startWith(Iterable<? extends T> iterable) {
return concatArray(fromIterable(iterable), this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> startWithArray(T... tArr) {
b0 fromArray = fromArray(tArr);
if (fromArray == empty()) {
return p.a.c1.a.a(this);
}
return concatArray(fromArray, this);
}
@p.a.t0.h("none")
public final p.a.u0.c subscribe() {
return subscribe(p.a.y0.b.a.d(), p.a.y0.b.a.f29916f, p.a.y0.b.a.c, p.a.y0.b.a.d());
}
public abstract void subscribeActual(i0<? super T> i0Var);
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> subscribeOn(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new k3(this, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <E extends i0<? super T>> E subscribeWith(E e2) {
subscribe(e2);
return e2;
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> switchIfEmpty(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return p.a.c1.a.a(new l3(this, g0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar) {
return switchMap(oVar, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final c switchMapCompletable(@p.a.t0.f p.a.x0.o<? super T, ? extends i> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.o(this, oVar, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public final c switchMapCompletableDelayError(@p.a.t0.f p.a.x0.o<? super T, ? extends i> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.o(this, oVar, true));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMapDelayError(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar) {
return switchMapDelayError(oVar, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMapMaybe(@p.a.t0.f p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.p(this, oVar, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMapMaybeDelayError(@p.a.t0.f p.a.x0.o<? super T, ? extends y<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.p(this, oVar, true));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMapSingle(@p.a.t0.f p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.q(this, oVar, false));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMapSingleDelayError(@p.a.t0.f p.a.x0.o<? super T, ? extends q0<? extends R>> oVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new p.a.y0.e.d.q(this, oVar, true));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> take(long j2) {
if (j2 >= 0) {
return p.a.c1.a.a(new n3(this, j2));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> takeLast(int i2) {
if (i2 < 0) {
throw new IndexOutOfBoundsException("count >= 0 required but it was " + i2);
} else if (i2 == 0) {
return p.a.c1.a.a(new m1(this));
} else {
if (i2 == 1) {
return p.a.c1.a.a(new p3(this));
}
return p.a.c1.a.a(new o3(this, i2));
}
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<T> takeUntil(g0<U> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return p.a.c1.a.a(new r3(this, g0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> takeWhile(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new t3(this, rVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.a1.n<T> test() {
p.a.a1.n<T> nVar = new p.a.a1.n<>();
subscribe(nVar);
return nVar;
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> throttleFirst(long j2, TimeUnit timeUnit) {
return throttleFirst(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> throttleLast(long j2, TimeUnit timeUnit) {
return sample(j2, timeUnit);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> throttleLatest(long j2, TimeUnit timeUnit) {
return throttleLatest(j2, timeUnit, p.a.e1.b.a(), false);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> throttleWithTimeout(long j2, TimeUnit timeUnit) {
return debounce(j2, timeUnit);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timeInterval() {
return timeInterval(TimeUnit.MILLISECONDS, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <V> b0<T> timeout(p.a.x0.o<? super T, ? extends g0<V>> oVar) {
return timeout0(null, oVar, null);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timestamp() {
return timestamp(TimeUnit.MILLISECONDS, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> R to(p.a.x0.o<? super b0<T>, R> oVar) {
try {
return (R) ((p.a.x0.o) p.a.y0.b.b.a(oVar, "converter is null")).apply(this);
} catch (Throwable th) {
p.a.v0.b.b(th);
throw p.a.y0.j.k.c(th);
}
}
@p.a.t0.b(p.a.t0.a.SPECIAL)
@p.a.t0.d
@p.a.t0.h("none")
public final l<T> toFlowable(b bVar) {
p.a.y0.e.b.k1 k1Var = new p.a.y0.e.b.k1(this);
int i2 = a.a[bVar.ordinal()];
if (i2 != 1) {
if (i2 != 2) {
if (i2 != 3) {
if (i2 != 4) {
return k1Var.w();
}
return p.a.c1.a.a(new n2(k1Var));
}
return k1Var;
}
return k1Var.y();
}
return k1Var.x();
}
@p.a.t0.d
@p.a.t0.h("none")
public final Future<T> toFuture() {
return (Future) subscribeWith(new p.a.y0.d.q());
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> toList() {
return toList(16);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K> k0<Map<K, T>> toMap(p.a.x0.o<? super T, ? extends K> oVar) {
p.a.y0.b.b.a(oVar, "keySelector is null");
return (k0<Map<K, T>>) collect(p.a.y0.j.m.asCallable(), p.a.y0.b.a.a((p.a.x0.o) oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K> k0<Map<K, Collection<T>>> toMultimap(p.a.x0.o<? super T, ? extends K> oVar) {
return (k0<Map<K, Collection<T>>>) toMultimap(oVar, p.a.y0.b.a.e(), p.a.y0.j.m.asCallable(), p.a.y0.j.b.asFunction());
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> toSortedList() {
return toSortedList(p.a.y0.b.a.g());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> unsubscribeOn(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new c4(this, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<b0<T>> window(long j2) {
return window(j2, j2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> withLatestFrom(g0<? extends U> g0Var, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
p.a.y0.b.b.a(g0Var, "other is null");
p.a.y0.b.b.a(cVar, "combiner is null");
return p.a.c1.a.a(new j4(this, cVar, g0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> zipWith(Iterable<U> iterable, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
p.a.y0.b.b.a(iterable, "other is null");
p.a.y0.b.b.a(cVar, "zipper is null");
return p.a.c1.a.a(new m4(this, iterable, cVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatest(Iterable<? extends g0<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar) {
return combineLatest(iterable, oVar, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatestDelayError(p.a.x0.o<? super Object[], ? extends R> oVar, int i2, g0<? extends T>... g0VarArr) {
return combineLatestDelayError(g0VarArr, oVar, i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatArrayEager(int i2, int i3, g0<? extends T>... g0VarArr) {
return fromArray(g0VarArr).concatMapEagerDelayError(p.a.y0.b.a.e(), i2, i3, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatArrayEagerDelayError(int i2, int i3, g0<? extends T>... g0VarArr) {
return fromArray(g0VarArr).concatMapEagerDelayError(p.a.y0.b.a.e(), i2, i3, true);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatEager(g0<? extends g0<? extends T>> g0Var, int i2, int i3) {
return wrap(g0Var).concatMapEager(p.a.y0.b.a.e(), i2, i3);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static b0<Long> interval(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new p1(Math.max(0L, j2), Math.max(0L, j3), timeUnit, j0Var));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static b0<Long> intervalRange(long j2, long j3, long j4, long j5, TimeUnit timeUnit, j0 j0Var) {
int i2 = (j3 > 0L ? 1 : (j3 == 0L ? 0 : -1));
if (i2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + j3);
} else if (i2 == 0) {
return empty().delay(j4, timeUnit, j0Var);
} else {
long j6 = j2 + (j3 - 1);
if (j2 > 0 && j6 < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new q1(j2, j6, Math.max(0L, j4), Math.max(0L, j5), timeUnit, j0Var));
}
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(Iterable<? extends g0<? extends T>> iterable) {
return fromIterable(iterable).flatMap(p.a.y0.b.a.e());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeArray(g0<? extends T>... g0VarArr) {
return fromArray(g0VarArr).flatMap(p.a.y0.b.a.e(), g0VarArr.length);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeArrayDelayError(g0<? extends T>... g0VarArr) {
return fromArray(g0VarArr).flatMap(p.a.y0.b.a.e(), true, g0VarArr.length);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(Iterable<? extends g0<? extends T>> iterable, int i2, int i3) {
return fromIterable(iterable).flatMap(p.a.y0.b.a.e(), true, i2, i3);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> sequenceEqual(g0<? extends T> g0Var, g0<? extends T> g0Var2, p.a.x0.d<? super T, ? super T> dVar) {
return sequenceEqual(g0Var, g0Var2, dVar, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> switchOnNextDelayError(g0<? extends g0<? extends T>> g0Var, int i2) {
p.a.y0.b.b.a(g0Var, "sources is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new m3(g0Var, p.a.y0.b.a.e(), i2, true));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static b0<Long> timer(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new z3(Math.max(j2, 0L), timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, D> b0<T> using(Callable<? extends D> callable, p.a.x0.o<? super D, ? extends g0<? extends T>> oVar, p.a.x0.g<? super D> gVar, boolean z2) {
p.a.y0.b.b.a(callable, "resourceSupplier is null");
p.a.y0.b.b.a(oVar, "sourceSupplier is null");
p.a.y0.b.b.a(gVar, "disposer is null");
return p.a.c1.a.a(new d4(callable, oVar, gVar, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final Iterable<T> blockingIterable(int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
return new p.a.y0.e.e.b(this, i2);
}
@p.a.t0.h("none")
public final void blockingSubscribe(p.a.x0.g<? super T> gVar) {
p.a.y0.e.e.l.a(this, gVar, p.a.y0.b.a.f29916f, p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<List<T>> buffer(int i2, int i3) {
return (b0<List<T>>) buffer(i2, i3, p.a.y0.j.b.asCallable());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return empty();
}
return x2.a(call, oVar);
}
return p.a.c1.a.a(new p.a.y0.e.e.v(this, oVar, i2, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.d
@p.a.t0.h("none")
public final c concatMapCompletable(p.a.x0.o<? super T, ? extends i> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "capacityHint");
return p.a.c1.a.a(new p.a.y0.e.d.l(this, oVar, p.a.y0.j.j.IMMEDIATE, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final c concatMapCompletableDelayError(p.a.x0.o<? super T, ? extends i> oVar, boolean z2) {
return concatMapCompletableDelayError(oVar, z2, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapDelayError(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, int i2, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return empty();
}
return x2.a(call, oVar);
}
return p.a.c1.a.a(new p.a.y0.e.e.v(this, oVar, i2, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapEager(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, int i2, int i3) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.e.w(this, oVar, p.a.y0.j.j.IMMEDIATE, i2, i3));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapEagerDelayError(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, int i2, int i3, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.e.w(this, oVar, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY, i2, i3));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapMaybe(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.m(this, oVar, p.a.y0.j.j.IMMEDIATE, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapMaybeDelayError(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, boolean z2) {
return concatMapMaybeDelayError(oVar, z2, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapSingle(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.n(this, oVar, p.a.y0.j.j.IMMEDIATE, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapSingleDelayError(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, boolean z2) {
return concatMapSingleDelayError(oVar, z2, 2);
}
@p.a.t0.e
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> dematerialize(p.a.x0.o<? super T, a0<R>> oVar) {
p.a.y0.b.b.a(oVar, "selector is null");
return p.a.c1.a.a(new p.a.y0.e.e.i0(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K> b0<T> distinct(p.a.x0.o<? super T, K> oVar) {
return distinct(oVar, p.a.y0.b.a.c());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K> b0<T> distinctUntilChanged(p.a.x0.o<? super T, K> oVar) {
p.a.y0.b.b.a(oVar, "keySelector is null");
return p.a.c1.a.a(new p.a.y0.e.e.l0(this, oVar, p.a.y0.b.b.a()));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, boolean z2) {
return flatMap(oVar, z2, Integer.MAX_VALUE);
}
@p.a.t0.d
@p.a.t0.h("none")
public final c flatMapCompletable(p.a.x0.o<? super T, ? extends i> oVar, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new y0(this, oVar, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMapMaybe(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new z0(this, oVar, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMapSingle(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, boolean z2) {
p.a.y0.b.b.a(oVar, "mapper is null");
return p.a.c1.a.a(new a1(this, oVar, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c forEachWhile(p.a.x0.r<? super T> rVar, p.a.x0.g<? super Throwable> gVar) {
return forEachWhile(rVar, gVar, p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K> b0<p.a.z0.b<K, T>> groupBy(p.a.x0.o<? super T, ? extends K> oVar, boolean z2) {
return (b0<p.a.z0.b<K, T>>) groupBy(oVar, p.a.y0.b.a.e(), z2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> observeOn(j0 j0Var, boolean z2) {
return observeOn(j0Var, z2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> publish(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar) {
p.a.y0.b.b.a(oVar, "selector is null");
return p.a.c1.a.a(new h2(this, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> repeat(long j2) {
int i2 = (j2 > 0L ? 1 : (j2 == 0L ? 0 : -1));
if (i2 >= 0) {
if (i2 == 0) {
return empty();
}
return p.a.c1.a.a(new o2(this, j2));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar) {
p.a.y0.b.b.a(oVar, "selector is null");
return r2.a(o1.a(this), oVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> retry(p.a.x0.d<? super Integer, ? super Throwable> dVar) {
p.a.y0.b.b.a(dVar, "predicate is null");
return p.a.c1.a.a(new s2(this, dVar));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> sample(long j2, TimeUnit timeUnit, boolean z2) {
return sample(j2, timeUnit, p.a.e1.b.a(), z2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> sorted(Comparator<? super T> comparator) {
p.a.y0.b.b.a(comparator, "sortFunction is null");
return toList().q().map(p.a.y0.b.a.a((Comparator) comparator)).flatMapIterable(p.a.y0.b.a.e());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> startWith(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return concatArray(g0Var, this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar) {
return subscribe(gVar, p.a.y0.b.a.f29916f, p.a.y0.b.a.c, p.a.y0.b.a.d());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "bufferSize");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return empty();
}
return x2.a(call, oVar);
}
return p.a.c1.a.a(new m3(this, oVar, i2, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> switchMapDelayError(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "bufferSize");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return empty();
}
return x2.a(call, oVar);
}
return p.a.c1.a.a(new m3(this, oVar, i2, true));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> throttleFirst(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new u3(this, j2, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> throttleLast(long j2, TimeUnit timeUnit, j0 j0Var) {
return sample(j2, timeUnit, j0Var);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> throttleLatest(long j2, TimeUnit timeUnit, boolean z2) {
return throttleLatest(j2, timeUnit, p.a.e1.b.a(), z2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> throttleWithTimeout(long j2, TimeUnit timeUnit, j0 j0Var) {
return debounce(j2, timeUnit, j0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timeInterval(j0 j0Var) {
return timeInterval(TimeUnit.MILLISECONDS, j0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <V> b0<T> timeout(p.a.x0.o<? super T, ? extends g0<V>> oVar, g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return timeout0(null, oVar, g0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timestamp(j0 j0Var) {
return timestamp(TimeUnit.MILLISECONDS, j0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> toList(int i2) {
p.a.y0.b.b.a(i2, "capacityHint");
return p.a.c1.a.a(new b4(this, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> toSortedList(Comparator<? super T> comparator) {
p.a.y0.b.b.a(comparator, "comparator is null");
return (k0<List<T>>) toList().i(p.a.y0.b.a.a((Comparator) comparator));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<b0<T>> window(long j2, long j3) {
return window(j2, j3, bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatest(Iterable<? extends g0<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(iterable, "sources is null");
p.a.y0.b.b.a(oVar, "combiner is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new p.a.y0.e.e.u(null, iterable, oVar, i2 << 1, false));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatestDelayError(g0<? extends T>[] g0VarArr, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(oVar, "combiner is null");
if (g0VarArr.length == 0) {
return empty();
}
return p.a.c1.a.a(new p.a.y0.e.e.u(g0VarArr, null, oVar, i2 << 1, true));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concat(g0<? extends g0<? extends T>> g0Var) {
return concat(g0Var, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatDelayError(g0<? extends g0<? extends T>> g0Var) {
return concatDelayError(g0Var, bufferSize(), true);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatEager(Iterable<? extends g0<? extends T>> iterable) {
return concatEager(iterable, bufferSize(), bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> error(Throwable th) {
p.a.y0.b.b.a(th, "exception is null");
return error(p.a.y0.b.a.b(th));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> fromFuture(Future<? extends T> future, long j2, TimeUnit timeUnit) {
p.a.y0.b.b.a(future, "future is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
return p.a.c1.a.a(new e1(future, j2, timeUnit));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
return fromArray(t2, t3);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(Iterable<? extends g0<? extends T>> iterable, int i2) {
return fromIterable(iterable).flatMap(p.a.y0.b.a.e(), i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(Iterable<? extends g0<? extends T>> iterable, int i2) {
return fromIterable(iterable).flatMap(p.a.y0.b.a.e(), true, i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> sequenceEqual(g0<? extends T> g0Var, g0<? extends T> g0Var2, p.a.x0.d<? super T, ? super T> dVar, int i2) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(dVar, "isEqual is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new b3(g0Var, g0Var2, dVar, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final T blockingSingle(T t2) {
return single(t2).e();
}
@p.a.t0.h("none")
public final void blockingSubscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2) {
p.a.y0.e.e.l.a(this, gVar, gVar2, p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U extends Collection<? super T>> b0<U> buffer(int i2, int i3, Callable<U> callable) {
p.a.y0.b.b.a(i2, "count");
p.a.y0.b.b.a(i3, "skip");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.e.m(this, i2, i3, callable));
}
@p.a.t0.d
@p.a.t0.h("none")
public final c concatMapCompletableDelayError(p.a.x0.o<? super T, ? extends i> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.l(this, oVar, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<U> concatMapIterable(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return (b0<U>) concatMap(o1.a(oVar), i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapMaybeDelayError(p.a.x0.o<? super T, ? extends y<? extends R>> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.m(this, oVar, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> concatMapSingleDelayError(p.a.x0.o<? super T, ? extends q0<? extends R>> oVar, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.d.n(this, oVar, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> concatWith(@p.a.t0.f q0<? extends T> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return p.a.c1.a.a(new p.a.y0.e.e.z(this, q0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> debounce(long j2, TimeUnit timeUnit) {
return debounce(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> delay(long j2, TimeUnit timeUnit) {
return delay(j2, timeUnit, p.a.e1.b.a(), false);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> delaySubscription(long j2, TimeUnit timeUnit) {
return delaySubscription(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K> b0<T> distinct(p.a.x0.o<? super T, K> oVar, Callable<? extends Collection<? super K>> callable) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(callable, "collectionSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.e.k0(this, oVar, callable));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<T> elementAt(long j2, T t2) {
if (j2 >= 0) {
p.a.y0.b.b.a((Object) t2, "defaultItem is null");
return p.a.c1.a.a(new s0(this, j2, t2));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, boolean z2, int i2) {
return flatMap(oVar, z2, i2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> b0<V> flatMapIterable(p.a.x0.o<? super T, ? extends Iterable<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends V> cVar) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(cVar, "resultSelector is null");
return (b0<V>) flatMap(o1.a(oVar), cVar, false, bufferSize(), bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c forEachWhile(p.a.x0.r<? super T> rVar, p.a.x0.g<? super Throwable> gVar, p.a.x0.a aVar) {
p.a.y0.b.b.a(rVar, "onNext is null");
p.a.y0.b.b.a(gVar, "onError is null");
p.a.y0.b.b.a(aVar, "onComplete is null");
p.a.y0.d.p pVar = new p.a.y0.d.p(rVar, gVar, aVar);
subscribe(pVar);
return pVar;
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> b0<p.a.z0.b<K, V>> groupBy(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2) {
return groupBy(oVar, oVar2, false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> mergeWith(@p.a.t0.f q0<? extends T> q0Var) {
p.a.y0.b.b.a(q0Var, "other is null");
return p.a.c1.a.a(new b2(this, q0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> observeOn(j0 j0Var, boolean z2, int i2) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new d2(this, j0Var, z2, i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> onErrorResumeNext(g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "next is null");
return onErrorResumeNext(p.a.y0.b.a.c(g0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> k0<R> reduce(R r2, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(r2, "seed is null");
p.a.y0.b.b.a(cVar, "reducer is null");
return p.a.c1.a.a(new l2(this, r2, cVar));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> sample(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new v2(this, j2, timeUnit, j0Var, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> scan(R r2, p.a.x0.c<R, ? super T, R> cVar) {
p.a.y0.b.b.a(r2, "initialValue is null");
return scanWith(p.a.y0.b.a.b(r2), cVar);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> skip(long j2, TimeUnit timeUnit) {
return skipUntil(timer(j2, timeUnit));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2) {
return subscribe(gVar, gVar2, p.a.y0.b.a.c, p.a.y0.b.a.d());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> take(long j2, TimeUnit timeUnit) {
return takeUntil(timer(j2, timeUnit));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> takeUntil(p.a.x0.r<? super T> rVar) {
p.a.y0.b.b.a(rVar, "stopPredicate is null");
return p.a.c1.a.a(new s3(this, rVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.a1.n<T> test(boolean z2) {
p.a.a1.n<T> nVar = new p.a.a1.n<>();
if (z2) {
nVar.dispose();
}
subscribe(nVar);
return nVar;
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> throttleLatest(long j2, TimeUnit timeUnit, j0 j0Var) {
return throttleLatest(j2, timeUnit, j0Var, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timeInterval(TimeUnit timeUnit) {
return timeInterval(timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timestamp(TimeUnit timeUnit) {
return timestamp(timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> k0<Map<K, V>> toMap(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
return (k0<Map<K, V>>) collect(p.a.y0.j.m.asCallable(), p.a.y0.b.a.a(oVar, oVar2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<b0<T>> window(long j2, long j3, int i2) {
p.a.y0.b.b.b(j2, "count");
p.a.y0.b.b.b(j3, "skip");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new e4(this, j2, j3, i2));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concat(g0<? extends g0<? extends T>> g0Var, int i2) {
p.a.y0.b.b.a(g0Var, "sources is null");
p.a.y0.b.b.a(i2, "prefetch");
return p.a.c1.a.a(new p.a.y0.e.e.v(g0Var, p.a.y0.b.a.e(), i2, p.a.y0.j.j.IMMEDIATE));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatDelayError(g0<? extends g0<? extends T>> g0Var, int i2, boolean z2) {
p.a.y0.b.b.a(g0Var, "sources is null");
p.a.y0.b.b.a(i2, "prefetch is null");
return p.a.c1.a.a(new p.a.y0.e.e.v(g0Var, p.a.y0.b.a.e(), i2, z2 ? p.a.y0.j.j.END : p.a.y0.j.j.BOUNDARY));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concatEager(Iterable<? extends g0<? extends T>> iterable, int i2, int i3) {
return fromIterable(iterable).concatMapEagerDelayError(p.a.y0.b.a.e(), i2, i3, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(g0<? extends g0<? extends T>> g0Var) {
p.a.y0.b.b.a(g0Var, "sources is null");
return p.a.c1.a.a(new w0(g0Var, p.a.y0.b.a.e(), false, Integer.MAX_VALUE, bufferSize()));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(g0<? extends g0<? extends T>> g0Var) {
p.a.y0.b.b.a(g0Var, "sources is null");
return p.a.c1.a.a(new w0(g0Var, p.a.y0.b.a.e(), true, Integer.MAX_VALUE, bufferSize()));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> switchOnNext(g0<? extends g0<? extends T>> g0Var) {
return switchOnNext(g0Var, bufferSize());
}
private <U, V> b0<T> timeout0(g0<U> g0Var, p.a.x0.o<? super T, ? extends g0<V>> oVar, g0<? extends T> g0Var2) {
p.a.y0.b.b.a(oVar, "itemTimeoutIndicator is null");
return p.a.c1.a.a(new x3(this, g0Var, oVar, g0Var2));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> zip(g0<? extends g0<? extends T>> g0Var, p.a.x0.o<? super Object[], ? extends R> oVar) {
p.a.y0.b.b.a(oVar, "zipper is null");
p.a.y0.b.b.a(g0Var, "sources is null");
return p.a.c1.a.a(new a4(g0Var, 16).flatMap(o1.c(oVar)));
}
@p.a.t0.h("none")
public final void blockingSubscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar) {
p.a.y0.e.e.l.a(this, gVar, gVar2, aVar);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> debounce(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new p.a.y0.e.e.e0(this, j2, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> delay(long j2, TimeUnit timeUnit, boolean z2) {
return delay(j2, timeUnit, p.a.e1.b.a(), z2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> delaySubscription(long j2, TimeUnit timeUnit, j0 j0Var) {
return delaySubscription(timer(j2, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> distinctUntilChanged(p.a.x0.d<? super T, ? super T> dVar) {
p.a.y0.b.b.a(dVar, "comparer is null");
return p.a.c1.a.a(new p.a.y0.e.e.l0(this, p.a.y0.b.a.e(), dVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, boolean z2, int i2, int i3) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
p.a.y0.b.b.a(i3, "bufferSize");
if (this instanceof p.a.y0.c.m) {
Object call = ((p.a.y0.c.m) this).call();
if (call == null) {
return empty();
}
return x2.a(call, oVar);
}
return p.a.c1.a.a(new w0(this, oVar, z2, i2, i3));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> b0<p.a.z0.b<K, V>> groupBy(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, boolean z2) {
return groupBy(oVar, oVar2, z2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar, int i2) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(i2, "bufferSize");
return r2.a(o1.a(this, i2), oVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> retry(long j2) {
return retry(j2, p.a.y0.b.a.b());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> skip(long j2, TimeUnit timeUnit, j0 j0Var) {
return skipUntil(timer(j2, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.O0)
public final b0<T> skipLast(long j2, TimeUnit timeUnit) {
return skipLast(j2, timeUnit, p.a.e1.b.g(), false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> startWith(T t2) {
p.a.y0.b.b.a((Object) t2, "item is null");
return concatArray(just(t2), this);
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar) {
return subscribe(gVar, gVar2, aVar, p.a.y0.b.a.d());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> take(long j2, TimeUnit timeUnit, j0 j0Var) {
return takeUntil(timer(j2, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> throttleLatest(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new v3(this, j2, timeUnit, j0Var, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timeInterval(TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new w3(this, timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> timeout(long j2, TimeUnit timeUnit) {
return timeout0(j2, timeUnit, null, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<p.a.e1.d<T>> timestamp(TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return (b0<p.a.e1.d<T>>) map(p.a.y0.b.a.a(timeUnit, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U extends Collection<? super T>> k0<U> toList(Callable<U> callable) {
p.a.y0.b.b.a(callable, "collectionSupplier is null");
return p.a.c1.a.a(new b4(this, callable));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> toSortedList(Comparator<? super T> comparator, int i2) {
p.a.y0.b.b.a(comparator, "comparator is null");
return (k0<List<T>>) toList(i2).i(p.a.y0.b.a.a((Comparator) comparator));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <T1, T2, R> b0<R> withLatestFrom(g0<T1> g0Var, g0<T2> g0Var2, p.a.x0.h<? super T, ? super T1, ? super T2, R> hVar) {
p.a.y0.b.b.a(g0Var, "o1 is null");
p.a.y0.b.b.a(g0Var2, "o2 is null");
p.a.y0.b.b.a(hVar, "combiner is null");
return withLatestFrom(new g0[]{g0Var, g0Var2}, p.a.y0.b.a.a((p.a.x0.h) hVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> zipWith(g0<? extends U> g0Var, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
p.a.y0.b.b.a(g0Var, "other is null");
return zip(this, g0Var, cVar);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, S> b0<T> generate(Callable<S> callable, p.a.x0.b<S, k<T>> bVar) {
p.a.y0.b.b.a(bVar, "generator is null");
return generate(callable, o1.a(bVar), p.a.y0.b.a.d());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public static b0<Long> interval(long j2, TimeUnit timeUnit) {
return interval(j2, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final T blockingFirst(T t2) {
p.a.y0.d.f fVar = new p.a.y0.d.f();
subscribe(fVar);
T b = fVar.b();
return b != null ? b : t2;
}
@p.a.t0.d
@p.a.t0.h("none")
public final T blockingLast(T t2) {
p.a.y0.d.g gVar = new p.a.y0.d.g();
subscribe(gVar);
T b = gVar.b();
return b != null ? b : t2;
}
@p.a.t0.h("none")
public final void blockingSubscribe(i0<? super T> i0Var) {
p.a.y0.e.e.l.a(this, i0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> concatWith(@p.a.t0.f y<? extends T> yVar) {
p.a.y0.b.b.a(yVar, "other is null");
return p.a.c1.a.a(new p.a.y0.e.e.y(this, yVar));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> delay(long j2, TimeUnit timeUnit, j0 j0Var) {
return delay(j2, timeUnit, j0Var, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> b0<p.a.z0.b<K, V>> groupBy(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, boolean z2, int i2) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new j1(this, oVar, oVar2, i2, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> mergeWith(@p.a.t0.f y<? extends T> yVar) {
p.a.y0.b.b.a(yVar, "other is null");
return p.a.c1.a.a(new a2(this, yVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> retry(long j2, p.a.x0.r<? super Throwable> rVar) {
if (j2 >= 0) {
p.a.y0.b.b.a(rVar, "predicate is null");
return p.a.c1.a.a(new t2(this, j2, rVar));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.O0)
public final b0<T> skipLast(long j2, TimeUnit timeUnit, boolean z2) {
return skipLast(j2, timeUnit, p.a.e1.b.g(), z2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.u0.c subscribe(p.a.x0.g<? super T> gVar, p.a.x0.g<? super Throwable> gVar2, p.a.x0.a aVar, p.a.x0.g<? super p.a.u0.c> gVar3) {
p.a.y0.b.b.a(gVar, "onNext is null");
p.a.y0.b.b.a(gVar2, "onError is null");
p.a.y0.b.b.a(aVar, "onComplete is null");
p.a.y0.b.b.a(gVar3, "onSubscribe is null");
p.a.y0.d.u uVar = new p.a.y0.d.u(gVar, gVar2, aVar, gVar3);
subscribe(uVar);
return uVar;
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.O0)
public final b0<T> takeLast(long j2, long j3, TimeUnit timeUnit) {
return takeLast(j2, j3, timeUnit, p.a.e1.b.g(), false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<T> timeout(long j2, TimeUnit timeUnit, g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return timeout0(j2, timeUnit, g0Var, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> k0<Map<K, Collection<V>>> toMultimap(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2) {
return toMultimap(oVar, oVar2, p.a.y0.j.m.asCallable(), p.a.y0.j.b.asFunction());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static <T> b0<T> fromFuture(Future<? extends T> future, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return fromFuture(future, j2, timeUnit).subscribeOn(j0Var);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static b0<Long> interval(long j2, TimeUnit timeUnit, j0 j0Var) {
return interval(j2, j2, timeUnit, j0Var);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
return fromArray(t2, t3, t4);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(g0<? extends g0<? extends T>> g0Var, int i2) {
p.a.y0.b.b.a(g0Var, "sources is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
return p.a.c1.a.a(new w0(g0Var, p.a.y0.b.a.e(), false, i2, bufferSize()));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(g0<? extends g0<? extends T>> g0Var, int i2) {
p.a.y0.b.b.a(g0Var, "sources is null");
p.a.y0.b.b.a(i2, "maxConcurrency");
return p.a.c1.a.a(new w0(g0Var, p.a.y0.b.a.e(), true, i2, bufferSize()));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> delay(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new p.a.y0.e.e.g0(this, j2, timeUnit, j0Var, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnEach(p.a.x0.g<? super a0<T>> gVar) {
p.a.y0.b.b.a(gVar, "onNotification is null");
return doOnEach(p.a.y0.b.a.c((p.a.x0.g) gVar), p.a.y0.b.a.b((p.a.x0.g) gVar), p.a.y0.b.a.a((p.a.x0.g) gVar), p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> sample(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return p.a.c1.a.a(new v2(this, j2, timeUnit, j0Var, z2));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> skipLast(long j2, TimeUnit timeUnit, j0 j0Var) {
return skipLast(j2, timeUnit, j0Var, false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> takeLast(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
return takeLast(j2, j3, timeUnit, j0Var, false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> k0<Map<K, V>> toMap(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, Callable<? extends Map<K, V>> callable) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
p.a.y0.b.b.a(callable, "mapSupplier is null");
return (k0<Map<K, V>>) collect(callable, p.a.y0.b.a.a(oVar, oVar2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final k0<List<T>> toSortedList(int i2) {
return toSortedList(p.a.y0.b.a.g(), i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> zipWith(g0<? extends U> g0Var, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2) {
return zip(this, g0Var, cVar, z2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatest(g0<? extends T>[] g0VarArr, p.a.x0.o<? super Object[], ? extends R> oVar) {
return combineLatest(g0VarArr, oVar, bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concat(g0<? extends T> g0Var, g0<? extends T> g0Var2) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
return concatArray(g0Var, g0Var2);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, S> b0<T> generate(Callable<S> callable, p.a.x0.b<S, k<T>> bVar, p.a.x0.g<? super S> gVar) {
p.a.y0.b.b.a(bVar, "generator is null");
return generate(callable, o1.a(bVar), gVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U extends Collection<? super T>> b0<U> buffer(int i2, Callable<U> callable) {
return buffer(i2, i2, callable);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> concatWith(@p.a.t0.f i iVar) {
p.a.y0.b.b.a(iVar, "other is null");
return p.a.c1.a.a(new p.a.y0.e.e.x(this, iVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> mergeWith(@p.a.t0.f i iVar) {
p.a.y0.b.b.a(iVar, "other is null");
return p.a.c1.a.a(new z1(this, iVar));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar, int i2, long j2, TimeUnit timeUnit) {
return replay(oVar, i2, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> skipLast(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
return skipLast(j2, timeUnit, j0Var, z2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> takeLast(long j2, long j3, TimeUnit timeUnit, j0 j0Var, boolean z2, int i2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
if (j2 >= 0) {
return p.a.c1.a.a(new q3(this, j2, j3, timeUnit, j0Var, i2, z2));
}
throw new IndexOutOfBoundsException("count >= 0 required but it was " + j2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> timeout(long j2, TimeUnit timeUnit, j0 j0Var, g0<? extends T> g0Var) {
p.a.y0.b.b.a(g0Var, "other is null");
return timeout0(j2, timeUnit, g0Var, j0Var);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<b0<T>> window(long j2, long j3, TimeUnit timeUnit) {
return window(j2, j3, timeUnit, p.a.e1.b.a(), bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> zipWith(g0<? extends U> g0Var, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2, int i2) {
return zip(this, g0Var, cVar, z2, i2);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatest(g0<? extends T>[] g0VarArr, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(g0VarArr, "sources is null");
if (g0VarArr.length == 0) {
return empty();
}
p.a.y0.b.b.a(oVar, "combiner is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new p.a.y0.e.e.u(g0VarArr, null, oVar, i2 << 1, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatestDelayError(Iterable<? extends g0<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar) {
return combineLatestDelayError(iterable, oVar, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> k0<Boolean> sequenceEqual(g0<? extends T> g0Var, g0<? extends T> g0Var2, int i2) {
return sequenceEqual(g0Var, g0Var2, p.a.y0.b.b.a(), i2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<List<T>> buffer(long j2, long j3, TimeUnit timeUnit) {
return (b0<List<T>>) buffer(j2, j3, timeUnit, p.a.e1.b.a(), p.a.y0.j.b.asCallable());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar, int i2, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return r2.a(o1.a(this, i2, j2, timeUnit, j0Var), oVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> retry(p.a.x0.r<? super Throwable> rVar) {
return retry(Long.MAX_VALUE, rVar);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> skipLast(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2, int i2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new h3(this, j2, timeUnit, j0Var, i2 << 1, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> k0<Map<K, Collection<V>>> toMultimap(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, Callable<? extends Map<K, Collection<V>>> callable, p.a.x0.o<? super K, ? extends Collection<? super V>> oVar3) {
p.a.y0.b.b.a(oVar, "keySelector is null");
p.a.y0.b.b.a(oVar2, "valueSelector is null");
p.a.y0.b.b.a(callable, "mapSupplier is null");
p.a.y0.b.b.a(oVar3, "collectionFactory is null");
return (k0<Map<K, Collection<V>>>) collect(callable, p.a.y0.b.a.a(oVar, oVar2, oVar3));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<b0<T>> window(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
return window(j2, j3, timeUnit, j0Var, bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, R> b0<R> combineLatestDelayError(Iterable<? extends g0<? extends T>> iterable, p.a.x0.o<? super Object[], ? extends R> oVar, int i2) {
p.a.y0.b.b.a(iterable, "sources is null");
p.a.y0.b.b.a(oVar, "combiner is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new p.a.y0.e.e.u(null, iterable, oVar, i2 << 1, true));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public static <T> b0<T> fromFuture(Future<? extends T> future, j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return fromFuture(future).subscribeOn(j0Var);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T, S> b0<T> generate(Callable<S> callable, p.a.x0.c<S, k<T>, S> cVar) {
return generate(callable, cVar, p.a.y0.b.a.d());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(g0<? extends T> g0Var, g0<? extends T> g0Var2) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
return fromArray(g0Var, g0Var2).flatMap(p.a.y0.b.a.e(), false, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(g0<? extends T> g0Var, g0<? extends T> g0Var2) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
return fromArray(g0Var, g0Var2).flatMap(p.a.y0.b.a.e(), true, 2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.c) cVar), false, bufferSize(), g0Var, g0Var2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<List<T>> buffer(long j2, long j3, TimeUnit timeUnit, j0 j0Var) {
return (b0<List<T>>) buffer(j2, j3, timeUnit, j0Var, p.a.y0.j.b.asCallable());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> b0<T> delay(g0<U> g0Var, p.a.x0.o<? super T, ? extends g0<V>> oVar) {
return delaySubscription(g0Var).delay(oVar);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<T> sample(g0<U> g0Var) {
p.a.y0.b.b.a(g0Var, "sampler is null");
return p.a.c1.a.a(new w2(this, g0Var, false));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> timeout(long j2, TimeUnit timeUnit, j0 j0Var) {
return timeout0(j2, timeUnit, null, j0Var);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<b0<T>> window(long j2, long j3, TimeUnit timeUnit, j0 j0Var, int i2) {
p.a.y0.b.b.b(j2, "timespan");
p.a.y0.b.b.b(j3, "timeskip");
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
return p.a.c1.a.a(new i4(this, j2, j3, timeUnit, j0Var, Long.MAX_VALUE, i2, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <T1, T2, T3, R> b0<R> withLatestFrom(g0<T1> g0Var, g0<T2> g0Var2, g0<T3> g0Var3, p.a.x0.i<? super T, ? super T1, ? super T2, ? super T3, R> iVar) {
p.a.y0.b.b.a(g0Var, "o1 is null");
p.a.y0.b.b.a(g0Var2, "o2 is null");
p.a.y0.b.b.a(g0Var3, "o3 is null");
p.a.y0.b.b.a(iVar, "combiner is null");
return withLatestFrom(new g0[]{g0Var, g0Var2, g0Var3}, p.a.y0.b.a.a((p.a.x0.i) iVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concat(g0<? extends T> g0Var, g0<? extends T> g0Var2, g0<? extends T> g0Var3) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
return concatArray(g0Var, g0Var2, g0Var3);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T, S> b0<T> generate(Callable<S> callable, p.a.x0.c<S, k<T>, S> cVar, p.a.x0.g<? super S> gVar) {
p.a.y0.b.b.a(callable, "initialState is null");
p.a.y0.b.b.a(cVar, "generator is null");
p.a.y0.b.b.a(gVar, "disposeState is null");
return p.a.c1.a.a(new i1(callable, cVar, gVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4, T t5) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
return fromArray(t2, t3, t4, t5);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final <U extends Collection<? super T>> b0<U> buffer(long j2, long j3, TimeUnit timeUnit, j0 j0Var, Callable<U> callable) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.e.q(this, j2, j3, timeUnit, j0Var, callable, Integer.MAX_VALUE, false));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> b0<T> timeout(g0<U> g0Var, p.a.x0.o<? super T, ? extends g0<V>> oVar) {
p.a.y0.b.b.a(g0Var, "firstTimeoutIndicator is null");
return timeout0(g0Var, oVar, null);
}
@p.a.t0.d
@p.a.t0.h("none")
public final b0<T> doOnEach(i0<? super T> i0Var) {
p.a.y0.b.b.a(i0Var, "observer is null");
return doOnEach(o1.c(i0Var), o1.b(i0Var), o1.a(i0Var), p.a.y0.b.a.c);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U> b0<T> sample(g0<U> g0Var, boolean z2) {
p.a.y0.b.b.a(g0Var, "sampler is null");
return p.a.c1.a.a(new w2(this, g0Var, z2));
}
@Override
@p.a.t0.h("none")
public final void subscribe(i0<? super T> i0Var) {
p.a.y0.b.b.a(i0Var, "observer is null");
try {
i0<? super T> a2 = p.a.c1.a.a(this, i0Var);
p.a.y0.b.b.a(a2, "The RxJavaPlugins.onSubscribe hook returned a null Observer. Please change the handler provided to RxJavaPlugins.setOnObservableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
subscribeActual(a2);
} catch (NullPointerException e2) {
throw e2;
} catch (Throwable th) {
p.a.v0.b.b(th);
p.a.c1.a.b(th);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(g0<? extends T> g0Var, g0<? extends T> g0Var2, g0<? extends T> g0Var3) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
return fromArray(g0Var, g0Var2, g0Var3).flatMap(p.a.y0.b.a.e(), false, 3);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(g0<? extends T> g0Var, g0<? extends T> g0Var2, g0<? extends T> g0Var3) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
return fromArray(g0Var, g0Var2, g0Var3).flatMap(p.a.y0.b.a.e(), true, 3);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar, boolean z2) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.c) cVar), z2, bufferSize(), g0Var, g0Var2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, p.a.x0.o<? super Throwable, ? extends g0<? extends R>> oVar2, Callable<? extends g0<? extends R>> callable) {
p.a.y0.b.b.a(oVar, "onNextMapper is null");
p.a.y0.b.b.a(oVar2, "onErrorMapper is null");
p.a.y0.b.b.a(callable, "onCompleteSupplier is null");
return merge(new x1(this, oVar, oVar2, callable));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.O0)
public final b0<T> takeLast(long j2, TimeUnit timeUnit) {
return takeLast(j2, timeUnit, p.a.e1.b.g(), false, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> b0<T> timeout(g0<U> g0Var, p.a.x0.o<? super T, ? extends g0<V>> oVar, g0<? extends T> g0Var2) {
p.a.y0.b.b.a(g0Var, "firstTimeoutIndicator is null");
p.a.y0.b.b.a(g0Var2, "other is null");
return timeout0(g0Var, oVar, g0Var2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.O0)
public final b0<T> takeLast(long j2, TimeUnit timeUnit, boolean z2) {
return takeLast(j2, timeUnit, p.a.e1.b.g(), z2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <K, V> k0<Map<K, Collection<V>>> toMultimap(p.a.x0.o<? super T, ? extends K> oVar, p.a.x0.o<? super T, ? extends V> oVar2, Callable<Map<K, Collection<V>>> callable) {
return toMultimap(oVar, oVar2, callable, p.a.y0.j.b.asFunction());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.c) cVar), bufferSize(), g0Var, g0Var2);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> concat(g0<? extends T> g0Var, g0<? extends T> g0Var2, g0<? extends T> g0Var3, g0<? extends T> g0Var4) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
return concatArray(g0Var, g0Var2, g0Var3, g0Var4);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<List<T>> buffer(long j2, TimeUnit timeUnit) {
return buffer(j2, timeUnit, p.a.e1.b.a(), Integer.MAX_VALUE);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar, int i2, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(i2, "bufferSize");
return r2.a(o1.a(this, i2), o1.a(oVar, j0Var));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> takeLast(long j2, TimeUnit timeUnit, j0 j0Var) {
return takeLast(j2, timeUnit, j0Var, false, bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4, T t5, T t6) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
return fromArray(t2, t3, t4, t5, t6);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, p.a.x0.c<? super T1, ? super T2, ? extends R> cVar, boolean z2, int i2) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.c) cVar), z2, i2, g0Var, g0Var2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<List<T>> buffer(long j2, TimeUnit timeUnit, int i2) {
return buffer(j2, timeUnit, p.a.e1.b.a(), i2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> takeLast(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2) {
return takeLast(j2, timeUnit, j0Var, z2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<b0<T>> window(long j2, TimeUnit timeUnit) {
return window(j2, timeUnit, p.a.e1.b.a(), Long.MAX_VALUE, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <T1, T2, T3, T4, R> b0<R> withLatestFrom(g0<T1> g0Var, g0<T2> g0Var2, g0<T3> g0Var3, g0<T4> g0Var4, p.a.x0.j<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> jVar) {
p.a.y0.b.b.a(g0Var, "o1 is null");
p.a.y0.b.b.a(g0Var2, "o2 is null");
p.a.y0.b.b.a(g0Var3, "o3 is null");
p.a.y0.b.b.a(g0Var4, "o4 is null");
p.a.y0.b.b.a(jVar, "combiner is null");
return withLatestFrom(new g0[]{g0Var, g0Var2, g0Var3, g0Var4}, p.a.y0.b.a.a((p.a.x0.j) jVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> merge(g0<? extends T> g0Var, g0<? extends T> g0Var2, g0<? extends T> g0Var3, g0<? extends T> g0Var4) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
return fromArray(g0Var, g0Var2, g0Var3, g0Var4).flatMap(p.a.y0.b.a.e(), false, 4);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> mergeDelayError(g0<? extends T> g0Var, g0<? extends T> g0Var2, g0<? extends T> g0Var3, g0<? extends T> g0Var4) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
return fromArray(g0Var, g0Var2, g0Var3, g0Var4).flatMap(p.a.y0.b.a.e(), true, 4);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<List<T>> buffer(long j2, TimeUnit timeUnit, j0 j0Var, int i2) {
return (b0<List<T>>) buffer(j2, timeUnit, j0Var, i2, p.a.y0.j.b.asCallable(), false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, p.a.x0.o<Throwable, ? extends g0<? extends R>> oVar2, Callable<? extends g0<? extends R>> callable, int i2) {
p.a.y0.b.b.a(oVar, "onNextMapper is null");
p.a.y0.b.b.a(oVar2, "onErrorMapper is null");
p.a.y0.b.b.a(callable, "onCompleteSupplier is null");
return merge(new x1(this, oVar, oVar2, callable), i2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<T> takeLast(long j2, TimeUnit timeUnit, j0 j0Var, boolean z2, int i2) {
return takeLast(Long.MAX_VALUE, j2, timeUnit, j0Var, z2, i2);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<b0<T>> window(long j2, TimeUnit timeUnit, long j3) {
return window(j2, timeUnit, p.a.e1.b.a(), j3, false);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, p.a.x0.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.h) hVar), bufferSize(), g0Var, g0Var2, g0Var3);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final <U extends Collection<? super T>> b0<U> buffer(long j2, TimeUnit timeUnit, j0 j0Var, int i2, Callable<U> callable, boolean z2) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
p.a.y0.b.b.a(i2, "count");
return p.a.c1.a.a(new p.a.y0.e.e.q(this, j2, j2, timeUnit, j0Var, callable, i2, z2));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final b0<b0<T>> window(long j2, TimeUnit timeUnit, long j3, boolean z2) {
return window(j2, timeUnit, p.a.e1.b.a(), j3, z2);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, p.a.x0.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.h) hVar), false, bufferSize(), g0Var, g0Var2, g0Var3);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<b0<T>> window(long j2, TimeUnit timeUnit, j0 j0Var) {
return window(j2, timeUnit, j0Var, Long.MAX_VALUE, false);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<b0<T>> window(long j2, TimeUnit timeUnit, j0 j0Var, long j3) {
return window(j2, timeUnit, j0Var, j3, false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends R>> oVar, int i2) {
return flatMap((p.a.x0.o) oVar, false, i2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar, long j2, TimeUnit timeUnit) {
return replay(oVar, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<b0<T>> window(long j2, TimeUnit timeUnit, j0 j0Var, long j3, boolean z2) {
return window(j2, timeUnit, j0Var, j3, z2, bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, p.a.x0.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.i) iVar), bufferSize(), g0Var, g0Var2, g0Var3, g0Var4);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4, T t5, T t6, T t7) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
return fromArray(t2, t3, t4, t5, t6, t7);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar) {
return flatMap(oVar, cVar, false, bufferSize(), bufferSize());
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return r2.a(o1.a(this, j2, timeUnit, j0Var), oVar);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<b0<T>> window(long j2, TimeUnit timeUnit, j0 j0Var, long j3, boolean z2, int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(j0Var, "scheduler is null");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.b(j3, "count");
return p.a.c1.a.a(new i4(this, j2, j2, timeUnit, j0Var, j3, i2, z2));
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, p.a.x0.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.i) iVar), false, bufferSize(), g0Var, g0Var2, g0Var3, g0Var4);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final b0<List<T>> buffer(long j2, TimeUnit timeUnit, j0 j0Var) {
return (b0<List<T>>) buffer(j2, timeUnit, j0Var, Integer.MAX_VALUE, p.a.y0.j.b.asCallable(), false);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2) {
return flatMap(oVar, cVar, z2, bufferSize(), bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> withLatestFrom(g0<?>[] g0VarArr, p.a.x0.o<? super Object[], R> oVar) {
p.a.y0.b.b.a(g0VarArr, "others is null");
p.a.y0.b.b.a(oVar, "combiner is null");
return p.a.c1.a.a(new k4(this, g0VarArr, oVar));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <TOpening, TClosing> b0<List<T>> buffer(g0<? extends TOpening> g0Var, p.a.x0.o<? super TOpening, ? extends g0<? extends TClosing>> oVar) {
return (b0<List<T>>) buffer(g0Var, oVar, p.a.y0.j.b.asCallable());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2, int i2) {
return flatMap(oVar, cVar, z2, i2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <TOpening, TClosing, U extends Collection<? super T>> b0<U> buffer(g0<? extends TOpening> g0Var, p.a.x0.o<? super TOpening, ? extends g0<? extends TClosing>> oVar, Callable<U> callable) {
p.a.y0.b.b.a(g0Var, "openingIndicator is null");
p.a.y0.b.b.a(oVar, "closingIndicator is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.e.n(this, g0Var, oVar, callable));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, boolean z2, int i2, int i3) {
p.a.y0.b.b.a(oVar, "mapper is null");
p.a.y0.b.b.a(cVar, "combiner is null");
return flatMap(o1.a(oVar, cVar), z2, i2, i3);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final <R> b0<R> replay(p.a.x0.o<? super b0<T>, ? extends g0<R>> oVar, j0 j0Var) {
p.a.y0.b.b.a(oVar, "selector is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return r2.a(o1.a(this), o1.a(oVar, j0Var));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <R> b0<R> withLatestFrom(Iterable<? extends g0<?>> iterable, p.a.x0.o<? super Object[], R> oVar) {
p.a.y0.b.b.a(iterable, "others is null");
p.a.y0.b.b.a(oVar, "combiner is null");
return p.a.c1.a.a(new k4(this, iterable, oVar));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, p.a.x0.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.j) jVar), bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B> b0<b0<T>> window(g0<B> g0Var) {
return window(g0Var, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, p.a.x0.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.j) jVar), false, bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, R> b0<R> flatMap(p.a.x0.o<? super T, ? extends g0<? extends U>> oVar, p.a.x0.c<? super T, ? super U, ? extends R> cVar, int i2) {
return flatMap(oVar, cVar, false, i2, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B> b0<b0<T>> window(g0<B> g0Var, int i2) {
p.a.y0.b.b.a(g0Var, "boundary is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new f4(this, g0Var, i2));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4, T t5, T t6, T t7, T t8) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
return fromArray(t2, t3, t4, t5, t6, t7, t8);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B> b0<List<T>> buffer(g0<B> g0Var) {
return (b0<List<T>>) buffer(g0Var, p.a.y0.j.b.asCallable());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B> b0<List<T>> buffer(g0<B> g0Var, int i2) {
p.a.y0.b.b.a(i2, "initialCapacity");
return (b0<List<T>>) buffer(g0Var, p.a.y0.b.a.b(i2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final p.a.z0.a<T> replay(int i2) {
p.a.y0.b.b.a(i2, "bufferSize");
return r2.a(this, i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> b0<b0<T>> window(g0<U> g0Var, p.a.x0.o<? super U, ? extends g0<V>> oVar) {
return window(g0Var, oVar, bufferSize());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B, U extends Collection<? super T>> b0<U> buffer(g0<B> g0Var, Callable<U> callable) {
p.a.y0.b.b.a(g0Var, "boundary is null");
p.a.y0.b.b.a(callable, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.e.p(this, g0Var, callable));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <U, V> b0<b0<T>> window(g0<U> g0Var, p.a.x0.o<? super U, ? extends g0<V>> oVar, int i2) {
p.a.y0.b.b.a(g0Var, "openingIndicator is null");
p.a.y0.b.b.a(oVar, "closingIndicator is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new g4(this, g0Var, oVar, i2));
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, p.a.x0.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.k) kVar), bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final p.a.z0.a<T> replay(int i2, long j2, TimeUnit timeUnit) {
return replay(i2, j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, p.a.x0.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.k) kVar), false, bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.z0.a<T> replay(int i2, long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(i2, "bufferSize");
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return r2.a(this, j2, timeUnit, j0Var, i2);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B> b0<List<T>> buffer(Callable<? extends g0<B>> callable) {
return (b0<List<T>>) buffer(callable, p.a.y0.j.b.asCallable());
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B, U extends Collection<? super T>> b0<U> buffer(Callable<? extends g0<B>> callable, Callable<U> callable2) {
p.a.y0.b.b.a(callable, "boundarySupplier is null");
p.a.y0.b.b.a(callable2, "bufferSupplier is null");
return p.a.c1.a.a(new p.a.y0.e.e.o(this, callable, callable2));
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B> b0<b0<T>> window(Callable<? extends g0<B>> callable) {
return window(callable, bufferSize());
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
p.a.y0.b.b.a((Object) t9, "item8 is null");
return fromArray(t2, t3, t4, t5, t6, t7, t8, t9);
}
@p.a.t0.d
@p.a.t0.h("none")
public final <B> b0<b0<T>> window(Callable<? extends g0<B>> callable, int i2) {
p.a.y0.b.b.a(callable, "boundary is null");
p.a.y0.b.b.a(i2, "bufferSize");
return p.a.c1.a.a(new h4(this, callable, i2));
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.z0.a<T> replay(int i2, j0 j0Var) {
p.a.y0.b.b.a(i2, "bufferSize");
return r2.a(replay(i2), j0Var);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, g0<? extends T7> g0Var7, p.a.x0.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
p.a.y0.b.b.a(g0Var7, "source7 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.l) lVar), bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6, g0Var7);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.L0)
public final p.a.z0.a<T> replay(long j2, TimeUnit timeUnit) {
return replay(j2, timeUnit, p.a.e1.b.a());
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, g0<? extends T7> g0Var7, p.a.x0.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
p.a.y0.b.b.a(g0Var7, "source7 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.l) lVar), false, bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6, g0Var7);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.z0.a<T> replay(long j2, TimeUnit timeUnit, j0 j0Var) {
p.a.y0.b.b.a(timeUnit, "unit is null");
p.a.y0.b.b.a(j0Var, "scheduler is null");
return r2.a(this, j2, timeUnit, j0Var);
}
@p.a.t0.d
@p.a.t0.h(p.a.t0.h.K0)
public final p.a.z0.a<T> replay(j0 j0Var) {
p.a.y0.b.b.a(j0Var, "scheduler is null");
return r2.a(replay(), j0Var);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
p.a.y0.b.b.a((Object) t9, "item8 is null");
p.a.y0.b.b.a((Object) t10, "item9 is null");
return fromArray(t2, t3, t4, t5, t6, t7, t8, t9, t10);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, g0<? extends T7> g0Var7, g0<? extends T8> g0Var8, p.a.x0.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
p.a.y0.b.b.a(g0Var7, "source7 is null");
p.a.y0.b.b.a(g0Var8, "source8 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.m) mVar), bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6, g0Var7, g0Var8);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, g0<? extends T7> g0Var7, g0<? extends T8> g0Var8, p.a.x0.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
p.a.y0.b.b.a(g0Var7, "source7 is null");
p.a.y0.b.b.a(g0Var8, "source8 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.m) mVar), false, bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6, g0Var7, g0Var8);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T> b0<T> just(T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10, T t11) {
p.a.y0.b.b.a((Object) t2, "item1 is null");
p.a.y0.b.b.a((Object) t3, "item2 is null");
p.a.y0.b.b.a((Object) t4, "item3 is null");
p.a.y0.b.b.a((Object) t5, "item4 is null");
p.a.y0.b.b.a((Object) t6, "item5 is null");
p.a.y0.b.b.a((Object) t7, "item6 is null");
p.a.y0.b.b.a((Object) t8, "item7 is null");
p.a.y0.b.b.a((Object) t9, "item8 is null");
p.a.y0.b.b.a((Object) t10, "item9 is null");
p.a.y0.b.b.a((Object) t11, "item10 is null");
return fromArray(t2, t3, t4, t5, t6, t7, t8, t9, t10, t11);
}
@p.a.t0.f
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> b0<R> combineLatest(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, g0<? extends T7> g0Var7, g0<? extends T8> g0Var8, g0<? extends T9> g0Var9, p.a.x0.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
p.a.y0.b.b.a(g0Var7, "source7 is null");
p.a.y0.b.b.a(g0Var8, "source8 is null");
p.a.y0.b.b.a(g0Var9, "source9 is null");
return combineLatest(p.a.y0.b.a.a((p.a.x0.n) nVar), bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6, g0Var7, g0Var8, g0Var9);
}
@p.a.t0.d
@p.a.t0.h("none")
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> b0<R> zip(g0<? extends T1> g0Var, g0<? extends T2> g0Var2, g0<? extends T3> g0Var3, g0<? extends T4> g0Var4, g0<? extends T5> g0Var5, g0<? extends T6> g0Var6, g0<? extends T7> g0Var7, g0<? extends T8> g0Var8, g0<? extends T9> g0Var9, p.a.x0.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
p.a.y0.b.b.a(g0Var, "source1 is null");
p.a.y0.b.b.a(g0Var2, "source2 is null");
p.a.y0.b.b.a(g0Var3, "source3 is null");
p.a.y0.b.b.a(g0Var4, "source4 is null");
p.a.y0.b.b.a(g0Var5, "source5 is null");
p.a.y0.b.b.a(g0Var6, "source6 is null");
p.a.y0.b.b.a(g0Var7, "source7 is null");
p.a.y0.b.b.a(g0Var8, "source8 is null");
p.a.y0.b.b.a(g0Var9, "source9 is null");
return zipArray(p.a.y0.b.a.a((p.a.x0.n) nVar), false, bufferSize(), g0Var, g0Var2, g0Var3, g0Var4, g0Var5, g0Var6, g0Var7, g0Var8, g0Var9);
}
}