Sunbit v2.4.4版本的 MD5 值为：a5021e5e2a58eb1d6741b432fe7533c4
以下内容为反编译后的 i0.java 源代码，内容仅作参考
package h.a.a.c;
import h.a.a.h.f.b.n1;
import h.a.a.h.f.c.q1;
import h.a.a.h.f.e.a1;
import h.a.a.h.f.e.a2;
import h.a.a.h.f.e.a3;
import h.a.a.h.f.e.a4;
import h.a.a.h.f.e.b2;
import h.a.a.h.f.e.b3;
import h.a.a.h.f.e.b4;
import h.a.a.h.f.e.c1;
import h.a.a.h.f.e.c2;
import h.a.a.h.f.e.c3;
import h.a.a.h.f.e.c4;
import h.a.a.h.f.e.d1;
import h.a.a.h.f.e.d2;
import h.a.a.h.f.e.d3;
import h.a.a.h.f.e.d4;
import h.a.a.h.f.e.e1;
import h.a.a.h.f.e.e2;
import h.a.a.h.f.e.e3;
import h.a.a.h.f.e.e4;
import h.a.a.h.f.e.f1;
import h.a.a.h.f.e.f2;
import h.a.a.h.f.e.g1;
import h.a.a.h.f.e.g2;
import h.a.a.h.f.e.g3;
import h.a.a.h.f.e.g4;
import h.a.a.h.f.e.h1;
import h.a.a.h.f.e.h2;
import h.a.a.h.f.e.h3;
import h.a.a.h.f.e.h4;
import h.a.a.h.f.e.i1;
import h.a.a.h.f.e.i2;
import h.a.a.h.f.e.i3;
import h.a.a.h.f.e.i4;
import h.a.a.h.f.e.j1;
import h.a.a.h.f.e.j2;
import h.a.a.h.f.e.j3;
import h.a.a.h.f.e.j4;
import h.a.a.h.f.e.k1;
import h.a.a.h.f.e.k2;
import h.a.a.h.f.e.k3;
import h.a.a.h.f.e.k4;
import h.a.a.h.f.e.l1;
import h.a.a.h.f.e.l2;
import h.a.a.h.f.e.l3;
import h.a.a.h.f.e.l4;
import h.a.a.h.f.e.m1;
import h.a.a.h.f.e.m2;
import h.a.a.h.f.e.m3;
import h.a.a.h.f.e.n2;
import h.a.a.h.f.e.n3;
import h.a.a.h.f.e.n4;
import h.a.a.h.f.e.o1;
import h.a.a.h.f.e.o2;
import h.a.a.h.f.e.o3;
import h.a.a.h.f.e.o4;
import h.a.a.h.f.e.p1;
import h.a.a.h.f.e.p2;
import h.a.a.h.f.e.p3;
import h.a.a.h.f.e.p4;
import h.a.a.h.f.e.q2;
import h.a.a.h.f.e.q3;
import h.a.a.h.f.e.q4;
import h.a.a.h.f.e.r1;
import h.a.a.h.f.e.r2;
import h.a.a.h.f.e.r3;
import h.a.a.h.f.e.r4;
import h.a.a.h.f.e.s1;
import h.a.a.h.f.e.s3;
import h.a.a.h.f.e.t1;
import h.a.a.h.f.e.t2;
import h.a.a.h.f.e.t3;
import h.a.a.h.f.e.u1;
import h.a.a.h.f.e.u2;
import h.a.a.h.f.e.u3;
import h.a.a.h.f.e.v1;
import h.a.a.h.f.e.v2;
import h.a.a.h.f.e.v3;
import h.a.a.h.f.e.w1;
import h.a.a.h.f.e.w2;
import h.a.a.h.f.e.w3;
import h.a.a.h.f.e.x1;
import h.a.a.h.f.e.x2;
import h.a.a.h.f.e.x3;
import h.a.a.h.f.e.y1;
import h.a.a.h.f.e.y2;
import h.a.a.h.f.e.y3;
import h.a.a.h.f.e.z0;
import h.a.a.h.f.e.z1;
import h.a.a.h.f.e.z2;
import h.a.a.h.f.e.z3;
import h.a.a.h.f.g.b1;
import java.util.Collection;
import java.util.Comparator;
import java.util.Iterator;
import java.util.List;
import java.util.Map;
import java.util.NoSuchElementException;
import java.util.Objects;
import java.util.Optional;
import java.util.Spliterators;
import java.util.concurrent.Callable;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.Future;
import java.util.concurrent.TimeUnit;
import java.util.function.Function;
import java.util.function.Supplier;
import java.util.stream.Collector;
import java.util.stream.Stream;
import java.util.stream.StreamSupport;
import me.leolin.shortcutbadger.impl.NewHtcHomeBadger;
public abstract class i0<T> implements n0<T> {
static class a {
static final int[] f13235a;
static {
int[] iArr = new int[i.values().length];
f13235a = iArr;
try {
iArr[i.DROP.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
f13235a[i.LATEST.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
try {
f13235a[i.MISSING.ordinal()] = 3;
} catch (NoSuchFieldError unused3) {
}
try {
f13235a[i.ERROR.ordinal()] = 4;
} catch (NoSuchFieldError unused4) {
}
}
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> amb(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.h(null, iterable));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> ambArray(@h.a.a.b.f n0<? extends T>... n0VarArr) {
Objects.requireNonNull(n0VarArr, "sources is null");
int length = n0VarArr.length;
if (length == 0) {
return empty();
}
if (length == 1) {
return wrap(n0VarArr[0]);
}
return h.a.a.l.a.a(new h.a.a.h.f.e.h(n0VarArr, null));
}
@h.a.a.b.d
public static int bufferSize() {
return s.U();
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatest(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return combineLatest(iterable, oVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatestArray(@h.a.a.b.f n0<? extends T>[] n0VarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return combineLatestArray(n0VarArr, oVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatestArrayDelayError(@h.a.a.b.f n0<? extends T>[] n0VarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return combineLatestArrayDelayError(n0VarArr, oVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatestDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
return combineLatestDelayError(iterable, oVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concat(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return fromIterable(iterable).concatMapDelayError(h.a.a.h.b.a.e(), false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> concatArray(@h.a.a.b.f n0<? extends T>... n0VarArr) {
Objects.requireNonNull(n0VarArr, "sources is null");
if (n0VarArr.length == 0) {
return empty();
}
if (n0VarArr.length == 1) {
return wrap(n0VarArr[0]);
}
return h.a.a.l.a.a(new h.a.a.h.f.e.u(fromArray(n0VarArr), h.a.a.h.b.a.e(), bufferSize(), h.a.a.h.k.j.BOUNDARY));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> concatArrayDelayError(@h.a.a.b.f n0<? extends T>... n0VarArr) {
Objects.requireNonNull(n0VarArr, "sources is null");
if (n0VarArr.length == 0) {
return empty();
}
if (n0VarArr.length == 1) {
return wrap(n0VarArr[0]);
}
return concatDelayError(fromArray(n0VarArr));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> concatArrayEager(@h.a.a.b.f n0<? extends T>... n0VarArr) {
return concatArrayEager(bufferSize(), bufferSize(), n0VarArr);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> concatArrayEagerDelayError(@h.a.a.b.f n0<? extends T>... n0VarArr) {
return concatArrayEagerDelayError(bufferSize(), bufferSize(), n0VarArr);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return concatDelayError(fromIterable(iterable));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEager(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable) {
return concatEager(iterable, bufferSize(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEagerDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable) {
return concatEagerDelayError(iterable, bufferSize(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> create(@h.a.a.b.f l0<T> l0Var) {
Objects.requireNonNull(l0Var, "source is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.c0(l0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> defer(@h.a.a.b.f h.a.a.g.s<? extends n0<? extends T>> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.f0(sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
private i0<T> doOnEach(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar, @h.a.a.b.f h.a.a.g.a aVar2) {
Objects.requireNonNull(gVar, "onNext is null");
Objects.requireNonNull(gVar2, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
Objects.requireNonNull(aVar2, "onAfterTerminate is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.o0(this, gVar, gVar2, aVar, aVar2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> empty() {
return h.a.a.l.a.a(h.a.a.h.f.e.t0.f14280a);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> error(@h.a.a.b.f h.a.a.g.s<? extends Throwable> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.u0(sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromAction(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "action is null");
return h.a.a.l.a.a((i0) new c1(aVar));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> fromArray(@h.a.a.b.f T... tArr) {
Objects.requireNonNull(tArr, "items is null");
if (tArr.length == 0) {
return empty();
}
if (tArr.length == 1) {
return just(tArr[0]);
}
return h.a.a.l.a.a(new d1(tArr));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromCallable(@h.a.a.b.f Callable<? extends T> callable) {
Objects.requireNonNull(callable, "callable is null");
return h.a.a.l.a.a((i0) new e1(callable));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromCompletable(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "completableSource is null");
return h.a.a.l.a.a(new f1(pVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromCompletionStage(@h.a.a.b.f CompletionStage<T> completionStage) {
Objects.requireNonNull(completionStage, "stage is null");
return h.a.a.l.a.a(new h.a.a.h.d.u(completionStage));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromFuture(@h.a.a.b.f Future<? extends T> future) {
Objects.requireNonNull(future, "future is null");
return h.a.a.l.a.a(new g1(future, 0L, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromIterable(@h.a.a.b.f Iterable<? extends T> iterable) {
Objects.requireNonNull(iterable, "source is null");
return h.a.a.l.a.a(new h1(iterable));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromMaybe(@h.a.a.b.f f0<T> f0Var) {
Objects.requireNonNull(f0Var, "maybe is null");
return h.a.a.l.a.a(new q1(f0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromOptional(@h.a.a.b.f Optional<T> optional) {
Objects.requireNonNull(optional, "optional is null");
return (i0) optional.map(new Function() {
@Override
public final Object apply(Object obj) {
return i0.just(obj);
}
}).orElseGet(new Supplier() {
@Override
public final Object get() {
return i0.empty();
}
});
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.UNBOUNDED_IN)
public static <T> i0<T> fromPublisher(@h.a.a.b.f q.i.c<? extends T> cVar) {
Objects.requireNonNull(cVar, "publisher is null");
return h.a.a.l.a.a(new i1(cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromRunnable(@h.a.a.b.f Runnable runnable) {
Objects.requireNonNull(runnable, "run is null");
return h.a.a.l.a.a((i0) new j1(runnable));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromSingle(@h.a.a.b.f x0<T> x0Var) {
Objects.requireNonNull(x0Var, "source is null");
return h.a.a.l.a.a(new b1(x0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromStream(@h.a.a.b.f Stream<T> stream) {
Objects.requireNonNull(stream, "stream is null");
return h.a.a.l.a.a(new h.a.a.h.d.v(stream));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromSupplier(@h.a.a.b.f h.a.a.g.s<? extends T> sVar) {
Objects.requireNonNull(sVar, "supplier is null");
return h.a.a.l.a.a((i0) new k1(sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> generate(@h.a.a.b.f h.a.a.g.g<r<T>> gVar) {
Objects.requireNonNull(gVar, "generator is null");
return generate(h.a.a.h.b.a.g(), s1.a(gVar), h.a.a.h.b.a.d());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public static i0<Long> interval(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return interval(j2, j3, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public static i0<Long> intervalRange(long j2, long j3, long j4, long j5, @h.a.a.b.f TimeUnit timeUnit) {
return intervalRange(j2, j3, j4, j5, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "item is null");
return h.a.a.l.a.a((i0) new w1(t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, int i2, int i3) {
return fromIterable(iterable).flatMap(h.a.a.h.b.a.e(), false, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> mergeArray(int i2, int i3, @h.a.a.b.f n0<? extends T>... n0VarArr) {
return fromArray(n0VarArr).flatMap(h.a.a.h.b.a.e(), false, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> mergeArrayDelayError(int i2, int i3, @h.a.a.b.f n0<? extends T>... n0VarArr) {
return fromArray(n0VarArr).flatMap(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable) {
return fromIterable(iterable).flatMap(h.a.a.h.b.a.e(), true);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> never() {
return h.a.a.l.a.a(g2.f14064a);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static i0<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 h.a.a.l.a.a(new n2(i2, i3));
}
throw new IllegalArgumentException("Integer overflow");
}
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static i0<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 h.a.a.l.a.a(new o2(j2, j3));
}
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> r0<Boolean> sequenceEqual(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2) {
return sequenceEqual(n0Var, n0Var2, h.a.a.h.b.b.a(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> switchOnNext(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2) {
Objects.requireNonNull(n0Var, "sources is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new r3(n0Var, h.a.a.h.b.a.e(), i2, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> switchOnNextDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
return switchOnNextDelayError(n0Var, bufferSize());
}
@h.a.a.b.f
private i0<T> timeout0(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.g n0<? extends T> n0Var, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new d4(this, j2, timeUnit, q0Var, n0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public static i0<Long> timer(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return timer(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> unsafeCreate(@h.a.a.b.f n0<T> n0Var) {
Objects.requireNonNull(n0Var, "onSubscribe is null");
if (!(n0Var instanceof i0)) {
return h.a.a.l.a.a(new l1(n0Var));
}
throw new IllegalArgumentException("unsafeCreate(Observable) should be upgraded");
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, D> i0<T> using(@h.a.a.b.f h.a.a.g.s<? extends D> sVar, @h.a.a.b.f h.a.a.g.o<? super D, ? extends n0<? extends T>> oVar, @h.a.a.b.f h.a.a.g.g<? super D> gVar) {
return using(sVar, oVar, gVar, true);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> wrap(@h.a.a.b.f n0<T> n0Var) {
Objects.requireNonNull(n0Var, "source is null");
if (n0Var instanceof i0) {
return h.a.a.l.a.a((i0) n0Var);
}
return h.a.a.l.a.a(new l1(n0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> zip(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar) {
Objects.requireNonNull(oVar, "zipper is null");
Objects.requireNonNull(iterable, "sources is null");
return h.a.a.l.a.a(new q4(null, iterable, oVar, bufferSize(), false));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T, R> i0<R> zipArray(@h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, boolean z, int i2, @h.a.a.b.f n0<? extends T>... n0VarArr) {
Objects.requireNonNull(n0VarArr, "sources is null");
if (n0VarArr.length == 0) {
return empty();
}
Objects.requireNonNull(oVar, "zipper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new q4(n0VarArr, null, oVar, i2, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Boolean> all(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.g(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> ambWith(@h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return ambArray(this, n0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Boolean> any(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.j(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final T blockingFirst() {
h.a.a.h.e.g gVar = new h.a.a.h.e.g();
subscribe(gVar);
T a2 = gVar.a();
if (a2 != null) {
return a2;
}
throw new NoSuchElementException();
}
@h.a.a.b.h("none")
@h.a.a.b.f
public final void blockingForEach(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
blockingForEach(gVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Iterable<T> blockingIterable() {
return blockingIterable(bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final T blockingLast() {
h.a.a.h.e.h hVar = new h.a.a.h.e.h();
subscribe(hVar);
T a2 = hVar.a();
if (a2 != null) {
return a2;
}
throw new NoSuchElementException();
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Iterable<T> blockingLatest() {
return new h.a.a.h.f.e.c(this);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Iterable<T> blockingMostRecent(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "initialItem is null");
return new h.a.a.h.f.e.d(this, t);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Iterable<T> blockingNext() {
return new h.a.a.h.f.e.e(this);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final T blockingSingle() {
T b = singleElement().b();
if (b != null) {
return b;
}
throw new NoSuchElementException();
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Stream<T> blockingStream() {
return blockingStream(bufferSize());
}
@h.a.a.b.h("none")
public final void blockingSubscribe() {
h.a.a.h.f.e.l.a(this);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<List<T>> buffer(int i2) {
return buffer(i2, i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> cache() {
return cacheWithInitialCapacity(16);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> cacheWithInitialCapacity(int i2) {
h.a.a.h.b.b.a(i2, "initialCapacity");
return h.a.a.l.a.a(new h.a.a.h.f.e.q(this, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<U> cast(@h.a.a.b.f Class<U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return (i0<U>) map(h.a.a.h.b.a.a((Class) cls));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> r0<U> collect(@h.a.a.b.f h.a.a.g.s<? extends U> sVar, @h.a.a.b.f h.a.a.g.b<? super U, ? super T> bVar) {
Objects.requireNonNull(sVar, "initialItemSupplier is null");
Objects.requireNonNull(bVar, "collector is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.s(this, sVar, bVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> r0<U> collectInto(@h.a.a.b.f U u, @h.a.a.b.f h.a.a.g.b<? super U, ? super T> bVar) {
Objects.requireNonNull(u, "initialItem is null");
return collect(h.a.a.h.b.a.d(u), bVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> compose(@h.a.a.b.f o0<? super T, ? extends R> o0Var) {
return wrap(((o0) Objects.requireNonNull(o0Var, "composer is null")).a(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar) {
return concatMap(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j concatMapCompletable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
return concatMapCompletable(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j concatMapCompletableDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
return concatMapCompletableDelayError(oVar, true, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar) {
return concatMapDelayError(oVar, true, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapEager(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar) {
return concatMapEager(oVar, Integer.MAX_VALUE, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapEagerDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, boolean z) {
return concatMapEagerDelayError(oVar, z, Integer.MAX_VALUE, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<U> concatMapIterable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.b1(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapMaybe(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
return concatMapMaybe(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapMaybeDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
return concatMapMaybeDelayError(oVar, true, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapSingle(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
return concatMapSingle(oVar, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapSingleDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
return concatMapSingleDelayError(oVar, true, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapStream(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar) {
return flatMapStream(oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> concatWith(@h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return concat(this, n0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Boolean> contains(@h.a.a.b.f Object obj) {
Objects.requireNonNull(obj, "item is null");
return any(h.a.a.h.b.a.a(obj));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Long> count() {
return h.a.a.l.a.a(new h.a.a.h.f.e.b0(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<T> debounce(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<U>> oVar) {
Objects.requireNonNull(oVar, "debounceIndicator is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.d0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> defaultIfEmpty(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
return switchIfEmpty(just(t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<T> delay(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<U>> oVar) {
Objects.requireNonNull(oVar, "itemDelayIndicator is null");
return (i0<T>) flatMap(s1.b(oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<T> delaySubscription(@h.a.a.b.f n0<U> n0Var) {
Objects.requireNonNull(n0Var, "subscriptionIndicator is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.h0(this, n0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> dematerialize(@h.a.a.b.f h.a.a.g.o<? super T, h0<R>> oVar) {
Objects.requireNonNull(oVar, "selector is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.i0(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> distinct() {
return distinct(h.a.a.h.b.a.e(), h.a.a.h.b.a.c());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> distinctUntilChanged() {
return distinctUntilChanged(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doAfterNext(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
Objects.requireNonNull(gVar, "onAfterNext is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.m0(this, gVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doAfterTerminate(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "onAfterTerminate is null");
return doOnEach(h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), h.a.a.h.b.a.c, aVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doFinally(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "onFinally is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.n0(this, aVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnComplete(@h.a.a.b.f h.a.a.g.a aVar) {
return doOnEach(h.a.a.h.b.a.d(), h.a.a.h.b.a.d(), aVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnDispose(@h.a.a.b.f h.a.a.g.a aVar) {
return doOnLifecycle(h.a.a.h.b.a.d(), aVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnError(@h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
h.a.a.g.g<? super T> d2 = h.a.a.h.b.a.d();
h.a.a.g.a aVar = h.a.a.h.b.a.c;
return doOnEach(d2, gVar, aVar, aVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnLifecycle(@h.a.a.b.f h.a.a.g.g<? super h.a.a.d.f> gVar, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(gVar, "onSubscribe is null");
Objects.requireNonNull(aVar, "onDispose is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.p0(this, gVar, aVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnNext(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
h.a.a.g.g<? super Throwable> d2 = h.a.a.h.b.a.d();
h.a.a.g.a aVar = h.a.a.h.b.a.c;
return doOnEach(gVar, d2, aVar, aVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnSubscribe(@h.a.a.b.f h.a.a.g.g<? super h.a.a.d.f> gVar) {
return doOnLifecycle(gVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnTerminate(@h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(aVar, "onTerminate is null");
return doOnEach(h.a.a.h.b.a.d(), h.a.a.h.b.a.a(aVar), aVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> elementAt(long j2) {
if (j2 >= 0) {
return h.a.a.l.a.a(new h.a.a.h.f.e.r0(this, j2));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> elementAtOrError(long j2) {
if (j2 >= 0) {
return h.a.a.l.a.a(new h.a.a.h.f.e.s0(this, j2, null));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> filter(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.v0(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> first(@h.a.a.b.f T t) {
return elementAt(0L, t);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> firstElement() {
return elementAt(0L);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> firstOrError() {
return elementAtOrError(0L);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> firstOrErrorStage() {
return (CompletionStage) subscribeWith(new h.a.a.h.d.s(false, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> firstStage(@h.a.a.b.g T t) {
return (CompletionStage) subscribeWith(new h.a.a.h.d.s(true, t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar) {
return flatMap((h.a.a.g.o) oVar, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j flatMapCompletable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
return flatMapCompletable(oVar, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<U> flatMapIterable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.b1(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMapMaybe(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
return flatMapMaybe(oVar, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMapSingle(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
return flatMapSingle(oVar, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMapStream(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Stream<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.d.t(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f forEach(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
return subscribe(gVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f forEachWhile(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
return forEachWhile(rVar, h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K> i0<h.a.a.i.b<K, T>> groupBy(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar) {
return (i0<h.a.a.i.b<K, T>>) groupBy(oVar, h.a.a.h.b.a.e(), false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <TRight, TLeftEnd, TRightEnd, R> i0<R> groupJoin(@h.a.a.b.f n0<? extends TRight> n0Var, @h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<TLeftEnd>> oVar, @h.a.a.b.f h.a.a.g.o<? super TRight, ? extends n0<TRightEnd>> oVar2, @h.a.a.b.f h.a.a.g.c<? super T, ? super i0<TRight>, ? extends R> cVar) {
Objects.requireNonNull(n0Var, "other is null");
Objects.requireNonNull(oVar, "leftEnd is null");
Objects.requireNonNull(oVar2, "rightEnd is null");
Objects.requireNonNull(cVar, "resultSelector is null");
return h.a.a.l.a.a(new o1(this, n0Var, oVar, oVar2, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> hide() {
return h.a.a.l.a.a(new p1(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j ignoreElements() {
return h.a.a.l.a.a(new r1(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<Boolean> isEmpty() {
return all(h.a.a.h.b.a.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <TRight, TLeftEnd, TRightEnd, R> i0<R> join(@h.a.a.b.f n0<? extends TRight> n0Var, @h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<TLeftEnd>> oVar, @h.a.a.b.f h.a.a.g.o<? super TRight, ? extends n0<TRightEnd>> oVar2, @h.a.a.b.f h.a.a.g.c<? super T, ? super TRight, ? extends R> cVar) {
Objects.requireNonNull(n0Var, "other is null");
Objects.requireNonNull(oVar, "leftEnd is null");
Objects.requireNonNull(oVar2, "rightEnd is null");
Objects.requireNonNull(cVar, "resultSelector is null");
return h.a.a.l.a.a(new v1(this, n0Var, oVar, oVar2, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> last(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
return h.a.a.l.a.a(new y1(this, t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> lastElement() {
return h.a.a.l.a.a(new x1(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> lastOrError() {
return h.a.a.l.a.a(new y1(this, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> lastOrErrorStage() {
return (CompletionStage) subscribeWith(new h.a.a.h.d.w(false, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> lastStage(@h.a.a.b.g T t) {
return (CompletionStage) subscribeWith(new h.a.a.h.d.w(true, t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> lift(@h.a.a.b.f m0<? extends R, ? super T> m0Var) {
Objects.requireNonNull(m0Var, "lifter is null");
return h.a.a.l.a.a(new z1(this, m0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> map(@h.a.a.b.f h.a.a.g.o<? super T, ? extends R> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new a2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> mapOptional(@h.a.a.b.f h.a.a.g.o<? super T, Optional<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.d.x(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h0<T>> materialize() {
return h.a.a.l.a.a(new c2(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> mergeWith(@h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return merge(this, n0Var);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> observeOn(@h.a.a.b.f q0 q0Var) {
return observeOn(q0Var, false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<U> ofType(@h.a.a.b.f Class<U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return filter(h.a.a.h.b.a.b((Class) cls)).cast(cls);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> onErrorComplete() {
return onErrorComplete(h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> onErrorResumeNext(@h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends n0<? extends T>> oVar) {
Objects.requireNonNull(oVar, "fallbackSupplier is null");
return h.a.a.l.a.a(new j2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> onErrorResumeWith(@h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "fallback is null");
return onErrorResumeNext(h.a.a.h.b.a.c(n0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> onErrorReturn(@h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends T> oVar) {
Objects.requireNonNull(oVar, "itemSupplier is null");
return h.a.a.l.a.a(new k2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> onErrorReturnItem(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "item is null");
return onErrorReturn(h.a.a.h.b.a.c(t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> onTerminateDetach() {
return h.a.a.l.a.a(new h.a.a.h.f.e.j0(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.i.a<T> publish() {
return h.a.a.l.a.a((h.a.a.i.a) new l2(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> reduce(@h.a.a.b.f h.a.a.g.c<T, T, T> cVar) {
Objects.requireNonNull(cVar, "reducer is null");
return h.a.a.l.a.a(new p2(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> r0<R> reduceWith(@h.a.a.b.f h.a.a.g.s<R> sVar, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(sVar, "seedSupplier is null");
Objects.requireNonNull(cVar, "reducer is null");
return h.a.a.l.a.a(new r2(this, sVar, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> repeat() {
return repeat(k.c3.w.p0.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> repeatUntil(@h.a.a.b.f h.a.a.g.e eVar) {
Objects.requireNonNull(eVar, "stop is null");
return h.a.a.l.a.a(new u2(this, eVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> repeatWhen(@h.a.a.b.f h.a.a.g.o<? super i0<Object>, ? extends n0<?>> oVar) {
Objects.requireNonNull(oVar, "handler is null");
return h.a.a.l.a.a(new v2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.i.a<T> replay() {
return w2.a(this);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> retry() {
return retry(k.c3.w.p0.c, h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> retryUntil(@h.a.a.b.f h.a.a.g.e eVar) {
Objects.requireNonNull(eVar, "stop is null");
return retry(k.c3.w.p0.c, h.a.a.h.b.a.a(eVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> retryWhen(@h.a.a.b.f h.a.a.g.o<? super i0<Throwable>, ? extends n0<?>> oVar) {
Objects.requireNonNull(oVar, "handler is null");
return h.a.a.l.a.a(new z2(this, oVar));
}
@h.a.a.b.h("none")
@h.a.a.b.f
public final void safeSubscribe(@h.a.a.b.f p0<? super T> p0Var) {
Objects.requireNonNull(p0Var, "observer is null");
if (p0Var instanceof h.a.a.j.l) {
subscribe(p0Var);
} else {
subscribe(new h.a.a.j.l(p0Var));
}
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> sample(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return sample(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> scan(@h.a.a.b.f h.a.a.g.c<T, T, T> cVar) {
Objects.requireNonNull(cVar, "accumulator is null");
return h.a.a.l.a.a(new d3(this, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> scanWith(@h.a.a.b.f h.a.a.g.s<R> sVar, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(sVar, "seedSupplier is null");
Objects.requireNonNull(cVar, "accumulator is null");
return h.a.a.l.a.a(new e3(this, sVar, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> serialize() {
return h.a.a.l.a.a(new h3(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> share() {
return publish().c();
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> single(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
return h.a.a.l.a.a(new j3(this, t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final z<T> singleElement() {
return h.a.a.l.a.a(new i3(this));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> singleOrError() {
return h.a.a.l.a.a(new j3(this, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> singleOrErrorStage() {
return (CompletionStage) subscribeWith(new h.a.a.h.d.y(false, null));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final CompletionStage<T> singleStage(@h.a.a.b.g T t) {
return (CompletionStage) subscribeWith(new h.a.a.h.d.y(true, t));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> skip(long j2) {
int i2 = (j2 > 0L ? 1 : (j2 == 0L ? 0 : -1));
if (i2 >= 0) {
if (i2 == 0) {
return h.a.a.l.a.a(this);
}
return h.a.a.l.a.a(new k3(this, j2));
}
throw new IllegalArgumentException("count >= 0 expected but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> skipLast(int i2) {
if (i2 >= 0) {
if (i2 == 0) {
return h.a.a.l.a.a(this);
}
return h.a.a.l.a.a(new l3(this, i2));
}
throw new IllegalArgumentException("count >= 0 required but it was " + i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<T> skipUntil(@h.a.a.b.f n0<U> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return h.a.a.l.a.a(new n3(this, n0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> skipWhile(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new o3(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> sorted() {
return toList().v().map(h.a.a.h.b.a.a(h.a.a.h.b.a.f())).flatMapIterable(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> startWith(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "other is null");
return concat(j.i(pVar).r(), this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public final i0<T> startWithArray(@h.a.a.b.f T... tArr) {
i0 fromArray = fromArray(tArr);
if (fromArray == empty()) {
return h.a.a.l.a.a(this);
}
return concatArray(fromArray, this);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> startWithItem(@h.a.a.b.f T t) {
return concatArray(just(t), this);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> startWithIterable(@h.a.a.b.f Iterable<? extends T> iterable) {
return concatArray(fromIterable(iterable), this);
}
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f subscribe() {
return subscribe(h.a.a.h.b.a.d(), h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
protected abstract void subscribeActual(@h.a.a.b.f p0<? super T> p0Var);
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> subscribeOn(@h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new p3(this, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <E extends p0<? super T>> E subscribeWith(E e2) {
subscribe(e2);
return e2;
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> switchIfEmpty(@h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return h.a.a.l.a.a(new q3(this, n0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar) {
return switchMap(oVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j switchMapCompletable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.t(this, oVar, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j switchMapCompletableDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.t(this, oVar, true));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMapDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar) {
return switchMapDelayError(oVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMapMaybe(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.u(this, oVar, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMapMaybeDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.u(this, oVar, true));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMapSingle(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.v(this, oVar, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMapSingleDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.d.v(this, oVar, true));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> take(long j2) {
if (j2 >= 0) {
return h.a.a.l.a.a(new s3(this, j2));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> takeLast(int i2) {
if (i2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + i2);
} else if (i2 == 0) {
return h.a.a.l.a.a(new h.a.a.h.f.e.q1(this));
} else {
if (i2 == 1) {
return h.a.a.l.a.a(new u3(this));
}
return h.a.a.l.a.a(new t3(this, i2));
}
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<T> takeUntil(@h.a.a.b.f n0<U> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return h.a.a.l.a.a(new w3(this, n0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> takeWhile(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new y3(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.j.n<T> test() {
h.a.a.j.n<T> nVar = new h.a.a.j.n<>();
subscribe(nVar);
return nVar;
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> throttleFirst(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return throttleFirst(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> throttleLast(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return sample(j2, timeUnit);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> throttleLatest(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return throttleLatest(j2, timeUnit, h.a.a.n.b.a(), false);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> throttleWithTimeout(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return debounce(j2, timeUnit);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timeInterval() {
return timeInterval(TimeUnit.MILLISECONDS, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <V> i0<T> timeout(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<V>> oVar) {
return timeout0(null, oVar, null);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timestamp() {
return timestamp(TimeUnit.MILLISECONDS, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> R to(@h.a.a.b.f j0<T, ? extends R> j0Var) {
return (R) ((j0) Objects.requireNonNull(j0Var, "converter is null")).a(this);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@h.a.a.b.b(h.a.a.b.a.SPECIAL)
public final s<T> toFlowable(@h.a.a.b.f i iVar) {
Objects.requireNonNull(iVar, "strategy is null");
n1 n1Var = new n1(this);
int i2 = a.f13235a[iVar.ordinal()];
if (i2 != 1) {
if (i2 != 2) {
if (i2 != 3) {
if (i2 != 4) {
return n1Var.w();
}
return h.a.a.l.a.a(new h.a.a.h.f.b.r2(n1Var));
}
return n1Var;
}
return n1Var.y();
}
return n1Var.x();
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Future<T> toFuture() {
return (Future) subscribeWith(new h.a.a.h.e.s());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<List<T>> toList() {
return toList(16);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K> r0<Map<K, T>> toMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar) {
Objects.requireNonNull(oVar, "keySelector is null");
return (r0<Map<K, T>>) collect(h.a.a.h.k.m.a(), h.a.a.h.b.a.a((h.a.a.g.o) oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K> r0<Map<K, Collection<T>>> toMultimap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar) {
return (r0<Map<K, Collection<T>>>) toMultimap(oVar, h.a.a.h.b.a.e(), h.a.a.h.k.m.a(), h.a.a.h.k.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<List<T>> toSortedList() {
return toSortedList(h.a.a.h.b.a.f());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> unsubscribeOn(@h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h4(this, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<i0<T>> window(long j2) {
return window(j2, j2, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> withLatestFrom(@h.a.a.b.f n0<? extends U> n0Var, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
Objects.requireNonNull(n0Var, "other is null");
Objects.requireNonNull(cVar, "combiner is null");
return h.a.a.l.a.a(new o4(this, cVar, n0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> zipWith(@h.a.a.b.f Iterable<U> iterable, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
Objects.requireNonNull(iterable, "other is null");
Objects.requireNonNull(cVar, "zipper is null");
return h.a.a.l.a.a(new r4(this, iterable, cVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatest(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(iterable, "sources is null");
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.e.t(null, iterable, oVar, i2 << 1, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatestArray(@h.a.a.b.f n0<? extends T>[] n0VarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(n0VarArr, "sources is null");
if (n0VarArr.length == 0) {
return empty();
}
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.e.t(n0VarArr, null, oVar, i2 << 1, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatestArrayDelayError(@h.a.a.b.f n0<? extends T>[] n0VarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(n0VarArr, "sources is null");
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (n0VarArr.length == 0) {
return empty();
}
return h.a.a.l.a.a(new h.a.a.h.f.e.t(n0VarArr, null, oVar, i2 << 1, true));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> combineLatestDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, int i2) {
Objects.requireNonNull(iterable, "sources is null");
Objects.requireNonNull(oVar, "combiner is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.e.t(null, iterable, oVar, i2 << 1, true));
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> concatArrayEager(int i2, int i3, @h.a.a.b.f n0<? extends T>... n0VarArr) {
return fromArray(n0VarArr).concatMapEagerDelayError(h.a.a.h.b.a.e(), false, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> concatArrayEagerDelayError(int i2, int i3, @h.a.a.b.f n0<? extends T>... n0VarArr) {
return fromArray(n0VarArr).concatMapEagerDelayError(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEager(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, int i2, int i3) {
return fromIterable(iterable).concatMapEagerDelayError(h.a.a.h.b.a.e(), false, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEagerDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, int i2, int i3) {
return fromIterable(iterable).concatMapEagerDelayError(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public static i0<Long> interval(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new t1(Math.max(0L, j2), Math.max(0L, j3), timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public static i0<Long> intervalRange(long j2, long j3, long j4, long j5, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
int i2 = (j3 > 0L ? 1 : (j3 == 0L ? 0 : -1));
if (i2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was " + j3);
} else if (i2 == 0) {
return empty().delay(j4, timeUnit, q0Var);
} else {
long j6 = j2 + (j3 - 1);
if (j2 > 0 && j6 < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new u1(j2, j6, Math.max(0L, j4), Math.max(0L, j5), timeUnit, q0Var));
}
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable) {
return fromIterable(iterable).flatMap(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> mergeArray(@h.a.a.b.f n0<? extends T>... n0VarArr) {
return fromArray(n0VarArr).flatMap(h.a.a.h.b.a.e(), n0VarArr.length);
}
@h.a.a.b.d
@h.a.a.b.f
@h.a.a.b.h("none")
@SafeVarargs
public static <T> i0<T> mergeArrayDelayError(@h.a.a.b.f n0<? extends T>... n0VarArr) {
return fromArray(n0VarArr).flatMap(h.a.a.h.b.a.e(), true, n0VarArr.length);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, int i2, int i3) {
return fromIterable(iterable).flatMap(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> r0<Boolean> sequenceEqual(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f h.a.a.g.d<? super T, ? super T> dVar) {
return sequenceEqual(n0Var, n0Var2, dVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> switchOnNextDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2) {
Objects.requireNonNull(n0Var, "sources is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new r3(n0Var, h.a.a.h.b.a.e(), i2, true));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public static i0<Long> timer(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new e4(Math.max(j2, 0L), timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, D> i0<T> using(@h.a.a.b.f h.a.a.g.s<? extends D> sVar, @h.a.a.b.f h.a.a.g.o<? super D, ? extends n0<? extends T>> oVar, @h.a.a.b.f h.a.a.g.g<? super D> gVar, boolean z) {
Objects.requireNonNull(sVar, "resourceSupplier is null");
Objects.requireNonNull(oVar, "sourceSupplier is null");
Objects.requireNonNull(gVar, "resourceCleanup is null");
return h.a.a.l.a.a(new i4(sVar, oVar, gVar, z));
}
@h.a.a.b.h("none")
@h.a.a.b.f
public final void blockingForEach(@h.a.a.b.f h.a.a.g.g<? super T> gVar, int i2) {
Objects.requireNonNull(gVar, "onNext is null");
Iterator<T> it = blockingIterable(i2).iterator();
while (it.hasNext()) {
try {
gVar.accept(it.next());
} catch (Throwable th) {
h.a.a.e.b.b(th);
((h.a.a.d.f) it).dispose();
throw h.a.a.h.k.k.c(th);
}
}
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Iterable<T> blockingIterable(int i2) {
h.a.a.h.b.b.a(i2, "capacityHint");
return new h.a.a.h.f.e.b(this, i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final Stream<T> blockingStream(int i2) {
Iterator<T> it = blockingIterable(i2).iterator();
Stream stream = StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, 0), false);
h.a.a.d.f fVar = (h.a.a.d.f) it;
fVar.getClass();
return (Stream) stream.onClose(new f(fVar));
}
@h.a.a.b.h("none")
public final void blockingSubscribe(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
h.a.a.h.f.e.l.a(this, gVar, h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<List<T>> buffer(int i2, int i3) {
return (i0<List<T>>) buffer(i2, i3, h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return empty();
}
return c3.a(obj, oVar);
}
return h.a.a.l.a.a(new h.a.a.h.f.e.u(this, oVar, i2, h.a.a.h.k.j.IMMEDIATE));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j concatMapCompletable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "capacityHint");
return h.a.a.l.a.a(new h.a.a.h.f.d.q(this, oVar, h.a.a.h.k.j.IMMEDIATE, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j concatMapCompletableDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, boolean z) {
return concatMapCompletableDelayError(oVar, z, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return empty();
}
return c3.a(obj, oVar);
}
return h.a.a.l.a.a(new h.a.a.h.f.e.u(this, oVar, i2, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapEager(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.e.v(this, oVar, h.a.a.h.k.j.IMMEDIATE, i2, i3));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapEagerDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, boolean z, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.e.v(this, oVar, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, i2, i3));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapMaybe(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.d.r(this, oVar, h.a.a.h.k.j.IMMEDIATE, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapMaybeDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, boolean z) {
return concatMapMaybeDelayError(oVar, z, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapSingle(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.d.s(this, oVar, h.a.a.h.k.j.IMMEDIATE, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapSingleDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, boolean z) {
return concatMapSingleDelayError(oVar, z, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K> i0<T> distinct(@h.a.a.b.f h.a.a.g.o<? super T, K> oVar) {
return distinct(oVar, h.a.a.h.b.a.c());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K> i0<T> distinctUntilChanged(@h.a.a.b.f h.a.a.g.o<? super T, K> oVar) {
Objects.requireNonNull(oVar, "keySelector is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.l0(this, oVar, h.a.a.h.b.b.a()));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, boolean z) {
return flatMap(oVar, z, Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j flatMapCompletable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, boolean z) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.y0(this, oVar, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMapMaybe(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, boolean z) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new z0(this, oVar, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMapSingle(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, boolean z) {
Objects.requireNonNull(oVar, "mapper is null");
return h.a.a.l.a.a(new a1(this, oVar, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f forEachWhile(@h.a.a.b.f h.a.a.g.r<? super T> rVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar) {
return forEachWhile(rVar, gVar, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K> i0<h.a.a.i.b<K, T>> groupBy(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, boolean z) {
return (i0<h.a.a.i.b<K, T>>) groupBy(oVar, h.a.a.h.b.a.e(), z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> observeOn(@h.a.a.b.f q0 q0Var, boolean z) {
return observeOn(q0Var, z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> onErrorComplete(@h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new i2(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> publish(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar) {
Objects.requireNonNull(oVar, "selector is null");
return h.a.a.l.a.a(new m2(this, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> repeat(long j2) {
int i2 = (j2 > 0L ? 1 : (j2 == 0L ? 0 : -1));
if (i2 >= 0) {
if (i2 == 0) {
return empty();
}
return h.a.a.l.a.a(new t2(this, j2));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar) {
Objects.requireNonNull(oVar, "selector is null");
return w2.a(s1.a(this), oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> retry(@h.a.a.b.f h.a.a.g.d<? super Integer, ? super Throwable> dVar) {
Objects.requireNonNull(dVar, "predicate is null");
return h.a.a.l.a.a(new x2(this, dVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> sample(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return sample(j2, timeUnit, h.a.a.n.b.a(), z);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> sorted(@h.a.a.b.f Comparator<? super T> comparator) {
Objects.requireNonNull(comparator, "comparator is null");
return toList().v().map(h.a.a.h.b.a.a((Comparator) comparator)).flatMapIterable(h.a.a.h.b.a.e());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f subscribe(@h.a.a.b.f h.a.a.g.g<? super T> gVar) {
return subscribe(gVar, h.a.a.h.b.a.f13257f, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return empty();
}
return c3.a(obj, oVar);
}
return h.a.a.l.a.a(new r3(this, oVar, i2, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> switchMapDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return empty();
}
return c3.a(obj, oVar);
}
return h.a.a.l.a.a(new r3(this, oVar, i2, true));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> throttleFirst(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new z3(this, j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> throttleLast(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return sample(j2, timeUnit, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> throttleLatest(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return throttleLatest(j2, timeUnit, h.a.a.n.b.a(), z);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> throttleWithTimeout(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return debounce(j2, timeUnit, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timeInterval(@h.a.a.b.f q0 q0Var) {
return timeInterval(TimeUnit.MILLISECONDS, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <V> i0<T> timeout(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<V>> oVar, @h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "fallback is null");
return timeout0(null, oVar, n0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timestamp(@h.a.a.b.f q0 q0Var) {
return timestamp(TimeUnit.MILLISECONDS, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<List<T>> toList(int i2) {
h.a.a.h.b.b.a(i2, "capacityHint");
return h.a.a.l.a.a(new g4(this, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<List<T>> toSortedList(@h.a.a.b.f Comparator<? super T> comparator) {
Objects.requireNonNull(comparator, "comparator is null");
return (r0<List<T>>) toList().n(h.a.a.h.b.a.a((Comparator) comparator));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<i0<T>> window(long j2, long j3) {
return window(j2, j3, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concat(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
return concat(n0Var, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
return concatDelayError(n0Var, bufferSize(), true);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEager(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
return concatEager(n0Var, bufferSize(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEagerDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
return concatEagerDelayError(n0Var, bufferSize(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> error(@h.a.a.b.f Throwable th) {
Objects.requireNonNull(th, "throwable is null");
return error(h.a.a.h.b.a.d(th));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> fromFuture(@h.a.a.b.f Future<? extends T> future, long j2, @h.a.a.b.f TimeUnit timeUnit) {
Objects.requireNonNull(future, "future is null");
Objects.requireNonNull(timeUnit, "unit is null");
return h.a.a.l.a.a(new g1(future, j2, timeUnit));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
return fromArray(t, t2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, int i2) {
return fromIterable(iterable).flatMap(h.a.a.h.b.a.e(), i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, int i2) {
return fromIterable(iterable).flatMap(h.a.a.h.b.a.e(), true, i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> r0<Boolean> sequenceEqual(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f h.a.a.g.d<? super T, ? super T> dVar, int i2) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(dVar, "isEqual is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new g3(n0Var, n0Var2, dVar, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final T blockingSingle(@h.a.a.b.f T t) {
return single(t).d();
}
@h.a.a.b.h("none")
public final void blockingSubscribe(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2) {
h.a.a.h.f.e.l.a(this, gVar, gVar2, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U extends Collection<? super T>> i0<U> buffer(int i2, int i3, @h.a.a.b.f h.a.a.g.s<U> sVar) {
h.a.a.h.b.b.a(i2, NewHtcHomeBadger.f20939d);
h.a.a.h.b.b.a(i3, "skip");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.m(this, i2, i3, sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final j concatMapCompletableDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends p> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.d.q(this, oVar, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapMaybeDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends f0<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.d.r(this, oVar, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> concatMapSingleDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends x0<? extends R>> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.d.s(this, oVar, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> concatWith(@h.a.a.b.f x0<? extends T> x0Var) {
Objects.requireNonNull(x0Var, "other is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.z(this, x0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> debounce(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return debounce(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> delay(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return delay(j2, timeUnit, h.a.a.n.b.a(), false);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> delaySubscription(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return delaySubscription(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K> i0<T> distinct(@h.a.a.b.f h.a.a.g.o<? super T, K> oVar, @h.a.a.b.f h.a.a.g.s<? extends Collection<? super K>> sVar) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(sVar, "collectionSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.k0(this, oVar, sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<T> elementAt(long j2, @h.a.a.b.f T t) {
if (j2 >= 0) {
Objects.requireNonNull(t, "defaultItem is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.s0(this, j2, t));
}
throw new IndexOutOfBoundsException("index >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, boolean z, int i2) {
return flatMap(oVar, z, i2, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, V> i0<V> flatMapIterable(@h.a.a.b.f h.a.a.g.o<? super T, ? extends Iterable<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends V> cVar) {
Objects.requireNonNull(oVar, "mapper is null");
Objects.requireNonNull(cVar, "combiner is null");
return (i0<V>) flatMap(s1.a(oVar), cVar, false, bufferSize(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f forEachWhile(@h.a.a.b.f h.a.a.g.r<? super T> rVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(rVar, "onNext is null");
Objects.requireNonNull(gVar, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
h.a.a.h.e.q qVar = new h.a.a.h.e.q(rVar, gVar, aVar);
subscribe(qVar);
return qVar;
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> i0<h.a.a.i.b<K, V>> groupBy(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, h.a.a.g.o<? super T, ? extends V> oVar2) {
return groupBy(oVar, oVar2, false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> mergeWith(@h.a.a.b.f x0<? extends T> x0Var) {
Objects.requireNonNull(x0Var, "other is null");
return h.a.a.l.a.a(new f2(this, x0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> observeOn(@h.a.a.b.f q0 q0Var, boolean z, int i2) {
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h2(this, q0Var, z, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> r0<R> reduce(R r2, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(r2, "seed is null");
Objects.requireNonNull(cVar, "reducer is null");
return h.a.a.l.a.a(new q2(this, r2, cVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> sample(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new a3(this, j2, timeUnit, q0Var, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> scan(@h.a.a.b.f R r2, @h.a.a.b.f h.a.a.g.c<R, ? super T, R> cVar) {
Objects.requireNonNull(r2, "initialValue is null");
return scanWith(h.a.a.h.b.a.d(r2), cVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> startWith(@h.a.a.b.f x0<T> x0Var) {
Objects.requireNonNull(x0Var, "other is null");
return concat(r0.j(x0Var).v(), this);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f subscribe(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2) {
return subscribe(gVar, gVar2, h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> take(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return takeUntil(timer(j2, timeUnit));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> takeUntil(@h.a.a.b.f h.a.a.g.r<? super T> rVar) {
Objects.requireNonNull(rVar, "stopPredicate is null");
return h.a.a.l.a.a(new x3(this, rVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.j.n<T> test(boolean z) {
h.a.a.j.n<T> nVar = new h.a.a.j.n<>();
if (z) {
nVar.dispose();
}
subscribe(nVar);
return nVar;
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> throttleLatest(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return throttleLatest(j2, timeUnit, q0Var, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timeInterval(@h.a.a.b.f TimeUnit timeUnit) {
return timeInterval(timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timestamp(@h.a.a.b.f TimeUnit timeUnit) {
return timestamp(timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> r0<Map<K, V>> toMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
return (r0<Map<K, V>>) collect(h.a.a.h.k.m.a(), h.a.a.h.b.a.a(oVar, oVar2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<i0<T>> window(long j2, long j3, int i2) {
h.a.a.h.b.b.a(j2, NewHtcHomeBadger.f20939d);
h.a.a.h.b.b.a(j3, "skip");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new j4(this, j2, j3, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concat(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2) {
Objects.requireNonNull(n0Var, "sources is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.e.u(n0Var, h.a.a.h.b.a.e(), i2, h.a.a.h.k.j.IMMEDIATE));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2, boolean z) {
Objects.requireNonNull(n0Var, "sources is null");
h.a.a.h.b.b.a(i2, "bufferSize is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.u(n0Var, h.a.a.h.b.a.e(), i2, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEager(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2, int i3) {
return wrap(n0Var).concatMapEager(h.a.a.h.b.a.e(), i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concatEagerDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2, int i3) {
return wrap(n0Var).concatMapEagerDelayError(h.a.a.h.b.a.e(), true, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
Objects.requireNonNull(n0Var, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.w0(n0Var, h.a.a.h.b.a.e(), false, Integer.MAX_VALUE, bufferSize()));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
Objects.requireNonNull(n0Var, "sources is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.w0(n0Var, h.a.a.h.b.a.e(), true, Integer.MAX_VALUE, bufferSize()));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> switchOnNext(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var) {
return switchOnNext(n0Var, bufferSize());
}
@h.a.a.b.f
private <U, V> i0<T> timeout0(@h.a.a.b.f n0<U> n0Var, @h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<V>> oVar, @h.a.a.b.g n0<? extends T> n0Var2) {
Objects.requireNonNull(oVar, "itemTimeoutIndicator is null");
return h.a.a.l.a.a(new c4(this, n0Var, oVar, n0Var2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, R> i0<R> zip(@h.a.a.b.f Iterable<? extends n0<? extends T>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], ? extends R> oVar, boolean z, int i2) {
Objects.requireNonNull(oVar, "zipper is null");
Objects.requireNonNull(iterable, "sources is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new q4(null, iterable, oVar, i2, z));
}
@h.a.a.b.h("none")
public final void blockingSubscribe(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar) {
h.a.a.h.f.e.l.a(this, gVar, gVar2, aVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R, A> r0<R> collect(@h.a.a.b.f Collector<T, A, R> collector) {
Objects.requireNonNull(collector, "collector is null");
return h.a.a.l.a.a(new h.a.a.h.d.r(this, collector));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> debounce(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.e0(this, j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> delay(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return delay(j2, timeUnit, h.a.a.n.b.a(), z);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> delaySubscription(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return delaySubscription(timer(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> distinctUntilChanged(@h.a.a.b.f h.a.a.g.d<? super T, ? super T> dVar) {
Objects.requireNonNull(dVar, "comparer is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.l0(this, h.a.a.h.b.a.e(), dVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, boolean z, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
h.a.a.h.b.b.a(i3, "bufferSize");
if (this instanceof h.a.a.h.c.o) {
Object obj = ((h.a.a.h.c.o) this).get();
if (obj == null) {
return empty();
}
return c3.a(obj, oVar);
}
return h.a.a.l.a.a(new h.a.a.h.f.e.w0(this, oVar, z, i2, i3));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> i0<h.a.a.i.b<K, V>> groupBy(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, boolean z) {
return groupBy(oVar, oVar2, z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, int i2) {
Objects.requireNonNull(oVar, "selector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return w2.a(s1.a(this, i2, false), oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> retry(long j2) {
return retry(j2, h.a.a.h.b.a.b());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> skip(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return skipUntil(timer(j2, timeUnit));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13219i)
@h.a.a.b.f
public final i0<T> skipLast(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return skipLast(j2, timeUnit, h.a.a.n.b.g(), false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.d.f subscribe(@h.a.a.b.f h.a.a.g.g<? super T> gVar, @h.a.a.b.f h.a.a.g.g<? super Throwable> gVar2, @h.a.a.b.f h.a.a.g.a aVar) {
Objects.requireNonNull(gVar, "onNext is null");
Objects.requireNonNull(gVar2, "onError is null");
Objects.requireNonNull(aVar, "onComplete is null");
h.a.a.h.e.v vVar = new h.a.a.h.e.v(gVar, gVar2, aVar, h.a.a.h.b.a.d());
subscribe(vVar);
return vVar;
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> take(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return takeUntil(timer(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> throttleLatest(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new a4(this, j2, timeUnit, q0Var, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timeInterval(@h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new b4(this, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> timeout(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return timeout0(j2, timeUnit, null, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<h.a.a.n.d<T>> timestamp(@h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return (i0<h.a.a.n.d<T>>) map(h.a.a.h.b.a.a(timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U extends Collection<? super T>> r0<U> toList(@h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(sVar, "collectionSupplier is null");
return h.a.a.l.a.a(new g4(this, sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<List<T>> toSortedList(@h.a.a.b.f Comparator<? super T> comparator, int i2) {
Objects.requireNonNull(comparator, "comparator is null");
return (r0<List<T>>) toList(i2).n(h.a.a.h.b.a.a((Comparator) comparator));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <T1, T2, R> i0<R> withLatestFrom(@h.a.a.b.f n0<T1> n0Var, @h.a.a.b.f n0<T2> n0Var2, @h.a.a.b.f h.a.a.g.h<? super T, ? super T1, ? super T2, R> hVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(hVar, "combiner is null");
return withLatestFrom(new n0[]{n0Var, n0Var2}, h.a.a.h.b.a.a((h.a.a.g.h) hVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> zipWith(@h.a.a.b.f n0<? extends U> n0Var, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
Objects.requireNonNull(n0Var, "other is null");
return zip(this, n0Var, cVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, S> i0<T> generate(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.b<S, r<T>> bVar) {
Objects.requireNonNull(bVar, "generator is null");
return generate(sVar, s1.a(bVar), h.a.a.h.b.a.d());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public static i0<Long> interval(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return interval(j2, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final T blockingFirst(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
h.a.a.h.e.g gVar = new h.a.a.h.e.g();
subscribe(gVar);
T a2 = gVar.a();
return a2 != null ? a2 : t;
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final T blockingLast(@h.a.a.b.f T t) {
Objects.requireNonNull(t, "defaultItem is null");
h.a.a.h.e.h hVar = new h.a.a.h.e.h();
subscribe(hVar);
T a2 = hVar.a();
return a2 != null ? a2 : t;
}
@h.a.a.b.h("none")
public final void blockingSubscribe(@h.a.a.b.f p0<? super T> p0Var) {
Objects.requireNonNull(p0Var, "observer is null");
h.a.a.h.f.e.l.a(this, p0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> concatWith(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.y(this, f0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> delay(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return delay(j2, timeUnit, q0Var, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> i0<h.a.a.i.b<K, V>> groupBy(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, boolean z, int i2) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new h.a.a.h.f.e.n1(this, oVar, oVar2, i2, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> mergeWith(@h.a.a.b.f f0<? extends T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return h.a.a.l.a.a(new e2(this, f0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> retry(long j2, @h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
if (j2 >= 0) {
Objects.requireNonNull(rVar, "predicate is null");
return h.a.a.l.a.a(new y2(this, j2, rVar));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> skip(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return skipUntil(timer(j2, timeUnit, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13219i)
@h.a.a.b.f
public final i0<T> skipLast(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return skipLast(j2, timeUnit, h.a.a.n.b.g(), z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> startWith(@h.a.a.b.f f0<T> f0Var) {
Objects.requireNonNull(f0Var, "other is null");
return concat(z.k(f0Var).v(), this);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13219i)
@h.a.a.b.f
public final i0<T> takeLast(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return takeLast(j2, j3, timeUnit, h.a.a.n.b.g(), false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<T> timeout(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "fallback is null");
return timeout0(j2, timeUnit, n0Var, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> r0<Map<K, Collection<V>>> toMultimap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, h.a.a.g.o<? super T, ? extends V> oVar2) {
return toMultimap(oVar, oVar2, h.a.a.h.k.m.a(), h.a.a.h.k.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(cVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2}, h.a.a.h.b.a.a((h.a.a.g.c) cVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public static i0<Long> interval(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return interval(j2, j2, timeUnit, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
return fromArray(t, t2, t3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2) {
Objects.requireNonNull(n0Var, "sources is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
return h.a.a.l.a.a(new h.a.a.h.f.e.w0(n0Var, h.a.a.h.b.a.e(), false, i2, bufferSize()));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f n0<? extends n0<? extends T>> n0Var, int i2) {
Objects.requireNonNull(n0Var, "sources is null");
h.a.a.h.b.b.a(i2, "maxConcurrency");
return h.a.a.l.a.a(new h.a.a.h.f.e.w0(n0Var, h.a.a.h.b.a.e(), true, i2, bufferSize()));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> delay(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.g0(this, j2, timeUnit, q0Var, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnEach(@h.a.a.b.f h.a.a.g.g<? super h0<T>> gVar) {
Objects.requireNonNull(gVar, "onNotification is null");
return doOnEach(h.a.a.h.b.a.c((h.a.a.g.g) gVar), h.a.a.h.b.a.b((h.a.a.g.g) gVar), h.a.a.h.b.a.a((h.a.a.g.g) gVar), h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> sample(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new a3(this, j2, timeUnit, q0Var, z));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> skipLast(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return skipLast(j2, timeUnit, q0Var, false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> takeLast(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return takeLast(j2, j3, timeUnit, q0Var, false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> r0<Map<K, V>> toMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, @h.a.a.b.f h.a.a.g.s<? extends Map<K, V>> sVar) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
Objects.requireNonNull(sVar, "mapSupplier is null");
return (r0<Map<K, V>>) collect(sVar, h.a.a.h.b.a.a(oVar, oVar2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final r0<List<T>> toSortedList(int i2) {
return toSortedList(h.a.a.h.b.a.f(), i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> zipWith(@h.a.a.b.f n0<? extends U> n0Var, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z) {
return zip(this, n0Var, cVar, z);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concat(@h.a.a.b.f n0<? extends T> n0Var, n0<? extends T> n0Var2) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
return concatArray(n0Var, n0Var2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, S> i0<T> generate(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.b<S, r<T>> bVar, @h.a.a.b.f h.a.a.g.g<? super S> gVar) {
Objects.requireNonNull(bVar, "generator is null");
return generate(sVar, s1.a(bVar), gVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U extends Collection<? super T>> i0<U> buffer(int i2, @h.a.a.b.f h.a.a.g.s<U> sVar) {
return buffer(i2, i2, sVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> concatWith(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "other is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.x(this, pVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> mergeWith(@h.a.a.b.f p pVar) {
Objects.requireNonNull(pVar, "other is null");
return h.a.a.l.a.a(new d2(this, pVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, int i2, boolean z) {
Objects.requireNonNull(oVar, "selector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return w2.a(s1.a(this, i2, z), oVar);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> skipLast(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
return skipLast(j2, timeUnit, q0Var, z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> startWith(@h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "other is null");
return concatArray(n0Var, this);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> takeLast(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z, int i2) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
if (j2 >= 0) {
return h.a.a.l.a.a(new v3(this, j2, j3, timeUnit, q0Var, i2, z));
}
throw new IllegalArgumentException("count >= 0 required but it was " + j2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> timeout(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, @h.a.a.b.f n0<? extends T> n0Var) {
Objects.requireNonNull(n0Var, "fallback is null");
return timeout0(j2, timeUnit, n0Var, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return window(j2, j3, timeUnit, h.a.a.n.b.a(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> zipWith(@h.a.a.b.f n0<? extends U> n0Var, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z, int i2) {
return zip(this, n0Var, cVar, z, i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> r0<Boolean> sequenceEqual(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, int i2) {
return sequenceEqual(n0Var, n0Var2, h.a.a.h.b.b.a(), i2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(cVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.c) cVar), false, bufferSize(), n0Var, n0Var2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<List<T>> buffer(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit) {
return (i0<List<T>>) buffer(j2, j3, timeUnit, h.a.a.n.b.a(), h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> retry(@h.a.a.b.f h.a.a.g.r<? super Throwable> rVar) {
return retry(k.c3.w.p0.c, rVar);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> skipLast(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z, int i2) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new m3(this, j2, timeUnit, q0Var, i2 << 1, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> r0<Map<K, Collection<V>>> toMultimap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, @h.a.a.b.f h.a.a.g.s<? extends Map<K, Collection<V>>> sVar, @h.a.a.b.f h.a.a.g.o<? super K, ? extends Collection<? super V>> oVar3) {
Objects.requireNonNull(oVar, "keySelector is null");
Objects.requireNonNull(oVar2, "valueSelector is null");
Objects.requireNonNull(sVar, "mapSupplier is null");
Objects.requireNonNull(oVar3, "collectionFactory is null");
return (r0<Map<K, Collection<V>>>) collect(sVar, h.a.a.h.b.a.a(oVar, oVar2, oVar3));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return window(j2, j3, timeUnit, q0Var, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, S> i0<T> generate(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.c<S, r<T>, S> cVar) {
return generate(sVar, cVar, h.a.a.h.b.a.d());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
return fromArray(n0Var, n0Var2).flatMap(h.a.a.h.b.a.e(), false, 2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
return fromArray(n0Var, n0Var2).flatMap(h.a.a.h.b.a.e(), true, 2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<List<T>> buffer(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return (i0<List<T>>) buffer(j2, j3, timeUnit, q0Var, h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <R> i0<R> concatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, int i2, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.w(this, oVar, i2, h.a.a.h.k.j.IMMEDIATE, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <R> i0<R> concatMapDelayError(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, boolean z, int i2, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "mapper is null");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(q0Var, "scheduler is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.w(this, oVar, i2, z ? h.a.a.h.k.j.END : h.a.a.h.k.j.BOUNDARY, q0Var));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, V> i0<T> delay(@h.a.a.b.f n0<U> n0Var, @h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<V>> oVar) {
return delaySubscription(n0Var).delay(oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<T> sample(@h.a.a.b.f n0<U> n0Var) {
Objects.requireNonNull(n0Var, "sampler is null");
return h.a.a.l.a.a(new b3(this, n0Var, false));
}
@Override
@h.a.a.b.h("none")
public final void subscribe(@h.a.a.b.f p0<? super T> p0Var) {
Objects.requireNonNull(p0Var, "observer is null");
try {
p0<? super T> a2 = h.a.a.l.a.a(this, p0Var);
Objects.requireNonNull(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) {
h.a.a.e.b.b(th);
h.a.a.l.a.b(th);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> timeout(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return timeout0(j2, timeUnit, null, q0Var);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, int i2) {
h.a.a.h.b.b.a(j2, "timespan");
h.a.a.h.b.b.a(j3, "timeskip");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(timeUnit, "unit is null");
return h.a.a.l.a.a(new n4(this, j2, j3, timeUnit, q0Var, k.c3.w.p0.c, i2, false));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <T1, T2, T3, R> i0<R> withLatestFrom(@h.a.a.b.f n0<T1> n0Var, @h.a.a.b.f n0<T2> n0Var2, @h.a.a.b.f n0<T3> n0Var3, @h.a.a.b.f h.a.a.g.i<? super T, ? super T1, ? super T2, ? super T3, R> iVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(iVar, "combiner is null");
return withLatestFrom(new n0[]{n0Var, n0Var2, n0Var3}, h.a.a.h.b.a.a((h.a.a.g.i) iVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f h.a.a.g.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(hVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2, n0Var3}, h.a.a.h.b.a.a((h.a.a.g.h) hVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concat(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f n0<? extends T> n0Var3) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
return concatArray(n0Var, n0Var2, n0Var3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T, S> i0<T> generate(@h.a.a.b.f h.a.a.g.s<S> sVar, @h.a.a.b.f h.a.a.g.c<S, r<T>, S> cVar, @h.a.a.b.f h.a.a.g.g<? super S> gVar) {
Objects.requireNonNull(sVar, "initialState is null");
Objects.requireNonNull(cVar, "generator is null");
Objects.requireNonNull(gVar, "disposeState is null");
return h.a.a.l.a.a(new m1(sVar, cVar, gVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3, @h.a.a.b.f T t4) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
return fromArray(t, t2, t3, t4);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <U extends Collection<? super T>> i0<U> buffer(long j2, long j3, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, @h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.p(this, j2, j3, timeUnit, q0Var, sVar, Integer.MAX_VALUE, false));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, int i2, long j2, @h.a.a.b.f TimeUnit timeUnit) {
return replay(oVar, i2, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, V> i0<T> timeout(@h.a.a.b.f n0<U> n0Var, @h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<V>> oVar) {
Objects.requireNonNull(n0Var, "firstTimeoutIndicator is null");
return timeout0(n0Var, oVar, null);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final i0<T> doOnEach(@h.a.a.b.f p0<? super T> p0Var) {
Objects.requireNonNull(p0Var, "observer is null");
return doOnEach(s1.c(p0Var), s1.b(p0Var), s1.a(p0Var), h.a.a.h.b.a.c);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "selector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(s1.a(this, i2, j2, timeUnit, q0Var, false), oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U> i0<T> sample(@h.a.a.b.f n0<U> n0Var, boolean z) {
Objects.requireNonNull(n0Var, "sampler is null");
return h.a.a.l.a.a(new b3(this, n0Var, z));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f n0<? extends T> n0Var3) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
return fromArray(n0Var, n0Var2, n0Var3).flatMap(h.a.a.h.b.a.e(), false, 3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f n0<? extends T> n0Var3) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
return fromArray(n0Var, n0Var2, n0Var3).flatMap(h.a.a.h.b.a.e(), true, 3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar, boolean z) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(cVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.c) cVar), z, bufferSize(), n0Var, n0Var2);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, @h.a.a.b.f h.a.a.g.o<? super Throwable, ? extends n0<? extends R>> oVar2, @h.a.a.b.f h.a.a.g.s<? extends n0<? extends R>> sVar) {
Objects.requireNonNull(oVar, "onNextMapper is null");
Objects.requireNonNull(oVar2, "onErrorMapper is null");
Objects.requireNonNull(sVar, "onCompleteSupplier is null");
return merge(new b2(this, oVar, oVar2, sVar));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13219i)
@h.a.a.b.f
public final i0<T> takeLast(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return takeLast(j2, timeUnit, h.a.a.n.b.g(), false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, V> i0<T> timeout(@h.a.a.b.f n0<U> n0Var, @h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<V>> oVar, @h.a.a.b.f n0<? extends T> n0Var2) {
Objects.requireNonNull(n0Var, "firstTimeoutIndicator is null");
Objects.requireNonNull(n0Var2, "fallback is null");
return timeout0(n0Var, oVar, n0Var2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13219i)
@h.a.a.b.f
public final i0<T> takeLast(long j2, @h.a.a.b.f TimeUnit timeUnit, boolean z) {
return takeLast(j2, timeUnit, h.a.a.n.b.g(), z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <K, V> r0<Map<K, Collection<V>>> toMultimap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends K> oVar, @h.a.a.b.f h.a.a.g.o<? super T, ? extends V> oVar2, @h.a.a.b.f h.a.a.g.s<Map<K, Collection<V>>> sVar) {
return toMultimap(oVar, oVar2, sVar, h.a.a.h.k.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> concat(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f n0<? extends T> n0Var3, @h.a.a.b.f n0<? extends T> n0Var4) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
return concatArray(n0Var, n0Var2, n0Var3, n0Var4);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<List<T>> buffer(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return buffer(j2, timeUnit, h.a.a.n.b.a(), Integer.MAX_VALUE);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> takeLast(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return takeLast(j2, timeUnit, q0Var, false, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f h.a.a.g.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(iVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2, n0Var3, n0Var4}, h.a.a.h.b.a.a((h.a.a.g.i) iVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3, @h.a.a.b.f T t4, @h.a.a.b.f T t5) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
return fromArray(t, t2, t3, t4, t5);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<List<T>> buffer(long j2, @h.a.a.b.f TimeUnit timeUnit, int i2) {
return buffer(j2, timeUnit, h.a.a.n.b.a(), i2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> takeLast(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
return takeLast(j2, timeUnit, q0Var, z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return window(j2, timeUnit, h.a.a.n.b.a(), (long) k.c3.w.p0.c, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <T1, T2, T3, T4, R> i0<R> withLatestFrom(@h.a.a.b.f n0<T1> n0Var, @h.a.a.b.f n0<T2> n0Var2, @h.a.a.b.f n0<T3> n0Var3, @h.a.a.b.f n0<T4> n0Var4, @h.a.a.b.f h.a.a.g.j<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> jVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(jVar, "combiner is null");
return withLatestFrom(new n0[]{n0Var, n0Var2, n0Var3, n0Var4}, h.a.a.h.b.a.a((h.a.a.g.j) jVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> merge(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f n0<? extends T> n0Var3, @h.a.a.b.f n0<? extends T> n0Var4) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
return fromArray(n0Var, n0Var2, n0Var3, n0Var4).flatMap(h.a.a.h.b.a.e(), false, 4);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> mergeDelayError(@h.a.a.b.f n0<? extends T> n0Var, @h.a.a.b.f n0<? extends T> n0Var2, @h.a.a.b.f n0<? extends T> n0Var3, @h.a.a.b.f n0<? extends T> n0Var4) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
return fromArray(n0Var, n0Var2, n0Var3, n0Var4).flatMap(h.a.a.h.b.a.e(), true, 4);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f h.a.a.g.c<? super T1, ? super T2, ? extends R> cVar, boolean z, int i2) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(cVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.c) cVar), z, i2, n0Var, n0Var2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<List<T>> buffer(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, int i2) {
return (i0<List<T>>) buffer(j2, timeUnit, q0Var, i2, h.a.a.h.k.b.b(), false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, @h.a.a.b.f h.a.a.g.o<Throwable, ? extends n0<? extends R>> oVar2, @h.a.a.b.f h.a.a.g.s<? extends n0<? extends R>> sVar, int i2) {
Objects.requireNonNull(oVar, "onNextMapper is null");
Objects.requireNonNull(oVar2, "onErrorMapper is null");
Objects.requireNonNull(sVar, "onCompleteSupplier is null");
return merge(new b2(this, oVar, oVar2, sVar), i2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<T> takeLast(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z, int i2) {
return takeLast(k.c3.w.p0.c, j2, timeUnit, q0Var, z, i2);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, @h.a.a.b.f TimeUnit timeUnit, long j3) {
return window(j2, timeUnit, h.a.a.n.b.a(), j3, false);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <U extends Collection<? super T>> i0<U> buffer(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, int i2, @h.a.a.b.f h.a.a.g.s<U> sVar, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
h.a.a.h.b.b.a(i2, NewHtcHomeBadger.f20939d);
return h.a.a.l.a.a(new h.a.a.h.f.e.p(this, j2, j2, timeUnit, q0Var, sVar, i2, z));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(oVar, "selector is null");
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(s1.a(this, i2, j2, timeUnit, q0Var, z), oVar);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, @h.a.a.b.f TimeUnit timeUnit, long j3, boolean z) {
return window(j2, timeUnit, h.a.a.n.b.a(), j3, z);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return window(j2, timeUnit, q0Var, (long) k.c3.w.p0.c, false);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, long j3) {
return window(j2, timeUnit, q0Var, j3, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f h.a.a.g.h<? super T1, ? super T2, ? super T3, ? extends R> hVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(hVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.h) hVar), false, bufferSize(), n0Var, n0Var2, n0Var3);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends R>> oVar, int i2) {
return flatMap((h.a.a.g.o) oVar, false, i2, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, long j3, boolean z) {
return window(j2, timeUnit, q0Var, j3, z, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f h.a.a.g.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(jVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2, n0Var3, n0Var4, n0Var5}, h.a.a.h.b.a.a((h.a.a.g.j) jVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3, @h.a.a.b.f T t4, @h.a.a.b.f T t5, @h.a.a.b.f T t6) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
return fromArray(t, t2, t3, t4, t5, t6);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar) {
return flatMap(oVar, cVar, false, bufferSize(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<i0<T>> window(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, long j3, boolean z, int i2) {
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(q0Var, "scheduler is null");
Objects.requireNonNull(timeUnit, "unit is null");
h.a.a.h.b.b.a(j3, NewHtcHomeBadger.f20939d);
return h.a.a.l.a.a(new n4(this, j2, j2, timeUnit, q0Var, j3, i2, z));
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final i0<List<T>> buffer(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
return (i0<List<T>>) buffer(j2, timeUnit, q0Var, Integer.MAX_VALUE, h.a.a.h.k.b.b(), false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z) {
return flatMap(oVar, cVar, z, bufferSize(), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> withLatestFrom(@h.a.a.b.f n0<?>[] n0VarArr, @h.a.a.b.f h.a.a.g.o<? super Object[], R> oVar) {
Objects.requireNonNull(n0VarArr, "others is null");
Objects.requireNonNull(oVar, "combiner is null");
return h.a.a.l.a.a(new p4(this, n0VarArr, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <TOpening, TClosing> i0<List<T>> buffer(@h.a.a.b.f n0<? extends TOpening> n0Var, @h.a.a.b.f h.a.a.g.o<? super TOpening, ? extends n0<? extends TClosing>> oVar) {
return (i0<List<T>>) buffer(n0Var, oVar, h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z, int i2) {
return flatMap(oVar, cVar, z, i2, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, long j2, @h.a.a.b.f TimeUnit timeUnit) {
return replay(oVar, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <TOpening, TClosing, U extends Collection<? super T>> i0<U> buffer(@h.a.a.b.f n0<? extends TOpening> n0Var, @h.a.a.b.f h.a.a.g.o<? super TOpening, ? extends n0<? extends TClosing>> oVar, @h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(n0Var, "openingIndicator is null");
Objects.requireNonNull(oVar, "closingIndicator is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.n(this, n0Var, oVar, sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, boolean z, int i2, int i3) {
Objects.requireNonNull(oVar, "mapper is null");
Objects.requireNonNull(cVar, "combiner is null");
return flatMap(s1.a(oVar, cVar), z, i2, i3);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(oVar, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(s1.a(this, j2, timeUnit, q0Var, false), oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f h.a.a.g.i<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> iVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(iVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.i) iVar), false, bufferSize(), n0Var, n0Var2, n0Var3, n0Var4);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <R> i0<R> withLatestFrom(@h.a.a.b.f Iterable<? extends n0<?>> iterable, @h.a.a.b.f h.a.a.g.o<? super Object[], R> oVar) {
Objects.requireNonNull(iterable, "others is null");
Objects.requireNonNull(oVar, "combiner is null");
return h.a.a.l.a.a(new p4(this, iterable, oVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <B> i0<i0<T>> window(@h.a.a.b.f n0<B> n0Var) {
return window(n0Var, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, R> i0<R> flatMap(@h.a.a.b.f h.a.a.g.o<? super T, ? extends n0<? extends U>> oVar, @h.a.a.b.f h.a.a.g.c<? super T, ? super U, ? extends R> cVar, int i2) {
return flatMap(oVar, cVar, false, i2, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <B> i0<i0<T>> window(@h.a.a.b.f n0<B> n0Var, int i2) {
Objects.requireNonNull(n0Var, "boundaryIndicator is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new k4(this, n0Var, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f h.a.a.g.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(kVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6}, h.a.a.h.b.a.a((h.a.a.g.k) kVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3, @h.a.a.b.f T t4, @h.a.a.b.f T t5, @h.a.a.b.f T t6, @h.a.a.b.f T t7) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <B> i0<List<T>> buffer(@h.a.a.b.f n0<B> n0Var) {
return (i0<List<T>>) buffer(n0Var, h.a.a.h.k.b.b());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final <R> i0<R> replay(@h.a.a.b.f h.a.a.g.o<? super i0<T>, ? extends n0<R>> oVar, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(oVar, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(s1.a(this, j2, timeUnit, q0Var, z), oVar);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <B> i0<List<T>> buffer(@h.a.a.b.f n0<B> n0Var, int i2) {
h.a.a.h.b.b.a(i2, "initialCapacity");
return (i0<List<T>>) buffer(n0Var, h.a.a.h.b.a.b(i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, V> i0<i0<T>> window(@h.a.a.b.f n0<U> n0Var, @h.a.a.b.f h.a.a.g.o<? super U, ? extends n0<V>> oVar) {
return window(n0Var, oVar, bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f h.a.a.g.j<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> jVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(jVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.j) jVar), false, bufferSize(), n0Var, n0Var2, n0Var3, n0Var4, n0Var5);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <B, U extends Collection<? super T>> i0<U> buffer(@h.a.a.b.f n0<B> n0Var, @h.a.a.b.f h.a.a.g.s<U> sVar) {
Objects.requireNonNull(n0Var, "boundaryIndicator is null");
Objects.requireNonNull(sVar, "bufferSupplier is null");
return h.a.a.l.a.a(new h.a.a.h.f.e.o(this, n0Var, sVar));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final <U, V> i0<i0<T>> window(@h.a.a.b.f n0<U> n0Var, @h.a.a.b.f h.a.a.g.o<? super U, ? extends n0<V>> oVar, int i2) {
Objects.requireNonNull(n0Var, "openingIndicator is null");
Objects.requireNonNull(oVar, "closingIndicator is null");
h.a.a.h.b.b.a(i2, "bufferSize");
return h.a.a.l.a.a(new l4(this, n0Var, oVar, i2));
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.i.a<T> replay(int i2) {
h.a.a.h.b.b.a(i2, "bufferSize");
return w2.a((n0) this, i2, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public final h.a.a.i.a<T> replay(int i2, boolean z) {
h.a.a.h.b.b.a(i2, "bufferSize");
return w2.a(this, i2, z);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f n0<? extends T7> n0Var7, @h.a.a.b.f h.a.a.g.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(n0Var7, "source7 is null");
Objects.requireNonNull(lVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6, n0Var7}, h.a.a.h.b.a.a((h.a.a.g.l) lVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3, @h.a.a.b.f T t4, @h.a.a.b.f T t5, @h.a.a.b.f T t6, @h.a.a.b.f T t7, @h.a.a.b.f T t8) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7, t8);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final h.a.a.i.a<T> replay(int i2, long j2, @h.a.a.b.f TimeUnit timeUnit) {
return replay(i2, j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final h.a.a.i.a<T> replay(int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(this, j2, timeUnit, q0Var, i2, false);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f h.a.a.g.k<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> kVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(kVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.k) kVar), false, bufferSize(), n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final h.a.a.i.a<T> replay(int i2, long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
h.a.a.h.b.b.a(i2, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(this, j2, timeUnit, q0Var, i2, z);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f n0<? extends T7> n0Var7, @h.a.a.b.f n0<? extends T8> n0Var8, @h.a.a.b.f h.a.a.g.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(n0Var7, "source7 is null");
Objects.requireNonNull(n0Var8, "source8 is null");
Objects.requireNonNull(mVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6, n0Var7, n0Var8}, h.a.a.h.b.a.a((h.a.a.g.m) mVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3, @h.a.a.b.f T t4, @h.a.a.b.f T t5, @h.a.a.b.f T t6, @h.a.a.b.f T t7, @h.a.a.b.f T t8, @h.a.a.b.f T t9) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
Objects.requireNonNull(t9, "item9 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7, t8, t9);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13216f)
@h.a.a.b.f
public final h.a.a.i.a<T> replay(long j2, @h.a.a.b.f TimeUnit timeUnit) {
return replay(j2, timeUnit, h.a.a.n.b.a());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f n0<? extends T7> n0Var7, @h.a.a.b.f h.a.a.g.l<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> lVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(n0Var7, "source7 is null");
Objects.requireNonNull(lVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.l) lVar), false, bufferSize(), n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6, n0Var7);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final h.a.a.i.a<T> replay(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(this, j2, timeUnit, q0Var, false);
}
@h.a.a.b.d
@h.a.a.b.h(h.a.a.b.h.f13215e)
@h.a.a.b.f
public final h.a.a.i.a<T> replay(long j2, @h.a.a.b.f TimeUnit timeUnit, @h.a.a.b.f q0 q0Var, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(q0Var, "scheduler is null");
return w2.a(this, j2, timeUnit, q0Var, z);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> i0<R> combineLatest(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f n0<? extends T7> n0Var7, @h.a.a.b.f n0<? extends T8> n0Var8, @h.a.a.b.f n0<? extends T9> n0Var9, @h.a.a.b.f h.a.a.g.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(n0Var7, "source7 is null");
Objects.requireNonNull(n0Var8, "source8 is null");
Objects.requireNonNull(n0Var9, "source9 is null");
Objects.requireNonNull(nVar, "combiner is null");
return combineLatestArray(new n0[]{n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6, n0Var7, n0Var8, n0Var9}, h.a.a.h.b.a.a((h.a.a.g.n) nVar), bufferSize());
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T> i0<T> just(@h.a.a.b.f T t, @h.a.a.b.f T t2, @h.a.a.b.f T t3, @h.a.a.b.f T t4, @h.a.a.b.f T t5, @h.a.a.b.f T t6, @h.a.a.b.f T t7, @h.a.a.b.f T t8, @h.a.a.b.f T t9, @h.a.a.b.f T t10) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
Objects.requireNonNull(t9, "item9 is null");
Objects.requireNonNull(t10, "item10 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7, t8, t9, t10);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f n0<? extends T7> n0Var7, @h.a.a.b.f n0<? extends T8> n0Var8, @h.a.a.b.f h.a.a.g.m<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> mVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(n0Var7, "source7 is null");
Objects.requireNonNull(n0Var8, "source8 is null");
Objects.requireNonNull(mVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.m) mVar), false, bufferSize(), n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6, n0Var7, n0Var8);
}
@h.a.a.b.d
@h.a.a.b.h("none")
@h.a.a.b.f
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> i0<R> zip(@h.a.a.b.f n0<? extends T1> n0Var, @h.a.a.b.f n0<? extends T2> n0Var2, @h.a.a.b.f n0<? extends T3> n0Var3, @h.a.a.b.f n0<? extends T4> n0Var4, @h.a.a.b.f n0<? extends T5> n0Var5, @h.a.a.b.f n0<? extends T6> n0Var6, @h.a.a.b.f n0<? extends T7> n0Var7, @h.a.a.b.f n0<? extends T8> n0Var8, @h.a.a.b.f n0<? extends T9> n0Var9, @h.a.a.b.f h.a.a.g.n<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> nVar) {
Objects.requireNonNull(n0Var, "source1 is null");
Objects.requireNonNull(n0Var2, "source2 is null");
Objects.requireNonNull(n0Var3, "source3 is null");
Objects.requireNonNull(n0Var4, "source4 is null");
Objects.requireNonNull(n0Var5, "source5 is null");
Objects.requireNonNull(n0Var6, "source6 is null");
Objects.requireNonNull(n0Var7, "source7 is null");
Objects.requireNonNull(n0Var8, "source8 is null");
Objects.requireNonNull(n0Var9, "source9 is null");
Objects.requireNonNull(nVar, "zipper is null");
return zipArray(h.a.a.h.b.a.a((h.a.a.g.n) nVar), false, bufferSize(), n0Var, n0Var2, n0Var3, n0Var4, n0Var5, n0Var6, n0Var7, n0Var8, n0Var9);
}
}