what-the-bank/sources/o/AbstractC13163fSk.java

2980 lines
144 KiB
Java
Raw Permalink Normal View History

2024-07-27 18:17:47 +07:00
package o;
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 o.C13309fWr;
import o.C13328fXb;
/* renamed from: o.fSk, reason: case insensitive filesystem */
/* loaded from: classes.dex */
public abstract class AbstractC13163fSk<T> implements InterfaceC13169fSq<T> {
protected abstract void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv);
public static <T> AbstractC13163fSk<T> amb(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return new C13257fVa(null, iterable);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> ambArray(InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
Objects.requireNonNull(interfaceC13169fSqArr, "sources is null");
int length = interfaceC13169fSqArr.length;
if (length == 0) {
return empty();
}
if (length == 1) {
return wrap(interfaceC13169fSqArr[0]);
}
return new C13257fVa(interfaceC13169fSqArr, null);
}
public static int bufferSize() {
return AbstractC13155fSc.a();
}
public static <T, R> AbstractC13163fSk<R> combineLatest(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, fSS<? super Object[], ? extends R> fss) {
return combineLatest(iterable, fss, bufferSize());
}
public static <T, R> AbstractC13163fSk<R> combineLatest(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, fSS<? super Object[], ? extends R> fss, int i) {
Objects.requireNonNull(iterable, "sources is null");
Objects.requireNonNull(fss, "combiner is null");
C13199fTm.c(i, "bufferSize");
return new C13269fVm(null, iterable, fss, i << 1, false);
}
public static <T, R> AbstractC13163fSk<R> combineLatestArray(InterfaceC13169fSq<? extends T>[] interfaceC13169fSqArr, fSS<? super Object[], ? extends R> fss) {
return combineLatestArray(interfaceC13169fSqArr, fss, bufferSize());
}
public static <T, R> AbstractC13163fSk<R> combineLatestArray(InterfaceC13169fSq<? extends T>[] interfaceC13169fSqArr, fSS<? super Object[], ? extends R> fss, int i) {
Objects.requireNonNull(interfaceC13169fSqArr, "sources is null");
if (interfaceC13169fSqArr.length == 0) {
return empty();
}
Objects.requireNonNull(fss, "combiner is null");
C13199fTm.c(i, "bufferSize");
return new C13269fVm(interfaceC13169fSqArr, null, fss, i << 1, false);
}
public static <T1, T2, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, fSL<? super T1, ? super T2, ? extends R> fsl) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(fsl, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2}, C13194fTh.b(fsl), bufferSize());
}
public static <T1, T2, T3, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13150fSU<? super T1, ? super T2, ? super T3, ? extends R> interfaceC13150fSU) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13150fSU, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3}, C13194fTh.c((InterfaceC13150fSU) interfaceC13150fSU), bufferSize());
}
public static <T1, T2, T3, T4, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, fST<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> fst) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(fst, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4}, C13194fTh.b(fst), bufferSize());
}
public static <T1, T2, T3, T4, T5, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13151fSX<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> interfaceC13151fSX) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13151fSX, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5}, C13194fTh.e(interfaceC13151fSX), bufferSize());
}
public static <T1, T2, T3, T4, T5, T6, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13187fTa<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> interfaceC13187fTa) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13187fTa, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6}, C13194fTh.a((InterfaceC13187fTa) interfaceC13187fTa), bufferSize());
}
public static <T1, T2, T3, T4, T5, T6, T7, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13169fSq<? extends T7> interfaceC13169fSq7, fSZ<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> fsz) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13169fSq7, "source7 is null");
Objects.requireNonNull(fsz, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6, interfaceC13169fSq7}, C13194fTh.a((fSZ) fsz), bufferSize());
}
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13169fSq<? extends T7> interfaceC13169fSq7, InterfaceC13169fSq<? extends T8> interfaceC13169fSq8, fSW<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> fsw) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13169fSq7, "source7 is null");
Objects.requireNonNull(interfaceC13169fSq8, "source8 is null");
Objects.requireNonNull(fsw, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6, interfaceC13169fSq7, interfaceC13169fSq8}, C13194fTh.b(fsw), bufferSize());
}
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> AbstractC13163fSk<R> combineLatest(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13169fSq<? extends T7> interfaceC13169fSq7, InterfaceC13169fSq<? extends T8> interfaceC13169fSq8, InterfaceC13169fSq<? extends T9> interfaceC13169fSq9, fSV<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> fsv) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13169fSq7, "source7 is null");
Objects.requireNonNull(interfaceC13169fSq8, "source8 is null");
Objects.requireNonNull(interfaceC13169fSq9, "source9 is null");
Objects.requireNonNull(fsv, "combiner is null");
return combineLatestArray(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6, interfaceC13169fSq7, interfaceC13169fSq8, interfaceC13169fSq9}, C13194fTh.b(fsv), bufferSize());
}
public static <T, R> AbstractC13163fSk<R> combineLatestArrayDelayError(InterfaceC13169fSq<? extends T>[] interfaceC13169fSqArr, fSS<? super Object[], ? extends R> fss) {
return combineLatestArrayDelayError(interfaceC13169fSqArr, fss, bufferSize());
}
public static <T, R> AbstractC13163fSk<R> combineLatestArrayDelayError(InterfaceC13169fSq<? extends T>[] interfaceC13169fSqArr, fSS<? super Object[], ? extends R> fss, int i) {
Objects.requireNonNull(interfaceC13169fSqArr, "sources is null");
Objects.requireNonNull(fss, "combiner is null");
C13199fTm.c(i, "bufferSize");
if (interfaceC13169fSqArr.length == 0) {
return empty();
}
return new C13269fVm(interfaceC13169fSqArr, null, fss, i << 1, true);
}
public static <T, R> AbstractC13163fSk<R> combineLatestDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, fSS<? super Object[], ? extends R> fss) {
return combineLatestDelayError(iterable, fss, bufferSize());
}
public static <T, R> AbstractC13163fSk<R> combineLatestDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, fSS<? super Object[], ? extends R> fss, int i) {
Objects.requireNonNull(iterable, "sources is null");
Objects.requireNonNull(fss, "combiner is null");
C13199fTm.c(i, "bufferSize");
return new C13269fVm(null, iterable, fss, i << 1, true);
}
public static <T> AbstractC13163fSk<T> concat(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return fromIterable(iterable).concatMapDelayError(C13194fTh.d(), false, bufferSize());
}
public static <T> AbstractC13163fSk<T> concat(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
return concat(interfaceC13169fSq, bufferSize());
}
public static <T> AbstractC13163fSk<T> concat(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
C13199fTm.c(i, "bufferSize");
return new C13274fVr(interfaceC13169fSq, C13194fTh.d(), i, EnumC13357fYN.IMMEDIATE);
}
public static <T> AbstractC13163fSk<T> concat(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
return concatArray(interfaceC13169fSq, interfaceC13169fSq2);
}
public static <T> AbstractC13163fSk<T> concat(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, InterfaceC13169fSq<? extends T> interfaceC13169fSq3) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
return concatArray(interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3);
}
public static <T> AbstractC13163fSk<T> concat(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, InterfaceC13169fSq<? extends T> interfaceC13169fSq3, InterfaceC13169fSq<? extends T> interfaceC13169fSq4) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
return concatArray(interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> concatArray(InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
Objects.requireNonNull(interfaceC13169fSqArr, "sources is null");
if (interfaceC13169fSqArr.length == 0) {
return empty();
}
if (interfaceC13169fSqArr.length == 1) {
return wrap(interfaceC13169fSqArr[0]);
}
return new C13274fVr(fromArray(interfaceC13169fSqArr), C13194fTh.d(), bufferSize(), EnumC13357fYN.BOUNDARY);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> concatArrayDelayError(InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
Objects.requireNonNull(interfaceC13169fSqArr, "sources is null");
if (interfaceC13169fSqArr.length == 0) {
return empty();
}
if (interfaceC13169fSqArr.length == 1) {
return wrap(interfaceC13169fSqArr[0]);
}
return concatDelayError(fromArray(interfaceC13169fSqArr));
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> concatArrayEager(InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return concatArrayEager(bufferSize(), bufferSize(), interfaceC13169fSqArr);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> concatArrayEager(int i, int i2, InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return fromArray(interfaceC13169fSqArr).concatMapEagerDelayError(C13194fTh.d(), false, i, i2);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> concatArrayEagerDelayError(InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return concatArrayEagerDelayError(bufferSize(), bufferSize(), interfaceC13169fSqArr);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> concatArrayEagerDelayError(int i, int i2, InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return fromArray(interfaceC13169fSqArr).concatMapEagerDelayError(C13194fTh.d(), true, i, i2);
}
public static <T> AbstractC13163fSk<T> concatDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable) {
Objects.requireNonNull(iterable, "sources is null");
return concatDelayError(fromIterable(iterable));
}
public static <T> AbstractC13163fSk<T> concatDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
return concatDelayError(interfaceC13169fSq, bufferSize(), true);
}
public static <T> AbstractC13163fSk<T> concatDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i, boolean z) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
C13199fTm.c(i, "bufferSize is null");
return new C13274fVr(interfaceC13169fSq, C13194fTh.d(), i, z ? EnumC13357fYN.END : EnumC13357fYN.BOUNDARY);
}
public static <T> AbstractC13163fSk<T> concatEager(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable) {
return concatEager(iterable, bufferSize(), bufferSize());
}
public static <T> AbstractC13163fSk<T> concatEager(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, int i, int i2) {
return fromIterable(iterable).concatMapEagerDelayError(C13194fTh.d(), false, i, i2);
}
public static <T> AbstractC13163fSk<T> concatEager(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
return concatEager(interfaceC13169fSq, bufferSize(), bufferSize());
}
public static <T> AbstractC13163fSk<T> concatEager(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i, int i2) {
return wrap(interfaceC13169fSq).concatMapEager(C13194fTh.d(), i, i2);
}
public static <T> AbstractC13163fSk<T> concatEagerDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable) {
return concatEagerDelayError(iterable, bufferSize(), bufferSize());
}
public static <T> AbstractC13163fSk<T> concatEagerDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, int i, int i2) {
return fromIterable(iterable).concatMapEagerDelayError(C13194fTh.d(), true, i, i2);
}
public static <T> AbstractC13163fSk<T> concatEagerDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
return concatEagerDelayError(interfaceC13169fSq, bufferSize(), bufferSize());
}
public static <T> AbstractC13163fSk<T> concatEagerDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i, int i2) {
return wrap(interfaceC13169fSq).concatMapEagerDelayError(C13194fTh.d(), true, i, i2);
}
public static <T> AbstractC13163fSk<T> create(InterfaceC13170fSr<T> interfaceC13170fSr) {
Objects.requireNonNull(interfaceC13170fSr, "source is null");
return new C13279fVw(interfaceC13170fSr);
}
public static <T> AbstractC13163fSk<T> defer(InterfaceC13189fTc<? extends InterfaceC13169fSq<? extends T>> interfaceC13189fTc) {
Objects.requireNonNull(interfaceC13189fTc, "supplier is null");
return new fVC(interfaceC13189fTc);
}
public static <T> AbstractC13163fSk<T> empty() {
return (AbstractC13163fSk<T>) C13254fVR.c;
}
public static <T> AbstractC13163fSk<T> error(InterfaceC13189fTc<? extends Throwable> interfaceC13189fTc) {
Objects.requireNonNull(interfaceC13189fTc, "supplier is null");
return new fVT(interfaceC13189fTc);
}
public static <T> AbstractC13163fSk<T> error(Throwable th) {
Objects.requireNonNull(th, "throwable is null");
return error((InterfaceC13189fTc<? extends Throwable>) C13194fTh.a(th));
}
public static <T> AbstractC13163fSk<T> fromAction(fSP fsp) {
Objects.requireNonNull(fsp, "action is null");
return new C13255fVX(fsp);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> fromArray(T... tArr) {
Objects.requireNonNull(tArr, "items is null");
if (tArr.length == 0) {
return empty();
}
if (tArr.length == 1) {
return just(tArr[0]);
}
return new C13294fWc(tArr);
}
public static <T> AbstractC13163fSk<T> fromCallable(Callable<? extends T> callable) {
Objects.requireNonNull(callable, "callable is null");
return new C13293fWb(callable);
}
public static <T> AbstractC13163fSk<T> fromCompletable(fRZ frz) {
Objects.requireNonNull(frz, "completableSource is null");
return new C13296fWe(frz);
}
public static <T> AbstractC13163fSk<T> fromFuture(Future<? extends T> future) {
Objects.requireNonNull(future, "future is null");
return new C13295fWd(future, 0L, null);
}
public static <T> AbstractC13163fSk<T> fromFuture(Future<? extends T> future, long j, TimeUnit timeUnit) {
Objects.requireNonNull(future, "future is null");
Objects.requireNonNull(timeUnit, "unit is null");
return new C13295fWd(future, j, timeUnit);
}
public static <T> AbstractC13163fSk<T> fromIterable(Iterable<? extends T> iterable) {
Objects.requireNonNull(iterable, "source is null");
return new C13297fWf(iterable);
}
public static <T> AbstractC13163fSk<T> fromMaybe(InterfaceC13160fSh<T> interfaceC13160fSh) {
Objects.requireNonNull(interfaceC13160fSh, "maybe is null");
return new C13214fUE(interfaceC13160fSh);
}
public static <T> AbstractC13163fSk<T> fromPublisher(InterfaceC15340gnp<? extends T> interfaceC15340gnp) {
Objects.requireNonNull(interfaceC15340gnp, "publisher is null");
return new C13301fWj(interfaceC15340gnp);
}
public static <T> AbstractC13163fSk<T> fromRunnable(Runnable runnable) {
Objects.requireNonNull(runnable, "run is null");
return new C13302fWk(runnable);
}
public static <T> AbstractC13163fSk<T> fromSingle(fSD<T> fsd) {
Objects.requireNonNull(fsd, "source is null");
return new C13377fYp(fsd);
}
public static <T> AbstractC13163fSk<T> fromSupplier(InterfaceC13189fTc<? extends T> interfaceC13189fTc) {
Objects.requireNonNull(interfaceC13189fTc, "supplier is null");
return new C13299fWh(interfaceC13189fTc);
}
public static <T> AbstractC13163fSk<T> generate(fSQ<InterfaceC13156fSd<T>> fsq) {
Objects.requireNonNull(fsq, "generator is null");
return generate(C13194fTh.i(), new C13309fWr.ZnX(fsq), C13194fTh.c());
}
public static <T, S> AbstractC13163fSk<T> generate(InterfaceC13189fTc<S> interfaceC13189fTc, fSK<S, InterfaceC13156fSd<T>> fsk) {
Objects.requireNonNull(fsk, "generator is null");
return generate(interfaceC13189fTc, new C13309fWr.dAO(fsk), C13194fTh.c());
}
public static <T, S> AbstractC13163fSk<T> generate(InterfaceC13189fTc<S> interfaceC13189fTc, fSK<S, InterfaceC13156fSd<T>> fsk, fSQ<? super S> fsq) {
Objects.requireNonNull(fsk, "generator is null");
return generate(interfaceC13189fTc, new C13309fWr.dAO(fsk), fsq);
}
public static <T, S> AbstractC13163fSk<T> generate(InterfaceC13189fTc<S> interfaceC13189fTc, fSL<S, InterfaceC13156fSd<T>, S> fsl) {
return generate(interfaceC13189fTc, fsl, C13194fTh.c());
}
public static <T, S> AbstractC13163fSk<T> generate(InterfaceC13189fTc<S> interfaceC13189fTc, fSL<S, InterfaceC13156fSd<T>, S> fsl, fSQ<? super S> fsq) {
Objects.requireNonNull(interfaceC13189fTc, "initialState is null");
Objects.requireNonNull(fsl, "generator is null");
Objects.requireNonNull(fsq, "disposeState is null");
return new C13300fWi(interfaceC13189fTc, fsl, fsq);
}
public static AbstractC13163fSk<Long> interval(long j, long j2, TimeUnit timeUnit) {
return interval(j, j2, timeUnit, C13417fZt.e());
}
public static AbstractC13163fSk<Long> interval(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new C13312fWu(Math.max(0L, j), Math.max(0L, j2), timeUnit, abstractC13173fSu);
}
public static AbstractC13163fSk<Long> interval(long j, TimeUnit timeUnit) {
return interval(j, j, timeUnit, C13417fZt.e());
}
public static AbstractC13163fSk<Long> interval(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return interval(j, j, timeUnit, abstractC13173fSu);
}
public static AbstractC13163fSk<Long> intervalRange(long j, long j2, long j3, long j4, TimeUnit timeUnit) {
return intervalRange(j, j2, j3, j4, timeUnit, C13417fZt.e());
}
public static AbstractC13163fSk<Long> intervalRange(long j, long j2, long j3, long j4, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
if (j2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(j2)));
}
if (j2 == 0) {
return empty().delay(j3, timeUnit, abstractC13173fSu);
}
long j5 = (j2 - 1) + j;
if (j > 0 && j5 < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new C13310fWs(j, j5, Math.max(0L, j3), Math.max(0L, j4), timeUnit, abstractC13173fSu);
}
public static <T> AbstractC13163fSk<T> just(T t) {
Objects.requireNonNull(t, "item is null");
return new C13308fWq(t);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
return fromArray(t, t2);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
return fromArray(t, t2, t3);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3, T t4) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
return fromArray(t, t2, t3, t4);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3, T t4, T t5) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
return fromArray(t, t2, t3, t4, t5);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3, T t4, T t5, T t6) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
return fromArray(t, t2, t3, t4, t5, t6);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3, T t4, T t5, T t6, T t7) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3, T t4, T t5, T t6, T t7, T t8) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7, t8);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
Objects.requireNonNull(t9, "item9 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7, t8, t9);
}
public static <T> AbstractC13163fSk<T> just(T t, T t2, T t3, T t4, T t5, T t6, T t7, T t8, T t9, T t10) {
Objects.requireNonNull(t, "item1 is null");
Objects.requireNonNull(t2, "item2 is null");
Objects.requireNonNull(t3, "item3 is null");
Objects.requireNonNull(t4, "item4 is null");
Objects.requireNonNull(t5, "item5 is null");
Objects.requireNonNull(t6, "item6 is null");
Objects.requireNonNull(t7, "item7 is null");
Objects.requireNonNull(t8, "item8 is null");
Objects.requireNonNull(t9, "item9 is null");
Objects.requireNonNull(t10, "item10 is null");
return fromArray(t, t2, t3, t4, t5, t6, t7, t8, t9, t10);
}
public static <T> AbstractC13163fSk<T> merge(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, int i, int i2) {
return fromIterable(iterable).flatMap(C13194fTh.d(), false, i, i2);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> mergeArray(int i, int i2, InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return fromArray(interfaceC13169fSqArr).flatMap(C13194fTh.d(), false, i, i2);
}
public static <T> AbstractC13163fSk<T> merge(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable) {
return fromIterable(iterable).flatMap(C13194fTh.d());
}
public static <T> AbstractC13163fSk<T> merge(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, int i) {
return fromIterable(iterable).flatMap(C13194fTh.d(), i);
}
public static <T> AbstractC13163fSk<T> merge(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
return new fVQ(interfaceC13169fSq, C13194fTh.d(), false, Integer.MAX_VALUE, bufferSize());
}
public static <T> AbstractC13163fSk<T> merge(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
C13199fTm.c(i, "maxConcurrency");
return new fVQ(interfaceC13169fSq, C13194fTh.d(), false, i, bufferSize());
}
public static <T> AbstractC13163fSk<T> merge(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
return fromArray(interfaceC13169fSq, interfaceC13169fSq2).flatMap(C13194fTh.d(), false, 2);
}
public static <T> AbstractC13163fSk<T> merge(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, InterfaceC13169fSq<? extends T> interfaceC13169fSq3) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
return fromArray(interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3).flatMap(C13194fTh.d(), false, 3);
}
public static <T> AbstractC13163fSk<T> merge(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, InterfaceC13169fSq<? extends T> interfaceC13169fSq3, InterfaceC13169fSq<? extends T> interfaceC13169fSq4) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
return fromArray(interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4).flatMap(C13194fTh.d(), false, 4);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> mergeArray(InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return fromArray(interfaceC13169fSqArr).flatMap(C13194fTh.d(), interfaceC13169fSqArr.length);
}
public static <T> AbstractC13163fSk<T> mergeDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable) {
return fromIterable(iterable).flatMap(C13194fTh.d(), true);
}
public static <T> AbstractC13163fSk<T> mergeDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, int i, int i2) {
return fromIterable(iterable).flatMap(C13194fTh.d(), true, i, i2);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> mergeArrayDelayError(int i, int i2, InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return fromArray(interfaceC13169fSqArr).flatMap(C13194fTh.d(), true, i, i2);
}
public static <T> AbstractC13163fSk<T> mergeDelayError(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, int i) {
return fromIterable(iterable).flatMap(C13194fTh.d(), true, i);
}
public static <T> AbstractC13163fSk<T> mergeDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
return new fVQ(interfaceC13169fSq, C13194fTh.d(), true, Integer.MAX_VALUE, bufferSize());
}
public static <T> AbstractC13163fSk<T> mergeDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
C13199fTm.c(i, "maxConcurrency");
return new fVQ(interfaceC13169fSq, C13194fTh.d(), true, i, bufferSize());
}
public static <T> AbstractC13163fSk<T> mergeDelayError(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
return fromArray(interfaceC13169fSq, interfaceC13169fSq2).flatMap(C13194fTh.d(), true, 2);
}
public static <T> AbstractC13163fSk<T> mergeDelayError(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, InterfaceC13169fSq<? extends T> interfaceC13169fSq3) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
return fromArray(interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3).flatMap(C13194fTh.d(), true, 3);
}
public static <T> AbstractC13163fSk<T> mergeDelayError(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, InterfaceC13169fSq<? extends T> interfaceC13169fSq3, InterfaceC13169fSq<? extends T> interfaceC13169fSq4) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
return fromArray(interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4).flatMap(C13194fTh.d(), true, 4);
}
@SafeVarargs
public static <T> AbstractC13163fSk<T> mergeArrayDelayError(InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
return fromArray(interfaceC13169fSqArr).flatMap(C13194fTh.d(), true, interfaceC13169fSqArr.length);
}
public static <T> AbstractC13163fSk<T> never() {
return (AbstractC13163fSk<T>) fWB.b;
}
public static AbstractC13163fSk<Integer> range(int i, int i2) {
if (i2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(i2)));
}
if (i2 == 0) {
return empty();
}
if (i2 == 1) {
return just(Integer.valueOf(i));
}
if (i + (i2 - 1) > 2147483647L) {
throw new IllegalArgumentException("Integer overflow");
}
return new C13287fWO(i, i2);
}
public static AbstractC13163fSk<Long> rangeLong(long j, long j2) {
if (j2 < 0) {
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(j2)));
}
if (j2 == 0) {
return empty();
}
if (j2 == 1) {
return just(Long.valueOf(j));
}
if (j > 0 && (j2 - 1) + j < 0) {
throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
}
return new fWP(j, j2);
}
public static <T> AbstractC13175fSw<Boolean> sequenceEqual(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2) {
return sequenceEqual(interfaceC13169fSq, interfaceC13169fSq2, C13199fTm.e(), bufferSize());
}
public static <T> AbstractC13175fSw<Boolean> sequenceEqual(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, fSN<? super T, ? super T> fsn) {
return sequenceEqual(interfaceC13169fSq, interfaceC13169fSq2, fsn, bufferSize());
}
public static <T> AbstractC13175fSw<Boolean> sequenceEqual(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, fSN<? super T, ? super T> fsn, int i) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(fsn, "isEqual is null");
C13199fTm.c(i, "bufferSize");
return new C13334fXh(interfaceC13169fSq, interfaceC13169fSq2, fsn, i);
}
public static <T> AbstractC13175fSw<Boolean> sequenceEqual(InterfaceC13169fSq<? extends T> interfaceC13169fSq, InterfaceC13169fSq<? extends T> interfaceC13169fSq2, int i) {
return sequenceEqual(interfaceC13169fSq, interfaceC13169fSq2, C13199fTm.e(), i);
}
public static <T> AbstractC13163fSk<T> switchOnNext(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
C13199fTm.c(i, "bufferSize");
return new C13347fXu(interfaceC13169fSq, C13194fTh.d(), i, false);
}
public static <T> AbstractC13163fSk<T> switchOnNext(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
return switchOnNext(interfaceC13169fSq, bufferSize());
}
public static <T> AbstractC13163fSk<T> switchOnNextDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq) {
return switchOnNextDelayError(interfaceC13169fSq, bufferSize());
}
public static <T> AbstractC13163fSk<T> switchOnNextDelayError(InterfaceC13169fSq<? extends InterfaceC13169fSq<? extends T>> interfaceC13169fSq, int i) {
Objects.requireNonNull(interfaceC13169fSq, "sources is null");
C13199fTm.c(i, "bufferSize");
return new C13347fXu(interfaceC13169fSq, C13194fTh.d(), i, true);
}
public static AbstractC13163fSk<Long> timer(long j, TimeUnit timeUnit) {
return timer(j, timeUnit, C13417fZt.e());
}
public static AbstractC13163fSk<Long> timer(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fXB(Math.max(j, 0L), timeUnit, abstractC13173fSu);
}
public static <T> AbstractC13163fSk<T> unsafeCreate(InterfaceC13169fSq<T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "onSubscribe is null");
if (interfaceC13169fSq instanceof AbstractC13163fSk) {
throw new IllegalArgumentException("unsafeCreate(Observable) should be upgraded");
}
return new C13298fWg(interfaceC13169fSq);
}
public static <T, D> AbstractC13163fSk<T> using(InterfaceC13189fTc<? extends D> interfaceC13189fTc, fSS<? super D, ? extends InterfaceC13169fSq<? extends T>> fss, fSQ<? super D> fsq) {
return using(interfaceC13189fTc, fss, fsq, true);
}
public static <T, D> AbstractC13163fSk<T> using(InterfaceC13189fTc<? extends D> interfaceC13189fTc, fSS<? super D, ? extends InterfaceC13169fSq<? extends T>> fss, fSQ<? super D> fsq, boolean z) {
Objects.requireNonNull(interfaceC13189fTc, "resourceSupplier is null");
Objects.requireNonNull(fss, "sourceSupplier is null");
Objects.requireNonNull(fsq, "resourceCleanup is null");
return new fXI(interfaceC13189fTc, fss, fsq, z);
}
public static <T> AbstractC13163fSk<T> wrap(InterfaceC13169fSq<T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "source is null");
if (interfaceC13169fSq instanceof AbstractC13163fSk) {
return (AbstractC13163fSk) interfaceC13169fSq;
}
return new C13298fWg(interfaceC13169fSq);
}
public static <T, R> AbstractC13163fSk<R> zip(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, fSS<? super Object[], ? extends R> fss) {
Objects.requireNonNull(fss, "zipper is null");
Objects.requireNonNull(iterable, "sources is null");
return new C13323fXU(null, iterable, fss, bufferSize(), false);
}
public static <T, R> AbstractC13163fSk<R> zip(Iterable<? extends InterfaceC13169fSq<? extends T>> iterable, fSS<? super Object[], ? extends R> fss, boolean z, int i) {
Objects.requireNonNull(fss, "zipper is null");
Objects.requireNonNull(iterable, "sources is null");
C13199fTm.c(i, "bufferSize");
return new C13323fXU(null, iterable, fss, i, z);
}
public static <T1, T2, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, fSL<? super T1, ? super T2, ? extends R> fsl) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(fsl, "zipper is null");
return zipArray(C13194fTh.b(fsl), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2);
}
public static <T1, T2, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, fSL<? super T1, ? super T2, ? extends R> fsl, boolean z) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(fsl, "zipper is null");
return zipArray(C13194fTh.b(fsl), z, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2);
}
public static <T1, T2, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, fSL<? super T1, ? super T2, ? extends R> fsl, boolean z, int i) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(fsl, "zipper is null");
return zipArray(C13194fTh.b(fsl), z, i, interfaceC13169fSq, interfaceC13169fSq2);
}
public static <T1, T2, T3, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13150fSU<? super T1, ? super T2, ? super T3, ? extends R> interfaceC13150fSU) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13150fSU, "zipper is null");
return zipArray(C13194fTh.c((InterfaceC13150fSU) interfaceC13150fSU), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3);
}
public static <T1, T2, T3, T4, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, fST<? super T1, ? super T2, ? super T3, ? super T4, ? extends R> fst) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(fst, "zipper is null");
return zipArray(C13194fTh.b(fst), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4);
}
public static <T1, T2, T3, T4, T5, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13151fSX<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? extends R> interfaceC13151fSX) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13151fSX, "zipper is null");
return zipArray(C13194fTh.e(interfaceC13151fSX), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5);
}
public static <T1, T2, T3, T4, T5, T6, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13187fTa<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? extends R> interfaceC13187fTa) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13187fTa, "zipper is null");
return zipArray(C13194fTh.a((InterfaceC13187fTa) interfaceC13187fTa), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6);
}
public static <T1, T2, T3, T4, T5, T6, T7, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13169fSq<? extends T7> interfaceC13169fSq7, fSZ<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? extends R> fsz) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13169fSq7, "source7 is null");
Objects.requireNonNull(fsz, "zipper is null");
return zipArray(C13194fTh.a((fSZ) fsz), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6, interfaceC13169fSq7);
}
public static <T1, T2, T3, T4, T5, T6, T7, T8, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13169fSq<? extends T7> interfaceC13169fSq7, InterfaceC13169fSq<? extends T8> interfaceC13169fSq8, fSW<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? extends R> fsw) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13169fSq7, "source7 is null");
Objects.requireNonNull(interfaceC13169fSq8, "source8 is null");
Objects.requireNonNull(fsw, "zipper is null");
return zipArray(C13194fTh.b(fsw), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6, interfaceC13169fSq7, interfaceC13169fSq8);
}
public static <T1, T2, T3, T4, T5, T6, T7, T8, T9, R> AbstractC13163fSk<R> zip(InterfaceC13169fSq<? extends T1> interfaceC13169fSq, InterfaceC13169fSq<? extends T2> interfaceC13169fSq2, InterfaceC13169fSq<? extends T3> interfaceC13169fSq3, InterfaceC13169fSq<? extends T4> interfaceC13169fSq4, InterfaceC13169fSq<? extends T5> interfaceC13169fSq5, InterfaceC13169fSq<? extends T6> interfaceC13169fSq6, InterfaceC13169fSq<? extends T7> interfaceC13169fSq7, InterfaceC13169fSq<? extends T8> interfaceC13169fSq8, InterfaceC13169fSq<? extends T9> interfaceC13169fSq9, fSV<? super T1, ? super T2, ? super T3, ? super T4, ? super T5, ? super T6, ? super T7, ? super T8, ? super T9, ? extends R> fsv) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13169fSq5, "source5 is null");
Objects.requireNonNull(interfaceC13169fSq6, "source6 is null");
Objects.requireNonNull(interfaceC13169fSq7, "source7 is null");
Objects.requireNonNull(interfaceC13169fSq8, "source8 is null");
Objects.requireNonNull(interfaceC13169fSq9, "source9 is null");
Objects.requireNonNull(fsv, "zipper is null");
return zipArray(C13194fTh.b(fsv), false, bufferSize(), interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4, interfaceC13169fSq5, interfaceC13169fSq6, interfaceC13169fSq7, interfaceC13169fSq8, interfaceC13169fSq9);
}
@SafeVarargs
public static <T, R> AbstractC13163fSk<R> zipArray(fSS<? super Object[], ? extends R> fss, boolean z, int i, InterfaceC13169fSq<? extends T>... interfaceC13169fSqArr) {
Objects.requireNonNull(interfaceC13169fSqArr, "sources is null");
if (interfaceC13169fSqArr.length == 0) {
return empty();
}
Objects.requireNonNull(fss, "zipper is null");
C13199fTm.c(i, "bufferSize");
return new C13323fXU(interfaceC13169fSqArr, null, fss, i, z);
}
public final AbstractC13175fSw<Boolean> all(InterfaceC13193fTg<? super T> interfaceC13193fTg) {
Objects.requireNonNull(interfaceC13193fTg, "predicate is null");
return new C13259fVc(this, interfaceC13193fTg);
}
public final AbstractC13163fSk<T> ambWith(InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return ambArray(this, interfaceC13169fSq);
}
public final AbstractC13175fSw<Boolean> any(InterfaceC13193fTg<? super T> interfaceC13193fTg) {
Objects.requireNonNull(interfaceC13193fTg, "predicate is null");
return new C13262fVf(this, interfaceC13193fTg);
}
public final T blockingFirst() {
fTK ftk = new fTK();
subscribe(ftk);
T e = ftk.e();
if (e != null) {
return e;
}
throw new NoSuchElementException();
}
public final T blockingFirst(T t) {
Objects.requireNonNull(t, "defaultItem is null");
fTK ftk = new fTK();
subscribe(ftk);
T e = ftk.e();
return e != null ? e : t;
}
public final void blockingForEach(fSQ<? super T> fsq) {
blockingForEach(fsq, bufferSize());
}
public final void blockingForEach(fSQ<? super T> fsq, int i) {
Objects.requireNonNull(fsq, "onNext is null");
Iterator<T> it = blockingIterable(i).iterator();
while (it.hasNext()) {
try {
fsq.c(it.next());
} catch (Throwable th) {
C13147fSI.c(th);
((fSJ) it).dispose();
throw fYR.c(th);
}
}
}
public final Iterable<T> blockingIterable() {
return blockingIterable(bufferSize());
}
public final Iterable<T> blockingIterable(int i) {
C13199fTm.c(i, "capacityHint");
return new fUW(this, i);
}
public final T blockingLast() {
fTG ftg = new fTG();
subscribe(ftg);
T e = ftg.e();
if (e != null) {
return e;
}
throw new NoSuchElementException();
}
public final T blockingLast(T t) {
Objects.requireNonNull(t, "defaultItem is null");
fTG ftg = new fTG();
subscribe(ftg);
T e = ftg.e();
return e != null ? e : t;
}
public final Iterable<T> blockingLatest() {
return new C13221fUU(this);
}
public final Iterable<T> blockingMostRecent(T t) {
Objects.requireNonNull(t, "initialItem is null");
return new C13220fUT(this, t);
}
public final Iterable<T> blockingNext() {
return new C13258fVb(this);
}
public final T blockingSingle() {
T a = singleElement().a();
if (a != null) {
return a;
}
throw new NoSuchElementException();
}
public final T blockingSingle(T t) {
AbstractC13175fSw<T> single = single(t);
fTM ftm = new fTM();
single.c(ftm);
return (T) ftm.d();
}
public final Future<T> toFuture() {
return (Future) subscribeWith(new FutureC13185fTT());
}
public final void blockingSubscribe(fSQ<? super T> fsq) {
C13261fVe.b(this, fsq, C13194fTh.a, C13194fTh.c);
}
public final void blockingSubscribe(fSQ<? super T> fsq, fSQ<? super Throwable> fsq2) {
C13261fVe.b(this, fsq, fsq2, C13194fTh.c);
}
public final void blockingSubscribe(fSQ<? super T> fsq, fSQ<? super Throwable> fsq2, fSP fsp) {
C13261fVe.b(this, fsq, fsq2, fsp);
}
public final void blockingSubscribe(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
Objects.requireNonNull(interfaceC13174fSv, "observer is null");
C13261fVe.a(this, interfaceC13174fSv);
}
public final AbstractC13163fSk<List<T>> buffer(int i) {
return buffer(i, i);
}
public final AbstractC13163fSk<List<T>> buffer(int i, int i2) {
return (AbstractC13163fSk<List<T>>) buffer(i, i2, EnumC13354fYH.c());
}
public final <U extends Collection<? super T>> AbstractC13163fSk<U> buffer(int i, int i2, InterfaceC13189fTc<U> interfaceC13189fTc) {
C13199fTm.c(i, "count");
C13199fTm.c(i2, "skip");
Objects.requireNonNull(interfaceC13189fTc, "bufferSupplier is null");
return new C13265fVi(this, i, i2, interfaceC13189fTc);
}
public final <U extends Collection<? super T>> AbstractC13163fSk<U> buffer(int i, InterfaceC13189fTc<U> interfaceC13189fTc) {
return buffer(i, i, interfaceC13189fTc);
}
public final AbstractC13163fSk<List<T>> buffer(long j, long j2, TimeUnit timeUnit) {
return (AbstractC13163fSk<List<T>>) buffer(j, j2, timeUnit, C13417fZt.e(), EnumC13354fYH.c());
}
public final AbstractC13163fSk<List<T>> buffer(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return (AbstractC13163fSk<List<T>>) buffer(j, j2, timeUnit, abstractC13173fSu, EnumC13354fYH.c());
}
public final <U extends Collection<? super T>> AbstractC13163fSk<U> buffer(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, InterfaceC13189fTc<U> interfaceC13189fTc) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(interfaceC13189fTc, "bufferSupplier is null");
return new C13270fVn(this, j, j2, timeUnit, abstractC13173fSu, interfaceC13189fTc, Integer.MAX_VALUE, false);
}
public final AbstractC13163fSk<List<T>> buffer(long j, TimeUnit timeUnit) {
return buffer(j, timeUnit, C13417fZt.e(), Integer.MAX_VALUE);
}
public final AbstractC13163fSk<List<T>> buffer(long j, TimeUnit timeUnit, int i) {
return buffer(j, timeUnit, C13417fZt.e(), i);
}
public final AbstractC13163fSk<List<T>> buffer(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, int i) {
return (AbstractC13163fSk<List<T>>) buffer(j, timeUnit, abstractC13173fSu, i, EnumC13354fYH.c(), false);
}
public final <U extends Collection<? super T>> AbstractC13163fSk<U> buffer(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, int i, InterfaceC13189fTc<U> interfaceC13189fTc, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(interfaceC13189fTc, "bufferSupplier is null");
C13199fTm.c(i, "count");
return new C13270fVn(this, j, j, timeUnit, abstractC13173fSu, interfaceC13189fTc, i, z);
}
public final AbstractC13163fSk<List<T>> buffer(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return (AbstractC13163fSk<List<T>>) buffer(j, timeUnit, abstractC13173fSu, Integer.MAX_VALUE, EnumC13354fYH.c(), false);
}
public final <TOpening, TClosing> AbstractC13163fSk<List<T>> buffer(InterfaceC13169fSq<? extends TOpening> interfaceC13169fSq, fSS<? super TOpening, ? extends InterfaceC13169fSq<? extends TClosing>> fss) {
return (AbstractC13163fSk<List<T>>) buffer(interfaceC13169fSq, fss, EnumC13354fYH.c());
}
public final <TOpening, TClosing, U extends Collection<? super T>> AbstractC13163fSk<U> buffer(InterfaceC13169fSq<? extends TOpening> interfaceC13169fSq, fSS<? super TOpening, ? extends InterfaceC13169fSq<? extends TClosing>> fss, InterfaceC13189fTc<U> interfaceC13189fTc) {
Objects.requireNonNull(interfaceC13169fSq, "openingIndicator is null");
Objects.requireNonNull(fss, "closingIndicator is null");
Objects.requireNonNull(interfaceC13189fTc, "bufferSupplier is null");
return new C13263fVg(this, interfaceC13169fSq, fss, interfaceC13189fTc);
}
public final <B> AbstractC13163fSk<List<T>> buffer(InterfaceC13169fSq<B> interfaceC13169fSq) {
return (AbstractC13163fSk<List<T>>) buffer(interfaceC13169fSq, EnumC13354fYH.c());
}
public final <B> AbstractC13163fSk<List<T>> buffer(InterfaceC13169fSq<B> interfaceC13169fSq, int i) {
C13199fTm.c(i, "initialCapacity");
return (AbstractC13163fSk<List<T>>) buffer(interfaceC13169fSq, C13194fTh.b(i));
}
public final <B, U extends Collection<? super T>> AbstractC13163fSk<U> buffer(InterfaceC13169fSq<B> interfaceC13169fSq, InterfaceC13189fTc<U> interfaceC13189fTc) {
Objects.requireNonNull(interfaceC13169fSq, "boundaryIndicator is null");
Objects.requireNonNull(interfaceC13189fTc, "bufferSupplier is null");
return new C13266fVj(this, interfaceC13169fSq, interfaceC13189fTc);
}
public final AbstractC13163fSk<T> cache() {
return cacheWithInitialCapacity(16);
}
public final AbstractC13163fSk<T> cacheWithInitialCapacity(int i) {
C13199fTm.c(i, "initialCapacity");
return new C13271fVo(this, i);
}
public final <U> AbstractC13163fSk<U> cast(Class<U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return (AbstractC13163fSk<U>) map(C13194fTh.a((Class) cls));
}
public final <U> AbstractC13175fSw<U> collect(InterfaceC13189fTc<? extends U> interfaceC13189fTc, fSK<? super U, ? super T> fsk) {
Objects.requireNonNull(interfaceC13189fTc, "initialItemSupplier is null");
Objects.requireNonNull(fsk, "collector is null");
return new C13268fVl(this, interfaceC13189fTc, fsk);
}
public final <U> AbstractC13175fSw<U> collectInto(U u, fSK<? super U, ? super T> fsk) {
Objects.requireNonNull(u, "initialItem is null");
return collect(C13194fTh.a(u), fsk);
}
public final <R> AbstractC13163fSk<R> compose(InterfaceC13171fSs<? super T, ? extends R> interfaceC13171fSs) {
return wrap(((InterfaceC13171fSs) Objects.requireNonNull(interfaceC13171fSs, "composer is null")).d(this));
}
public final <R> AbstractC13163fSk<R> concatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss) {
return concatMap(fss, 2);
}
/* JADX WARN: Multi-variable type inference failed */
public final <R> AbstractC13163fSk<R> concatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
if (this instanceof InterfaceC13409fZl) {
Object d = ((InterfaceC13409fZl) this).d();
if (d == null) {
return empty();
}
return new C13328fXb.IeS(d, fss);
}
return new C13274fVr(this, fss, i, EnumC13357fYN.IMMEDIATE);
}
public final <R> AbstractC13163fSk<R> concatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, int i, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new C13275fVs(this, fss, i, EnumC13357fYN.IMMEDIATE, abstractC13173fSu);
}
public final <R> AbstractC13163fSk<R> concatMapDelayError(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss) {
return concatMapDelayError(fss, true, bufferSize());
}
/* JADX WARN: Multi-variable type inference failed */
public final <R> AbstractC13163fSk<R> concatMapDelayError(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, boolean z, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
if (!(this instanceof InterfaceC13409fZl)) {
return new C13274fVr(this, fss, i, z ? EnumC13357fYN.END : EnumC13357fYN.BOUNDARY);
}
Object d = ((InterfaceC13409fZl) this).d();
if (d == null) {
return empty();
}
return new C13328fXb.IeS(d, fss);
}
public final <R> AbstractC13163fSk<R> concatMapDelayError(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, boolean z, int i, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new C13275fVs(this, fss, i, z ? EnumC13357fYN.END : EnumC13357fYN.BOUNDARY, abstractC13173fSu);
}
public final <R> AbstractC13163fSk<R> concatMapEager(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss) {
return concatMapEager(fss, Integer.MAX_VALUE, bufferSize());
}
public final <R> AbstractC13163fSk<R> concatMapEager(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, int i, int i2) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "maxConcurrency");
C13199fTm.c(i2, "bufferSize");
return new C13273fVq(this, fss, EnumC13357fYN.IMMEDIATE, i, i2);
}
public final <R> AbstractC13163fSk<R> concatMapEagerDelayError(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, boolean z) {
return concatMapEagerDelayError(fss, z, Integer.MAX_VALUE, bufferSize());
}
public final <R> AbstractC13163fSk<R> concatMapEagerDelayError(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, boolean z, int i, int i2) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "maxConcurrency");
C13199fTm.c(i2, "bufferSize");
return new C13273fVq(this, fss, z ? EnumC13357fYN.END : EnumC13357fYN.BOUNDARY, i, i2);
}
public final fRY concatMapCompletable(fSS<? super T, ? extends fRZ> fss) {
return concatMapCompletable(fss, 2);
}
public final fRY concatMapCompletable(fSS<? super T, ? extends fRZ> fss, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "capacityHint");
return new fUL(this, fss, EnumC13357fYN.IMMEDIATE, i);
}
public final fRY concatMapCompletableDelayError(fSS<? super T, ? extends fRZ> fss) {
return concatMapCompletableDelayError(fss, true, 2);
}
public final fRY concatMapCompletableDelayError(fSS<? super T, ? extends fRZ> fss, boolean z) {
return concatMapCompletableDelayError(fss, z, 2);
}
public final fRY concatMapCompletableDelayError(fSS<? super T, ? extends fRZ> fss, boolean z, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
return new fUL(this, fss, z ? EnumC13357fYN.END : EnumC13357fYN.BOUNDARY, i);
}
public final <U> AbstractC13163fSk<U> concatMapIterable(fSS<? super T, ? extends Iterable<? extends U>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13292fWa(this, fss);
}
public final <R> AbstractC13163fSk<R> concatMapMaybe(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss) {
return concatMapMaybe(fss, 2);
}
public final <R> AbstractC13163fSk<R> concatMapMaybe(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
return new fUI(this, fss, EnumC13357fYN.IMMEDIATE, i);
}
public final <R> AbstractC13163fSk<R> concatMapMaybeDelayError(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss) {
return concatMapMaybeDelayError(fss, true, 2);
}
public final <R> AbstractC13163fSk<R> concatMapMaybeDelayError(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss, boolean z) {
return concatMapMaybeDelayError(fss, z, 2);
}
public final <R> AbstractC13163fSk<R> concatMapMaybeDelayError(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss, boolean z, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
return new fUI(this, fss, z ? EnumC13357fYN.END : EnumC13357fYN.BOUNDARY, i);
}
public final <R> AbstractC13163fSk<R> concatMapSingle(fSS<? super T, ? extends fSD<? extends R>> fss) {
return concatMapSingle(fss, 2);
}
public final <R> AbstractC13163fSk<R> concatMapSingle(fSS<? super T, ? extends fSD<? extends R>> fss, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
return new C13216fUN(this, fss, EnumC13357fYN.IMMEDIATE, i);
}
public final <R> AbstractC13163fSk<R> concatMapSingleDelayError(fSS<? super T, ? extends fSD<? extends R>> fss) {
return concatMapSingleDelayError(fss, true, 2);
}
public final <R> AbstractC13163fSk<R> concatMapSingleDelayError(fSS<? super T, ? extends fSD<? extends R>> fss, boolean z) {
return concatMapSingleDelayError(fss, z, 2);
}
public final <R> AbstractC13163fSk<R> concatMapSingleDelayError(fSS<? super T, ? extends fSD<? extends R>> fss, boolean z, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
return new C13216fUN(this, fss, z ? EnumC13357fYN.END : EnumC13357fYN.BOUNDARY, i);
}
public final AbstractC13163fSk<T> concatWith(InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return concat(this, interfaceC13169fSq);
}
public final AbstractC13163fSk<T> concatWith(fSD<? extends T> fsd) {
Objects.requireNonNull(fsd, "other is null");
return new C13277fVu(this, fsd);
}
public final AbstractC13163fSk<T> concatWith(InterfaceC13160fSh<? extends T> interfaceC13160fSh) {
Objects.requireNonNull(interfaceC13160fSh, "other is null");
return new C13276fVt(this, interfaceC13160fSh);
}
public final AbstractC13163fSk<T> concatWith(fRZ frz) {
Objects.requireNonNull(frz, "other is null");
return new C13272fVp(this, frz);
}
public final AbstractC13175fSw<Boolean> contains(Object obj) {
Objects.requireNonNull(obj, "item is null");
return any(C13194fTh.d(obj));
}
public final AbstractC13175fSw<Long> count() {
return new C13281fVy(this);
}
public final <U> AbstractC13163fSk<T> debounce(fSS<? super T, ? extends InterfaceC13169fSq<U>> fss) {
Objects.requireNonNull(fss, "debounceIndicator is null");
return new C13278fVv(this, fss);
}
public final AbstractC13163fSk<T> debounce(long j, TimeUnit timeUnit) {
return debounce(j, timeUnit, C13417fZt.e());
}
public final AbstractC13163fSk<T> debounce(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fVD(this, j, timeUnit, abstractC13173fSu, null);
}
public final AbstractC13163fSk<T> debounce(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, fSQ<? super T> fsq) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(fsq, "onDropped is null");
return new fVD(this, j, timeUnit, abstractC13173fSu, fsq);
}
public final AbstractC13163fSk<T> defaultIfEmpty(T t) {
Objects.requireNonNull(t, "defaultItem is null");
return switchIfEmpty(just(t));
}
public final <U> AbstractC13163fSk<T> delay(fSS<? super T, ? extends InterfaceC13169fSq<U>> fss) {
Objects.requireNonNull(fss, "itemDelayIndicator is null");
return (AbstractC13163fSk<T>) flatMap(new C13309fWr.saX(fss));
}
public final AbstractC13163fSk<T> delay(long j, TimeUnit timeUnit) {
return delay(j, timeUnit, C13417fZt.e(), false);
}
public final AbstractC13163fSk<T> delay(long j, TimeUnit timeUnit, boolean z) {
return delay(j, timeUnit, C13417fZt.e(), z);
}
public final AbstractC13163fSk<T> delay(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return delay(j, timeUnit, abstractC13173fSu, false);
}
public final AbstractC13163fSk<T> delay(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new C13251fVE(this, j, timeUnit, abstractC13173fSu, z);
}
/* JADX WARN: Multi-variable type inference failed */
public final <U, V> AbstractC13163fSk<T> delay(InterfaceC13169fSq<U> interfaceC13169fSq, fSS<? super T, ? extends InterfaceC13169fSq<V>> fss) {
return delaySubscription(interfaceC13169fSq).delay(fss);
}
public final <U> AbstractC13163fSk<T> delaySubscription(InterfaceC13169fSq<U> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "subscriptionIndicator is null");
return new C13250fVB(this, interfaceC13169fSq);
}
public final AbstractC13163fSk<T> delaySubscription(long j, TimeUnit timeUnit) {
return delaySubscription(j, timeUnit, C13417fZt.e());
}
public final AbstractC13163fSk<T> delaySubscription(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return delaySubscription(timer(j, timeUnit, abstractC13173fSu));
}
public final <R> AbstractC13163fSk<R> dematerialize(fSS<? super T, C13166fSn<R>> fss) {
Objects.requireNonNull(fss, "selector is null");
return new C13249fVA(this, fss);
}
public final AbstractC13163fSk<T> distinct() {
return distinct(C13194fTh.d(), C13194fTh.a());
}
public final <K> AbstractC13163fSk<T> distinct(fSS<? super T, K> fss) {
return distinct(fss, C13194fTh.a());
}
public final <K> AbstractC13163fSk<T> distinct(fSS<? super T, K> fss, InterfaceC13189fTc<? extends Collection<? super K>> interfaceC13189fTc) {
Objects.requireNonNull(fss, "keySelector is null");
Objects.requireNonNull(interfaceC13189fTc, "collectionSupplier is null");
return new fVH(this, fss, interfaceC13189fTc);
}
public final AbstractC13163fSk<T> distinctUntilChanged() {
return distinctUntilChanged(C13194fTh.d());
}
public final <K> AbstractC13163fSk<T> distinctUntilChanged(fSS<? super T, K> fss) {
Objects.requireNonNull(fss, "keySelector is null");
return new fVI(this, fss, C13199fTm.e());
}
public final AbstractC13163fSk<T> distinctUntilChanged(fSN<? super T, ? super T> fsn) {
Objects.requireNonNull(fsn, "comparer is null");
return new fVI(this, C13194fTh.d(), fsn);
}
public final AbstractC13163fSk<T> doAfterNext(fSQ<? super T> fsq) {
Objects.requireNonNull(fsq, "onAfterNext is null");
return new fVJ(this, fsq);
}
public final AbstractC13163fSk<T> doAfterTerminate(fSP fsp) {
Objects.requireNonNull(fsp, "onAfterTerminate is null");
return doOnEach(C13194fTh.c(), C13194fTh.c(), C13194fTh.c, fsp);
}
public final AbstractC13163fSk<T> doFinally(fSP fsp) {
Objects.requireNonNull(fsp, "onFinally is null");
return new C13252fVK(this, fsp);
}
public final AbstractC13163fSk<T> doOnDispose(fSP fsp) {
return doOnLifecycle(C13194fTh.c(), fsp);
}
public final AbstractC13163fSk<T> doOnComplete(fSP fsp) {
return doOnEach(C13194fTh.c(), C13194fTh.c(), fsp, C13194fTh.c);
}
private AbstractC13163fSk<T> doOnEach(fSQ<? super T> fsq, fSQ<? super Throwable> fsq2, fSP fsp, fSP fsp2) {
Objects.requireNonNull(fsq, "onNext is null");
Objects.requireNonNull(fsq2, "onError is null");
Objects.requireNonNull(fsp, "onComplete is null");
Objects.requireNonNull(fsp2, "onAfterTerminate is null");
return new fVN(this, fsq, fsq2, fsp, fsp2);
}
public final AbstractC13163fSk<T> doOnEach(fSQ<? super C13166fSn<T>> fsq) {
Objects.requireNonNull(fsq, "onNotification is null");
return doOnEach(C13194fTh.c((fSQ) fsq), C13194fTh.b(fsq), C13194fTh.d((fSQ) fsq), C13194fTh.c);
}
public final AbstractC13163fSk<T> doOnEach(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
Objects.requireNonNull(interfaceC13174fSv, "observer is null");
return doOnEach(new C13309fWr.jbe(interfaceC13174fSv), new C13309fWr.ojQ(interfaceC13174fSv), new C13309fWr.ZqN(interfaceC13174fSv), C13194fTh.c);
}
public final AbstractC13163fSk<T> doOnError(fSQ<? super Throwable> fsq) {
fSQ<? super T> c = C13194fTh.c();
fSP fsp = C13194fTh.c;
return doOnEach(c, fsq, fsp, fsp);
}
public final AbstractC13163fSk<T> doOnLifecycle(fSQ<? super fSJ> fsq, fSP fsp) {
Objects.requireNonNull(fsq, "onSubscribe is null");
Objects.requireNonNull(fsp, "onDispose is null");
return new C13253fVP(this, fsq, fsp);
}
public final AbstractC13163fSk<T> doOnNext(fSQ<? super T> fsq) {
fSQ<? super Throwable> c = C13194fTh.c();
fSP fsp = C13194fTh.c;
return doOnEach(fsq, c, fsp, fsp);
}
public final AbstractC13163fSk<T> doOnSubscribe(fSQ<? super fSJ> fsq) {
return doOnLifecycle(fsq, C13194fTh.c);
}
public final AbstractC13163fSk<T> doOnTerminate(fSP fsp) {
Objects.requireNonNull(fsp, "onTerminate is null");
return doOnEach(C13194fTh.c(), C13194fTh.b(fsp), fsp, C13194fTh.c);
}
public final AbstractC13159fSg<T> elementAt(long j) {
if (j < 0) {
throw new IndexOutOfBoundsException("index >= 0 required but it was ".concat(String.valueOf(j)));
}
return new fVO(this, j);
}
public final AbstractC13175fSw<T> elementAt(long j, T t) {
if (j < 0) {
throw new IndexOutOfBoundsException("index >= 0 required but it was ".concat(String.valueOf(j)));
}
Objects.requireNonNull(t, "defaultItem is null");
return new fVM(this, j, t);
}
public final AbstractC13175fSw<T> elementAtOrError(long j) {
if (j < 0) {
throw new IndexOutOfBoundsException("index >= 0 required but it was ".concat(String.valueOf(j)));
}
return new fVM(this, j, null);
}
public final AbstractC13163fSk<T> filter(InterfaceC13193fTg<? super T> interfaceC13193fTg) {
Objects.requireNonNull(interfaceC13193fTg, "predicate is null");
return new fVS(this, interfaceC13193fTg);
}
public final AbstractC13159fSg<T> firstElement() {
return elementAt(0L);
}
public final AbstractC13175fSw<T> first(T t) {
return elementAt(0L, t);
}
public final AbstractC13175fSw<T> firstOrError() {
return elementAtOrError(0L);
}
public final <R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss) {
return flatMap((fSS) fss, false);
}
public final <R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, boolean z) {
return flatMap(fss, z, Integer.MAX_VALUE);
}
public final <R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, boolean z, int i) {
return flatMap(fss, z, i, bufferSize());
}
/* JADX WARN: Multi-variable type inference failed */
public final <R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, boolean z, int i, int i2) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "maxConcurrency");
C13199fTm.c(i2, "bufferSize");
if (this instanceof InterfaceC13409fZl) {
Object d = ((InterfaceC13409fZl) this).d();
if (d == null) {
return empty();
}
return new C13328fXb.IeS(d, fss);
}
return new fVQ(this, fss, z, i, i2);
}
public final <R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, fSS<? super Throwable, ? extends InterfaceC13169fSq<? extends R>> fss2, InterfaceC13189fTc<? extends InterfaceC13169fSq<? extends R>> interfaceC13189fTc) {
Objects.requireNonNull(fss, "onNextMapper is null");
Objects.requireNonNull(fss2, "onErrorMapper is null");
Objects.requireNonNull(interfaceC13189fTc, "onCompleteSupplier is null");
return merge(new C13313fWv(this, fss, fss2, interfaceC13189fTc));
}
public final <R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, fSS<Throwable, ? extends InterfaceC13169fSq<? extends R>> fss2, InterfaceC13189fTc<? extends InterfaceC13169fSq<? extends R>> interfaceC13189fTc, int i) {
Objects.requireNonNull(fss, "onNextMapper is null");
Objects.requireNonNull(fss2, "onErrorMapper is null");
Objects.requireNonNull(interfaceC13189fTc, "onCompleteSupplier is null");
return merge(new C13313fWv(this, fss, fss2, interfaceC13189fTc), i);
}
public final <R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, int i) {
return flatMap((fSS) fss, false, i, bufferSize());
}
public final <U, R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends U>> fss, fSL<? super T, ? super U, ? extends R> fsl) {
return flatMap(fss, fsl, false, bufferSize(), bufferSize());
}
public final <U, R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends U>> fss, fSL<? super T, ? super U, ? extends R> fsl, boolean z) {
return flatMap(fss, fsl, z, bufferSize(), bufferSize());
}
public final <U, R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends U>> fss, fSL<? super T, ? super U, ? extends R> fsl, boolean z, int i) {
return flatMap(fss, fsl, z, i, bufferSize());
}
public final <U, R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends U>> fss, fSL<? super T, ? super U, ? extends R> fsl, boolean z, int i, int i2) {
Objects.requireNonNull(fss, "mapper is null");
Objects.requireNonNull(fsl, "combiner is null");
return flatMap(new C13309fWr.Sts(fsl, fss), z, i, i2);
}
public final <U, R> AbstractC13163fSk<R> flatMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends U>> fss, fSL<? super T, ? super U, ? extends R> fsl, int i) {
return flatMap(fss, fsl, false, i, bufferSize());
}
public final fRY flatMapCompletable(fSS<? super T, ? extends fRZ> fss) {
return flatMapCompletable(fss, false);
}
public final fRY flatMapCompletable(fSS<? super T, ? extends fRZ> fss, boolean z) {
Objects.requireNonNull(fss, "mapper is null");
return new fVY(this, fss, z);
}
public final <U> AbstractC13163fSk<U> flatMapIterable(fSS<? super T, ? extends Iterable<? extends U>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13292fWa(this, fss);
}
/* JADX WARN: Multi-variable type inference failed */
public final <U, V> AbstractC13163fSk<V> flatMapIterable(fSS<? super T, ? extends Iterable<? extends U>> fss, fSL<? super T, ? super U, ? extends V> fsl) {
Objects.requireNonNull(fss, "mapper is null");
Objects.requireNonNull(fsl, "combiner is null");
return (AbstractC13163fSk<V>) flatMap(new C13309fWr.IeS(fss), fsl, false, bufferSize(), bufferSize());
}
public final <R> AbstractC13163fSk<R> flatMapMaybe(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss) {
return flatMapMaybe(fss, false);
}
public final <R> AbstractC13163fSk<R> flatMapMaybe(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss, boolean z) {
Objects.requireNonNull(fss, "mapper is null");
return new fVW(this, fss, z);
}
public final <R> AbstractC13163fSk<R> flatMapSingle(fSS<? super T, ? extends fSD<? extends R>> fss) {
return flatMapSingle(fss, false);
}
public final <R> AbstractC13163fSk<R> flatMapSingle(fSS<? super T, ? extends fSD<? extends R>> fss, boolean z) {
Objects.requireNonNull(fss, "mapper is null");
return new fVV(this, fss, z);
}
public final fSJ forEach(fSQ<? super T> fsq) {
return subscribe(fsq);
}
public final fSJ forEachWhile(InterfaceC13193fTg<? super T> interfaceC13193fTg) {
return forEachWhile(interfaceC13193fTg, C13194fTh.a, C13194fTh.c);
}
public final fSJ forEachWhile(InterfaceC13193fTg<? super T> interfaceC13193fTg, fSQ<? super Throwable> fsq) {
return forEachWhile(interfaceC13193fTg, fsq, C13194fTh.c);
}
public final fSJ forEachWhile(InterfaceC13193fTg<? super T> interfaceC13193fTg, fSQ<? super Throwable> fsq, fSP fsp) {
Objects.requireNonNull(interfaceC13193fTg, "onNext is null");
Objects.requireNonNull(fsq, "onError is null");
Objects.requireNonNull(fsp, "onComplete is null");
fTU ftu = new fTU(interfaceC13193fTg, fsq, fsp);
subscribe(ftu);
return ftu;
}
public final <K> AbstractC13163fSk<AbstractC13399fZb<K, T>> groupBy(fSS<? super T, ? extends K> fss) {
return (AbstractC13163fSk<AbstractC13399fZb<K, T>>) groupBy(fss, C13194fTh.d(), false, bufferSize());
}
public final <K> AbstractC13163fSk<AbstractC13399fZb<K, T>> groupBy(fSS<? super T, ? extends K> fss, boolean z) {
return (AbstractC13163fSk<AbstractC13399fZb<K, T>>) groupBy(fss, C13194fTh.d(), z, bufferSize());
}
public final <K, V> AbstractC13163fSk<AbstractC13399fZb<K, V>> groupBy(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2) {
return groupBy(fss, fss2, false, bufferSize());
}
public final <K, V> AbstractC13163fSk<AbstractC13399fZb<K, V>> groupBy(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2, boolean z) {
return groupBy(fss, fss2, z, bufferSize());
}
public final <K, V> AbstractC13163fSk<AbstractC13399fZb<K, V>> groupBy(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2, boolean z, int i) {
Objects.requireNonNull(fss, "keySelector is null");
Objects.requireNonNull(fss2, "valueSelector is null");
C13199fTm.c(i, "bufferSize");
return new C13306fWo(this, fss, fss2, i, z);
}
public final <TRight, TLeftEnd, TRightEnd, R> AbstractC13163fSk<R> groupJoin(InterfaceC13169fSq<? extends TRight> interfaceC13169fSq, fSS<? super T, ? extends InterfaceC13169fSq<TLeftEnd>> fss, fSS<? super TRight, ? extends InterfaceC13169fSq<TRightEnd>> fss2, fSL<? super T, ? super AbstractC13163fSk<TRight>, ? extends R> fsl) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
Objects.requireNonNull(fss, "leftEnd is null");
Objects.requireNonNull(fss2, "rightEnd is null");
Objects.requireNonNull(fsl, "resultSelector is null");
return new C13303fWl(this, interfaceC13169fSq, fss, fss2, fsl);
}
public final AbstractC13163fSk<T> hide() {
return new C13304fWm(this);
}
public final fRY ignoreElements() {
return new C13307fWp(this);
}
public final AbstractC13175fSw<Boolean> isEmpty() {
return all(C13194fTh.e());
}
public final <TRight, TLeftEnd, TRightEnd, R> AbstractC13163fSk<R> join(InterfaceC13169fSq<? extends TRight> interfaceC13169fSq, fSS<? super T, ? extends InterfaceC13169fSq<TLeftEnd>> fss, fSS<? super TRight, ? extends InterfaceC13169fSq<TRightEnd>> fss2, fSL<? super T, ? super TRight, ? extends R> fsl) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
Objects.requireNonNull(fss, "leftEnd is null");
Objects.requireNonNull(fss2, "rightEnd is null");
Objects.requireNonNull(fsl, "resultSelector is null");
return new C13311fWt(this, interfaceC13169fSq, fss, fss2, fsl);
}
public final AbstractC13159fSg<T> lastElement() {
return new C13315fWx(this);
}
public final AbstractC13175fSw<T> last(T t) {
Objects.requireNonNull(t, "defaultItem is null");
return new C13317fWz(this, t);
}
public final AbstractC13175fSw<T> lastOrError() {
return new C13317fWz(this, null);
}
public final <R> AbstractC13163fSk<R> lift(InterfaceC13172fSt<? extends R, ? super T> interfaceC13172fSt) {
Objects.requireNonNull(interfaceC13172fSt, "lifter is null");
return new C13316fWy(this, interfaceC13172fSt);
}
public final <R> AbstractC13163fSk<R> map(fSS<? super T, ? extends R> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13314fWw(this, fss);
}
public final AbstractC13163fSk<C13166fSn<T>> materialize() {
return new fWE(this);
}
public final AbstractC13163fSk<T> mergeWith(InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return merge(this, interfaceC13169fSq);
}
public final AbstractC13163fSk<T> mergeWith(fSD<? extends T> fsd) {
Objects.requireNonNull(fsd, "other is null");
return new fWA(this, fsd);
}
public final AbstractC13163fSk<T> mergeWith(InterfaceC13160fSh<? extends T> interfaceC13160fSh) {
Objects.requireNonNull(interfaceC13160fSh, "other is null");
return new C13284fWC(this, interfaceC13160fSh);
}
public final AbstractC13163fSk<T> mergeWith(fRZ frz) {
Objects.requireNonNull(frz, "other is null");
return new fWD(this, frz);
}
public final AbstractC13163fSk<T> observeOn(AbstractC13173fSu abstractC13173fSu) {
return observeOn(abstractC13173fSu, false, bufferSize());
}
public final AbstractC13163fSk<T> observeOn(AbstractC13173fSu abstractC13173fSu, boolean z) {
return observeOn(abstractC13173fSu, z, bufferSize());
}
public final AbstractC13163fSk<T> observeOn(AbstractC13173fSu abstractC13173fSu, boolean z, int i) {
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
C13199fTm.c(i, "bufferSize");
return new fWH(this, abstractC13173fSu, z, i);
}
public final <U> AbstractC13163fSk<U> ofType(Class<U> cls) {
Objects.requireNonNull(cls, "clazz is null");
return filter(C13194fTh.b(cls)).cast(cls);
}
public final AbstractC13163fSk<T> onErrorComplete() {
return onErrorComplete(C13194fTh.b());
}
public final AbstractC13163fSk<T> onErrorComplete(InterfaceC13193fTg<? super Throwable> interfaceC13193fTg) {
Objects.requireNonNull(interfaceC13193fTg, "predicate is null");
return new C13285fWJ(this, interfaceC13193fTg);
}
public final AbstractC13163fSk<T> onErrorResumeNext(fSS<? super Throwable, ? extends InterfaceC13169fSq<? extends T>> fss) {
Objects.requireNonNull(fss, "fallbackSupplier is null");
return new fWF(this, fss);
}
public final AbstractC13163fSk<T> onErrorResumeWith(InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "fallback is null");
return onErrorResumeNext(C13194fTh.c(interfaceC13169fSq));
}
public final AbstractC13163fSk<T> onErrorReturn(fSS<? super Throwable, ? extends T> fss) {
Objects.requireNonNull(fss, "itemSupplier is null");
return new fWG(this, fss);
}
public final AbstractC13163fSk<T> onErrorReturnItem(T t) {
Objects.requireNonNull(t, "item is null");
return onErrorReturn(C13194fTh.c(t));
}
public final AbstractC13163fSk<T> onTerminateDetach() {
return new fVG(this);
}
public final fYZ<T> publish() {
return new fWI(this);
}
public final <R> AbstractC13163fSk<R> publish(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss) {
Objects.requireNonNull(fss, "selector is null");
return new fWL(this, fss);
}
public final AbstractC13159fSg<T> reduce(fSL<T, T, T> fsl) {
Objects.requireNonNull(fsl, "reducer is null");
return new fWK(this, fsl);
}
public final <R> AbstractC13175fSw<R> reduce(R r, fSL<R, ? super T, R> fsl) {
Objects.requireNonNull(r, "seed is null");
Objects.requireNonNull(fsl, "reducer is null");
return new C13286fWM(this, r, fsl);
}
public final <R> AbstractC13175fSw<R> reduceWith(InterfaceC13189fTc<R> interfaceC13189fTc, fSL<R, ? super T, R> fsl) {
Objects.requireNonNull(interfaceC13189fTc, "seedSupplier is null");
Objects.requireNonNull(fsl, "reducer is null");
return new C13288fWQ(this, interfaceC13189fTc, fsl);
}
public final AbstractC13163fSk<T> repeat() {
return repeat(Long.MAX_VALUE);
}
public final AbstractC13163fSk<T> repeat(long j) {
if (j < 0) {
throw new IllegalArgumentException("times >= 0 required but it was ".concat(String.valueOf(j)));
}
if (j == 0) {
return empty();
}
return new C13289fWR(this, j);
}
public final AbstractC13163fSk<T> repeatUntil(InterfaceC13148fSM interfaceC13148fSM) {
Objects.requireNonNull(interfaceC13148fSM, "stop is null");
return new fWU(this, interfaceC13148fSM);
}
public final AbstractC13163fSk<T> repeatWhen(fSS<? super AbstractC13163fSk<Object>, ? extends InterfaceC13169fSq<?>> fss) {
Objects.requireNonNull(fss, "handler is null");
return new fWT(this, fss);
}
public final fYZ<T> replay() {
return fWZ.c(this);
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss) {
Objects.requireNonNull(fss, "selector is null");
return fWZ.a(new C13309fWr.tOB(this), fss);
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, int i) {
Objects.requireNonNull(fss, "selector is null");
C13199fTm.c(i, "bufferSize");
return fWZ.a(new C13309fWr.RVV(this, i, false), fss);
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, int i, boolean z) {
Objects.requireNonNull(fss, "selector is null");
C13199fTm.c(i, "bufferSize");
return fWZ.a(new C13309fWr.RVV(this, i, z), fss);
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, int i, long j, TimeUnit timeUnit) {
return replay(fss, i, j, timeUnit, C13417fZt.e());
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, int i, long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(fss, "selector is null");
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.a(new C13309fWr.HBt(this, i, j, timeUnit, abstractC13173fSu, false), fss);
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, int i, long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
Objects.requireNonNull(fss, "selector is null");
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.a(new C13309fWr.HBt(this, i, j, timeUnit, abstractC13173fSu, z), fss);
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, long j, TimeUnit timeUnit) {
return replay(fss, j, timeUnit, C13417fZt.e());
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(fss, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.a(new C13309fWr.jNh(this, j, timeUnit, abstractC13173fSu, false), fss);
}
public final <R> AbstractC13163fSk<R> replay(fSS<? super AbstractC13163fSk<T>, ? extends InterfaceC13169fSq<R>> fss, long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
Objects.requireNonNull(fss, "selector is null");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.a(new C13309fWr.jNh(this, j, timeUnit, abstractC13173fSu, z), fss);
}
public final fYZ<T> replay(int i) {
C13199fTm.c(i, "bufferSize");
return fWZ.b(this, i, false);
}
public final fYZ<T> replay(int i, boolean z) {
C13199fTm.c(i, "bufferSize");
return fWZ.b(this, i, z);
}
public final fYZ<T> replay(int i, long j, TimeUnit timeUnit) {
return replay(i, j, timeUnit, C13417fZt.e());
}
public final fYZ<T> replay(int i, long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.b(this, j, timeUnit, abstractC13173fSu, i, false);
}
public final fYZ<T> replay(int i, long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.b(this, j, timeUnit, abstractC13173fSu, i, z);
}
public final fYZ<T> replay(long j, TimeUnit timeUnit) {
return replay(j, timeUnit, C13417fZt.e());
}
public final fYZ<T> replay(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.e(this, j, timeUnit, abstractC13173fSu, false);
}
public final fYZ<T> replay(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return fWZ.e(this, j, timeUnit, abstractC13173fSu, z);
}
public final AbstractC13163fSk<T> retry() {
return retry(Long.MAX_VALUE, C13194fTh.b());
}
public final AbstractC13163fSk<T> retry(fSN<? super Integer, ? super Throwable> fsn) {
Objects.requireNonNull(fsn, "predicate is null");
return new C13291fWV(this, fsn);
}
public final AbstractC13163fSk<T> retry(long j) {
return retry(j, C13194fTh.b());
}
public final AbstractC13163fSk<T> retry(long j, InterfaceC13193fTg<? super Throwable> interfaceC13193fTg) {
if (j < 0) {
throw new IllegalArgumentException("times >= 0 required but it was ".concat(String.valueOf(j)));
}
Objects.requireNonNull(interfaceC13193fTg, "predicate is null");
return new C13327fXa(this, j, interfaceC13193fTg);
}
public final AbstractC13163fSk<T> retry(InterfaceC13193fTg<? super Throwable> interfaceC13193fTg) {
return retry(Long.MAX_VALUE, interfaceC13193fTg);
}
public final AbstractC13163fSk<T> retryUntil(InterfaceC13148fSM interfaceC13148fSM) {
Objects.requireNonNull(interfaceC13148fSM, "stop is null");
return retry(Long.MAX_VALUE, C13194fTh.a(interfaceC13148fSM));
}
public final AbstractC13163fSk<T> retryWhen(fSS<? super AbstractC13163fSk<Throwable>, ? extends InterfaceC13169fSq<?>> fss) {
Objects.requireNonNull(fss, "handler is null");
return new fWW(this, fss);
}
public final void safeSubscribe(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
Objects.requireNonNull(interfaceC13174fSv, "observer is null");
if (interfaceC13174fSv instanceof C13407fZj) {
subscribe(interfaceC13174fSv);
} else {
subscribe(new C13407fZj(interfaceC13174fSv));
}
}
public final AbstractC13163fSk<T> sample(long j, TimeUnit timeUnit) {
return sample(j, timeUnit, C13417fZt.e());
}
public final AbstractC13163fSk<T> sample(long j, TimeUnit timeUnit, boolean z) {
return sample(j, timeUnit, C13417fZt.e(), z);
}
public final AbstractC13163fSk<T> sample(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fWX(this, j, timeUnit, abstractC13173fSu, false, null);
}
public final AbstractC13163fSk<T> sample(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fWX(this, j, timeUnit, abstractC13173fSu, z, null);
}
public final AbstractC13163fSk<T> sample(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z, fSQ<? super T> fsq) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(fsq, "onDropped is null");
return new fWX(this, j, timeUnit, abstractC13173fSu, z, fsq);
}
public final <U> AbstractC13163fSk<T> sample(InterfaceC13169fSq<U> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "sampler is null");
return new C13331fXe(this, interfaceC13169fSq, false);
}
public final <U> AbstractC13163fSk<T> sample(InterfaceC13169fSq<U> interfaceC13169fSq, boolean z) {
Objects.requireNonNull(interfaceC13169fSq, "sampler is null");
return new C13331fXe(this, interfaceC13169fSq, z);
}
public final AbstractC13163fSk<T> scan(fSL<T, T, T> fsl) {
Objects.requireNonNull(fsl, "accumulator is null");
return new C13330fXd(this, fsl);
}
public final <R> AbstractC13163fSk<R> scan(R r, fSL<R, ? super T, R> fsl) {
Objects.requireNonNull(r, "initialValue is null");
return scanWith(C13194fTh.a(r), fsl);
}
public final <R> AbstractC13163fSk<R> scanWith(InterfaceC13189fTc<R> interfaceC13189fTc, fSL<R, ? super T, R> fsl) {
Objects.requireNonNull(interfaceC13189fTc, "seedSupplier is null");
Objects.requireNonNull(fsl, "accumulator is null");
return new C13329fXc(this, interfaceC13189fTc, fsl);
}
public final AbstractC13163fSk<T> serialize() {
return new C13337fXk(this);
}
public final AbstractC13163fSk<T> share() {
return new C13290fWS(publish());
}
public final AbstractC13159fSg<T> singleElement() {
return new C13335fXi(this);
}
public final AbstractC13175fSw<T> single(T t) {
Objects.requireNonNull(t, "defaultItem is null");
return new C13333fXg(this, t);
}
public final AbstractC13175fSw<T> singleOrError() {
return new C13333fXg(this, null);
}
public final AbstractC13163fSk<T> skip(long j) {
if (j >= 0) {
return j == 0 ? this : new C13336fXj(this, j);
}
throw new IllegalArgumentException("count >= 0 expected but it was ".concat(String.valueOf(j)));
}
public final AbstractC13163fSk<T> skip(long j, TimeUnit timeUnit) {
return skipUntil(timer(j, timeUnit));
}
public final AbstractC13163fSk<T> skip(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return skipUntil(timer(j, timeUnit, abstractC13173fSu));
}
public final AbstractC13163fSk<T> skipLast(int i) {
if (i >= 0) {
return i == 0 ? this : new C13341fXo(this, i);
}
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(i)));
}
public final AbstractC13163fSk<T> skipLast(long j, TimeUnit timeUnit) {
return skipLast(j, timeUnit, C13417fZt.d(), false, bufferSize());
}
public final AbstractC13163fSk<T> skipLast(long j, TimeUnit timeUnit, boolean z) {
return skipLast(j, timeUnit, C13417fZt.d(), z, bufferSize());
}
public final AbstractC13163fSk<T> skipLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return skipLast(j, timeUnit, abstractC13173fSu, false, bufferSize());
}
public final AbstractC13163fSk<T> skipLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
return skipLast(j, timeUnit, abstractC13173fSu, z, bufferSize());
}
public final AbstractC13163fSk<T> skipLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z, int i) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
C13199fTm.c(i, "bufferSize");
return new C13342fXp(this, j, timeUnit, abstractC13173fSu, i << 1, z);
}
public final <U> AbstractC13163fSk<T> skipUntil(InterfaceC13169fSq<U> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return new C13339fXm(this, interfaceC13169fSq);
}
public final AbstractC13163fSk<T> skipWhile(InterfaceC13193fTg<? super T> interfaceC13193fTg) {
Objects.requireNonNull(interfaceC13193fTg, "predicate is null");
return new C13340fXn(this, interfaceC13193fTg);
}
public final AbstractC13163fSk<T> sorted() {
AbstractC13163fSk<T> c13377fYp;
AbstractC13175fSw<List<T>> list = toList();
if (list instanceof InterfaceC13204fTr) {
c13377fYp = ((InterfaceC13204fTr) list).b();
} else {
c13377fYp = new C13377fYp(list);
}
return c13377fYp.map(C13194fTh.e(C13194fTh.h())).flatMapIterable(C13194fTh.d());
}
public final AbstractC13163fSk<T> sorted(Comparator<? super T> comparator) {
AbstractC13163fSk<T> c13377fYp;
Objects.requireNonNull(comparator, "comparator is null");
AbstractC13175fSw<List<T>> list = toList();
if (list instanceof InterfaceC13204fTr) {
c13377fYp = ((InterfaceC13204fTr) list).b();
} else {
c13377fYp = new C13377fYp(list);
}
return c13377fYp.map(C13194fTh.e(comparator)).flatMapIterable(C13194fTh.d());
}
public final AbstractC13163fSk<T> startWithIterable(Iterable<? extends T> iterable) {
return concatArray(fromIterable(iterable), this);
}
public final AbstractC13163fSk<T> startWith(fRZ frz) {
AbstractC13163fSk<T> c13243fUv;
Objects.requireNonNull(frz, "other is null");
fRZ e = fRY.e(frz);
if (e instanceof InterfaceC13204fTr) {
c13243fUv = ((InterfaceC13204fTr) e).b();
} else {
c13243fUv = new C13243fUv(e);
}
return concat(c13243fUv, this);
}
public final AbstractC13163fSk<T> startWith(fSD<T> fsd) {
AbstractC13163fSk<T> c13377fYp;
Objects.requireNonNull(fsd, "other is null");
fSD c = AbstractC13175fSw.c(fsd);
if (c instanceof InterfaceC13204fTr) {
c13377fYp = ((InterfaceC13204fTr) c).b();
} else {
c13377fYp = new C13377fYp(c);
}
return concat(c13377fYp, this);
}
public final AbstractC13163fSk<T> startWith(InterfaceC13160fSh<T> interfaceC13160fSh) {
AbstractC13163fSk<T> c13214fUE;
Objects.requireNonNull(interfaceC13160fSh, "other is null");
InterfaceC13160fSh b = AbstractC13159fSg.b(interfaceC13160fSh);
if (b instanceof InterfaceC13204fTr) {
c13214fUE = ((InterfaceC13204fTr) b).b();
} else {
c13214fUE = new C13214fUE(b);
}
return concat(c13214fUE, this);
}
public final AbstractC13163fSk<T> startWith(InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return concatArray(interfaceC13169fSq, this);
}
public final AbstractC13163fSk<T> startWithItem(T t) {
return concatArray(just(t), this);
}
@SafeVarargs
public final AbstractC13163fSk<T> startWithArray(T... tArr) {
AbstractC13163fSk fromArray = fromArray(tArr);
return fromArray == empty() ? this : concatArray(fromArray, this);
}
public final fSJ subscribe() {
return subscribe(C13194fTh.c(), C13194fTh.a, C13194fTh.c);
}
public final fSJ subscribe(fSQ<? super T> fsq) {
return subscribe(fsq, C13194fTh.a, C13194fTh.c);
}
public final fSJ subscribe(fSQ<? super T> fsq, fSQ<? super Throwable> fsq2) {
return subscribe(fsq, fsq2, C13194fTh.c);
}
public final fSJ subscribe(fSQ<? super T> fsq, fSQ<? super Throwable> fsq2, fSP fsp) {
Objects.requireNonNull(fsq, "onNext is null");
Objects.requireNonNull(fsq2, "onError is null");
Objects.requireNonNull(fsp, "onComplete is null");
fTY fty = new fTY(fsq, fsq2, fsp, C13194fTh.c());
subscribe(fty);
return fty;
}
public final fSJ subscribe(fSQ<? super T> fsq, fSQ<? super Throwable> fsq2, fSP fsp, InterfaceC13145fSF interfaceC13145fSF) {
Objects.requireNonNull(fsq, "onNext is null");
Objects.requireNonNull(fsq2, "onError is null");
Objects.requireNonNull(fsp, "onComplete is null");
Objects.requireNonNull(interfaceC13145fSF, "container is null");
fTQ ftq = new fTQ(interfaceC13145fSF, fsq, fsq2, fsp);
interfaceC13145fSF.e(ftq);
subscribe(ftq);
return ftq;
}
@Override // o.InterfaceC13169fSq
public final void subscribe(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
Objects.requireNonNull(interfaceC13174fSv, "observer is null");
try {
Objects.requireNonNull(interfaceC13174fSv, "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(interfaceC13174fSv);
} catch (NullPointerException e) {
throw e;
} catch (Throwable th) {
C13147fSI.c(th);
C13418fZu.c(th);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th);
throw nullPointerException;
}
}
public final <E extends InterfaceC13174fSv<? super T>> E subscribeWith(E e) {
subscribe(e);
return e;
}
public final AbstractC13163fSk<T> subscribeOn(AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new C13338fXl(this, abstractC13173fSu);
}
public final AbstractC13163fSk<T> switchIfEmpty(InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return new C13343fXq(this, interfaceC13169fSq);
}
public final <R> AbstractC13163fSk<R> switchMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss) {
return switchMap(fss, bufferSize());
}
/* JADX WARN: Multi-variable type inference failed */
public final <R> AbstractC13163fSk<R> switchMap(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
if (this instanceof InterfaceC13409fZl) {
Object d = ((InterfaceC13409fZl) this).d();
if (d == null) {
return empty();
}
return new C13328fXb.IeS(d, fss);
}
return new C13347fXu(this, fss, i, false);
}
public final fRY switchMapCompletable(fSS<? super T, ? extends fRZ> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13218fUR(this, fss, false);
}
public final fRY switchMapCompletableDelayError(fSS<? super T, ? extends fRZ> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13218fUR(this, fss, true);
}
public final <R> AbstractC13163fSk<R> switchMapMaybe(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13219fUS(this, fss, false);
}
public final <R> AbstractC13163fSk<R> switchMapMaybeDelayError(fSS<? super T, ? extends InterfaceC13160fSh<? extends R>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13219fUS(this, fss, true);
}
public final <R> AbstractC13163fSk<R> switchMapSingle(fSS<? super T, ? extends fSD<? extends R>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new fUQ(this, fss, false);
}
public final <R> AbstractC13163fSk<R> switchMapSingleDelayError(fSS<? super T, ? extends fSD<? extends R>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new fUQ(this, fss, true);
}
public final <R> AbstractC13163fSk<R> switchMapDelayError(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss) {
return switchMapDelayError(fss, bufferSize());
}
/* JADX WARN: Multi-variable type inference failed */
public final <R> AbstractC13163fSk<R> switchMapDelayError(fSS<? super T, ? extends InterfaceC13169fSq<? extends R>> fss, int i) {
Objects.requireNonNull(fss, "mapper is null");
C13199fTm.c(i, "bufferSize");
if (this instanceof InterfaceC13409fZl) {
Object d = ((InterfaceC13409fZl) this).d();
if (d == null) {
return empty();
}
return new C13328fXb.IeS(d, fss);
}
return new C13347fXu(this, fss, i, true);
}
public final AbstractC13163fSk<T> take(long j) {
if (j < 0) {
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(j)));
}
return new C13344fXr(this, j);
}
public final AbstractC13163fSk<T> take(long j, TimeUnit timeUnit) {
return takeUntil(timer(j, timeUnit));
}
public final AbstractC13163fSk<T> take(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return takeUntil(timer(j, timeUnit, abstractC13173fSu));
}
public final AbstractC13163fSk<T> takeLast(int i) {
if (i < 0) {
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(i)));
}
if (i == 0) {
return new C13305fWn(this);
}
if (i == 1) {
return new C13346fXt(this);
}
return new C13345fXs(this, i);
}
public final AbstractC13163fSk<T> takeLast(long j, long j2, TimeUnit timeUnit) {
return takeLast(j, j2, timeUnit, C13417fZt.d(), false, bufferSize());
}
public final AbstractC13163fSk<T> takeLast(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return takeLast(j, j2, timeUnit, abstractC13173fSu, false, bufferSize());
}
public final AbstractC13163fSk<T> takeLast(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z, int i) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
C13199fTm.c(i, "bufferSize");
if (j < 0) {
throw new IllegalArgumentException("count >= 0 required but it was ".concat(String.valueOf(j)));
}
return new C13350fXx(this, j, j2, timeUnit, abstractC13173fSu, i, z);
}
public final AbstractC13163fSk<T> takeLast(long j, TimeUnit timeUnit) {
return takeLast(j, timeUnit, C13417fZt.d(), false, bufferSize());
}
public final AbstractC13163fSk<T> takeLast(long j, TimeUnit timeUnit, boolean z) {
return takeLast(j, timeUnit, C13417fZt.d(), z, bufferSize());
}
public final AbstractC13163fSk<T> takeLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return takeLast(j, timeUnit, abstractC13173fSu, false, bufferSize());
}
public final AbstractC13163fSk<T> takeLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
return takeLast(j, timeUnit, abstractC13173fSu, z, bufferSize());
}
public final AbstractC13163fSk<T> takeLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z, int i) {
return takeLast(Long.MAX_VALUE, j, timeUnit, abstractC13173fSu, z, i);
}
public final <U> AbstractC13163fSk<T> takeUntil(InterfaceC13169fSq<U> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return new C13352fXz(this, interfaceC13169fSq);
}
public final AbstractC13163fSk<T> takeUntil(InterfaceC13193fTg<? super T> interfaceC13193fTg) {
Objects.requireNonNull(interfaceC13193fTg, "stopPredicate is null");
return new C13351fXy(this, interfaceC13193fTg);
}
public final AbstractC13163fSk<T> takeWhile(InterfaceC13193fTg<? super T> interfaceC13193fTg) {
Objects.requireNonNull(interfaceC13193fTg, "predicate is null");
return new C13348fXv(this, interfaceC13193fTg);
}
public final AbstractC13163fSk<T> throttleFirst(long j, TimeUnit timeUnit) {
return throttleFirst(j, timeUnit, C13417fZt.e());
}
public final AbstractC13163fSk<T> throttleFirst(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new C13349fXw(this, j, timeUnit, abstractC13173fSu, null);
}
public final AbstractC13163fSk<T> throttleFirst(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, fSQ<? super T> fsq) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(fsq, "onDropped is null");
return new C13349fXw(this, j, timeUnit, abstractC13173fSu, fsq);
}
public final AbstractC13163fSk<T> throttleLast(long j, TimeUnit timeUnit) {
return sample(j, timeUnit);
}
public final AbstractC13163fSk<T> throttleLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, fSQ<? super T> fsq) {
return sample(j, timeUnit, abstractC13173fSu, false, fsq);
}
public final AbstractC13163fSk<T> throttleLast(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return sample(j, timeUnit, abstractC13173fSu);
}
public final AbstractC13163fSk<T> throttleLatest(long j, TimeUnit timeUnit) {
return throttleLatest(j, timeUnit, C13417fZt.e(), false);
}
public final AbstractC13163fSk<T> throttleLatest(long j, TimeUnit timeUnit, boolean z) {
return throttleLatest(j, timeUnit, C13417fZt.e(), z);
}
public final AbstractC13163fSk<T> throttleLatest(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return throttleLatest(j, timeUnit, abstractC13173fSu, false);
}
public final AbstractC13163fSk<T> throttleLatest(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fXC(this, j, timeUnit, abstractC13173fSu, z, null);
}
public final AbstractC13163fSk<T> throttleLatest(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, boolean z, fSQ<? super T> fsq) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(fsq, "onDropped is null");
return new fXC(this, j, timeUnit, abstractC13173fSu, z, fsq);
}
public final AbstractC13163fSk<T> throttleWithTimeout(long j, TimeUnit timeUnit) {
return debounce(j, timeUnit);
}
public final AbstractC13163fSk<T> throttleWithTimeout(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return debounce(j, timeUnit, abstractC13173fSu);
}
public final AbstractC13163fSk<T> throttleWithTimeout(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, fSQ<? super T> fsq) {
return debounce(j, timeUnit, abstractC13173fSu, fsq);
}
public final AbstractC13163fSk<C13421fZx<T>> timeInterval() {
return timeInterval(TimeUnit.MILLISECONDS, C13417fZt.e());
}
public final AbstractC13163fSk<C13421fZx<T>> timeInterval(AbstractC13173fSu abstractC13173fSu) {
return timeInterval(TimeUnit.MILLISECONDS, abstractC13173fSu);
}
public final AbstractC13163fSk<C13421fZx<T>> timeInterval(TimeUnit timeUnit) {
return timeInterval(timeUnit, C13417fZt.e());
}
public final AbstractC13163fSk<C13421fZx<T>> timeInterval(TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fXD(this, timeUnit, abstractC13173fSu);
}
public final <V> AbstractC13163fSk<T> timeout(fSS<? super T, ? extends InterfaceC13169fSq<V>> fss) {
return timeout0(null, fss, null);
}
public final <V> AbstractC13163fSk<T> timeout(fSS<? super T, ? extends InterfaceC13169fSq<V>> fss, InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "fallback is null");
return timeout0(null, fss, interfaceC13169fSq);
}
public final AbstractC13163fSk<T> timeout(long j, TimeUnit timeUnit) {
return timeout0(j, timeUnit, null, C13417fZt.e());
}
public final AbstractC13163fSk<T> timeout(long j, TimeUnit timeUnit, InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "fallback is null");
return timeout0(j, timeUnit, interfaceC13169fSq, C13417fZt.e());
}
public final AbstractC13163fSk<T> timeout(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, InterfaceC13169fSq<? extends T> interfaceC13169fSq) {
Objects.requireNonNull(interfaceC13169fSq, "fallback is null");
return timeout0(j, timeUnit, interfaceC13169fSq, abstractC13173fSu);
}
public final AbstractC13163fSk<T> timeout(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return timeout0(j, timeUnit, null, abstractC13173fSu);
}
public final <U, V> AbstractC13163fSk<T> timeout(InterfaceC13169fSq<U> interfaceC13169fSq, fSS<? super T, ? extends InterfaceC13169fSq<V>> fss) {
Objects.requireNonNull(interfaceC13169fSq, "firstTimeoutIndicator is null");
return timeout0(interfaceC13169fSq, fss, null);
}
public final <U, V> AbstractC13163fSk<T> timeout(InterfaceC13169fSq<U> interfaceC13169fSq, fSS<? super T, ? extends InterfaceC13169fSq<V>> fss, InterfaceC13169fSq<? extends T> interfaceC13169fSq2) {
Objects.requireNonNull(interfaceC13169fSq, "firstTimeoutIndicator is null");
Objects.requireNonNull(interfaceC13169fSq2, "fallback is null");
return timeout0(interfaceC13169fSq, fss, interfaceC13169fSq2);
}
private AbstractC13163fSk<T> timeout0(long j, TimeUnit timeUnit, InterfaceC13169fSq<? extends T> interfaceC13169fSq, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fXE(this, j, timeUnit, abstractC13173fSu, interfaceC13169fSq);
}
private <U, V> AbstractC13163fSk<T> timeout0(InterfaceC13169fSq<U> interfaceC13169fSq, fSS<? super T, ? extends InterfaceC13169fSq<V>> fss, InterfaceC13169fSq<? extends T> interfaceC13169fSq2) {
Objects.requireNonNull(fss, "itemTimeoutIndicator is null");
return new fXA(this, interfaceC13169fSq, fss, interfaceC13169fSq2);
}
public final AbstractC13163fSk<C13421fZx<T>> timestamp() {
return timestamp(TimeUnit.MILLISECONDS, C13417fZt.e());
}
public final AbstractC13163fSk<C13421fZx<T>> timestamp(AbstractC13173fSu abstractC13173fSu) {
return timestamp(TimeUnit.MILLISECONDS, abstractC13173fSu);
}
public final AbstractC13163fSk<C13421fZx<T>> timestamp(TimeUnit timeUnit) {
return timestamp(timeUnit, C13417fZt.e());
}
public final AbstractC13163fSk<C13421fZx<T>> timestamp(TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(timeUnit, "unit is null");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return (AbstractC13163fSk<C13421fZx<T>>) map(C13194fTh.d(timeUnit, abstractC13173fSu));
}
public final <R> R to(InterfaceC13165fSm<T, ? extends R> interfaceC13165fSm) {
return (R) ((InterfaceC13165fSm) Objects.requireNonNull(interfaceC13165fSm, "converter is null")).d();
}
public final AbstractC13175fSw<List<T>> toList() {
return toList(16);
}
public final AbstractC13175fSw<List<T>> toList(int i) {
C13199fTm.c(i, "capacityHint");
return new fXJ(this, i);
}
public final <U extends Collection<? super T>> AbstractC13175fSw<U> toList(InterfaceC13189fTc<U> interfaceC13189fTc) {
Objects.requireNonNull(interfaceC13189fTc, "collectionSupplier is null");
return new fXJ(this, interfaceC13189fTc);
}
public final <K> AbstractC13175fSw<Map<K, T>> toMap(fSS<? super T, ? extends K> fss) {
Objects.requireNonNull(fss, "keySelector is null");
return (AbstractC13175fSw<Map<K, T>>) collect(fYW.c(), C13194fTh.a((fSS) fss));
}
public final <K, V> AbstractC13175fSw<Map<K, V>> toMap(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2) {
Objects.requireNonNull(fss, "keySelector is null");
Objects.requireNonNull(fss2, "valueSelector is null");
return (AbstractC13175fSw<Map<K, V>>) collect(fYW.c(), C13194fTh.d(fss, fss2));
}
/* JADX WARN: Multi-variable type inference failed */
public final <K, V> AbstractC13175fSw<Map<K, V>> toMap(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2, InterfaceC13189fTc<? extends Map<K, V>> interfaceC13189fTc) {
Objects.requireNonNull(fss, "keySelector is null");
Objects.requireNonNull(fss2, "valueSelector is null");
Objects.requireNonNull(interfaceC13189fTc, "mapSupplier is null");
return (AbstractC13175fSw<Map<K, V>>) collect(interfaceC13189fTc, C13194fTh.d(fss, fss2));
}
public final <K> AbstractC13175fSw<Map<K, Collection<T>>> toMultimap(fSS<? super T, ? extends K> fss) {
return (AbstractC13175fSw<Map<K, Collection<T>>>) toMultimap(fss, C13194fTh.d(), fYW.c(), EnumC13354fYH.b());
}
public final <K, V> AbstractC13175fSw<Map<K, Collection<V>>> toMultimap(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2) {
return toMultimap(fss, fss2, fYW.c(), EnumC13354fYH.b());
}
/* JADX WARN: Multi-variable type inference failed */
public final <K, V> AbstractC13175fSw<Map<K, Collection<V>>> toMultimap(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2, InterfaceC13189fTc<? extends Map<K, Collection<V>>> interfaceC13189fTc, fSS<? super K, ? extends Collection<? super V>> fss3) {
Objects.requireNonNull(fss, "keySelector is null");
Objects.requireNonNull(fss2, "valueSelector is null");
Objects.requireNonNull(interfaceC13189fTc, "mapSupplier is null");
Objects.requireNonNull(fss3, "collectionFactory is null");
return (AbstractC13175fSw<Map<K, Collection<V>>>) collect(interfaceC13189fTc, C13194fTh.e(fss, fss2, fss3));
}
public final <K, V> AbstractC13175fSw<Map<K, Collection<V>>> toMultimap(fSS<? super T, ? extends K> fss, fSS<? super T, ? extends V> fss2, InterfaceC13189fTc<Map<K, Collection<V>>> interfaceC13189fTc) {
return toMultimap(fss, fss2, interfaceC13189fTc, EnumC13354fYH.b());
}
public final AbstractC13155fSc<T> toFlowable(fRT frt) {
Objects.requireNonNull(frt, "strategy is null");
C13244fUw c13244fUw = new C13244fUw(this);
int i = AnonymousClass5.d[frt.ordinal()];
if (i == 1) {
return new fUC(c13244fUw);
}
if (i == 2) {
return new fUD(c13244fUw);
}
if (i == 3) {
return c13244fUw;
}
if (i == 4) {
return new fUG(c13244fUw);
}
int a = AbstractC13155fSc.a();
C13199fTm.c(a, "capacity");
return new fUB(c13244fUw, a, C13194fTh.c);
}
/* renamed from: o.fSk$5, reason: invalid class name */
/* loaded from: classes.dex */
static /* synthetic */ class AnonymousClass5 {
static final int[] d;
static {
int[] iArr = new int[fRT.values().length];
d = iArr;
try {
iArr[fRT.DROP.ordinal()] = 1;
} catch (NoSuchFieldError unused) {
}
try {
d[fRT.LATEST.ordinal()] = 2;
} catch (NoSuchFieldError unused2) {
}
try {
d[fRT.MISSING.ordinal()] = 3;
} catch (NoSuchFieldError unused3) {
}
try {
d[fRT.ERROR.ordinal()] = 4;
} catch (NoSuchFieldError unused4) {
}
}
}
public final AbstractC13175fSw<List<T>> toSortedList() {
return toSortedList(C13194fTh.h());
}
public final AbstractC13175fSw<List<T>> toSortedList(Comparator<? super T> comparator) {
Objects.requireNonNull(comparator, "comparator is null");
AbstractC13175fSw<List<T>> list = toList();
fSS e = C13194fTh.e(comparator);
Objects.requireNonNull(e, "mapper is null");
return new C13372fYk(list, e);
}
public final AbstractC13175fSw<List<T>> toSortedList(Comparator<? super T> comparator, int i) {
Objects.requireNonNull(comparator, "comparator is null");
AbstractC13175fSw<List<T>> list = toList(i);
fSS e = C13194fTh.e(comparator);
Objects.requireNonNull(e, "mapper is null");
return new C13372fYk(list, e);
}
public final AbstractC13175fSw<List<T>> toSortedList(int i) {
return toSortedList(C13194fTh.h(), i);
}
public final AbstractC13163fSk<T> unsubscribeOn(AbstractC13173fSu abstractC13173fSu) {
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
return new fXH(this, abstractC13173fSu);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j) {
return window(j, j, bufferSize());
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, long j2) {
return window(j, j2, bufferSize());
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, long j2, int i) {
C13199fTm.e(j, "count");
C13199fTm.e(j2, "skip");
C13199fTm.c(i, "bufferSize");
return new C13319fXG(this, j, j2, i);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, long j2, TimeUnit timeUnit) {
return window(j, j2, timeUnit, C13417fZt.e(), bufferSize());
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return window(j, j2, timeUnit, abstractC13173fSu, bufferSize());
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, int i) {
C13199fTm.e(j, "timespan");
C13199fTm.e(j2, "timeskip");
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(timeUnit, "unit is null");
return new C13321fXQ(this, j, j2, timeUnit, abstractC13173fSu, Long.MAX_VALUE, i, false);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, TimeUnit timeUnit) {
return window(j, timeUnit, C13417fZt.e(), Long.MAX_VALUE, false);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, TimeUnit timeUnit, long j2) {
return window(j, timeUnit, C13417fZt.e(), j2, false);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, TimeUnit timeUnit, long j2, boolean z) {
return window(j, timeUnit, C13417fZt.e(), j2, z);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
return window(j, timeUnit, abstractC13173fSu, Long.MAX_VALUE, false);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, long j2) {
return window(j, timeUnit, abstractC13173fSu, j2, false);
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, long j2, boolean z) {
return window(j, timeUnit, abstractC13173fSu, j2, z, bufferSize());
}
public final AbstractC13163fSk<AbstractC13163fSk<T>> window(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu, long j2, boolean z, int i) {
C13199fTm.c(i, "bufferSize");
Objects.requireNonNull(abstractC13173fSu, "scheduler is null");
Objects.requireNonNull(timeUnit, "unit is null");
C13199fTm.e(j2, "count");
return new C13321fXQ(this, j, j, timeUnit, abstractC13173fSu, j2, i, z);
}
public final <B> AbstractC13163fSk<AbstractC13163fSk<T>> window(InterfaceC13169fSq<B> interfaceC13169fSq) {
return window(interfaceC13169fSq, bufferSize());
}
public final <B> AbstractC13163fSk<AbstractC13163fSk<T>> window(InterfaceC13169fSq<B> interfaceC13169fSq, int i) {
Objects.requireNonNull(interfaceC13169fSq, "boundaryIndicator is null");
C13199fTm.c(i, "bufferSize");
return new C13320fXK(this, interfaceC13169fSq, i);
}
public final <U, V> AbstractC13163fSk<AbstractC13163fSk<T>> window(InterfaceC13169fSq<U> interfaceC13169fSq, fSS<? super U, ? extends InterfaceC13169fSq<V>> fss) {
return window(interfaceC13169fSq, fss, bufferSize());
}
public final <U, V> AbstractC13163fSk<AbstractC13163fSk<T>> window(InterfaceC13169fSq<U> interfaceC13169fSq, fSS<? super U, ? extends InterfaceC13169fSq<V>> fss, int i) {
Objects.requireNonNull(interfaceC13169fSq, "openingIndicator is null");
Objects.requireNonNull(fss, "closingIndicator is null");
C13199fTm.c(i, "bufferSize");
return new fXM(this, interfaceC13169fSq, fss, i);
}
public final <U, R> AbstractC13163fSk<R> withLatestFrom(InterfaceC13169fSq<? extends U> interfaceC13169fSq, fSL<? super T, ? super U, ? extends R> fsl) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
Objects.requireNonNull(fsl, "combiner is null");
return new fXP(this, fsl, interfaceC13169fSq);
}
public final <T1, T2, R> AbstractC13163fSk<R> withLatestFrom(InterfaceC13169fSq<T1> interfaceC13169fSq, InterfaceC13169fSq<T2> interfaceC13169fSq2, InterfaceC13150fSU<? super T, ? super T1, ? super T2, R> interfaceC13150fSU) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13150fSU, "combiner is null");
return withLatestFrom(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2}, C13194fTh.c((InterfaceC13150fSU) interfaceC13150fSU));
}
public final <T1, T2, T3, R> AbstractC13163fSk<R> withLatestFrom(InterfaceC13169fSq<T1> interfaceC13169fSq, InterfaceC13169fSq<T2> interfaceC13169fSq2, InterfaceC13169fSq<T3> interfaceC13169fSq3, fST<? super T, ? super T1, ? super T2, ? super T3, R> fst) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(fst, "combiner is null");
return withLatestFrom(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3}, C13194fTh.b(fst));
}
public final <T1, T2, T3, T4, R> AbstractC13163fSk<R> withLatestFrom(InterfaceC13169fSq<T1> interfaceC13169fSq, InterfaceC13169fSq<T2> interfaceC13169fSq2, InterfaceC13169fSq<T3> interfaceC13169fSq3, InterfaceC13169fSq<T4> interfaceC13169fSq4, InterfaceC13151fSX<? super T, ? super T1, ? super T2, ? super T3, ? super T4, R> interfaceC13151fSX) {
Objects.requireNonNull(interfaceC13169fSq, "source1 is null");
Objects.requireNonNull(interfaceC13169fSq2, "source2 is null");
Objects.requireNonNull(interfaceC13169fSq3, "source3 is null");
Objects.requireNonNull(interfaceC13169fSq4, "source4 is null");
Objects.requireNonNull(interfaceC13151fSX, "combiner is null");
return withLatestFrom(new InterfaceC13169fSq[]{interfaceC13169fSq, interfaceC13169fSq2, interfaceC13169fSq3, interfaceC13169fSq4}, C13194fTh.e(interfaceC13151fSX));
}
public final <R> AbstractC13163fSk<R> withLatestFrom(InterfaceC13169fSq<?>[] interfaceC13169fSqArr, fSS<? super Object[], R> fss) {
Objects.requireNonNull(interfaceC13169fSqArr, "others is null");
Objects.requireNonNull(fss, "combiner is null");
return new fXS(this, interfaceC13169fSqArr, fss);
}
public final <R> AbstractC13163fSk<R> withLatestFrom(Iterable<? extends InterfaceC13169fSq<?>> iterable, fSS<? super Object[], R> fss) {
Objects.requireNonNull(iterable, "others is null");
Objects.requireNonNull(fss, "combiner is null");
return new fXS(this, iterable, fss);
}
public final <U, R> AbstractC13163fSk<R> zipWith(Iterable<U> iterable, fSL<? super T, ? super U, ? extends R> fsl) {
Objects.requireNonNull(iterable, "other is null");
Objects.requireNonNull(fsl, "zipper is null");
return new fXR(this, iterable, fsl);
}
public final <U, R> AbstractC13163fSk<R> zipWith(InterfaceC13169fSq<? extends U> interfaceC13169fSq, fSL<? super T, ? super U, ? extends R> fsl) {
Objects.requireNonNull(interfaceC13169fSq, "other is null");
return zip(this, interfaceC13169fSq, fsl);
}
public final <U, R> AbstractC13163fSk<R> zipWith(InterfaceC13169fSq<? extends U> interfaceC13169fSq, fSL<? super T, ? super U, ? extends R> fsl, boolean z) {
return zip(this, interfaceC13169fSq, fsl, z);
}
public final <U, R> AbstractC13163fSk<R> zipWith(InterfaceC13169fSq<? extends U> interfaceC13169fSq, fSL<? super T, ? super U, ? extends R> fsl, boolean z, int i) {
return zip(this, interfaceC13169fSq, fsl, z, i);
}
public final C13404fZg<T> test() {
C13404fZg<T> c13404fZg = new C13404fZg<>();
subscribe(c13404fZg);
return c13404fZg;
}
public final C13404fZg<T> test(boolean z) {
C13404fZg<T> c13404fZg = new C13404fZg<>();
if (z) {
c13404fZg.dispose();
}
subscribe(c13404fZg);
return c13404fZg;
}
public static <T> AbstractC13163fSk<T> fromOptional(Optional<T> optional) {
Objects.requireNonNull(optional, "optional is null");
return (AbstractC13163fSk) optional.map(new Function() { // from class: o.fSl
@Override // java.util.function.Function
public final Object apply(Object obj) {
return AbstractC13163fSk.just(obj);
}
}).orElseGet(new Supplier() { // from class: o.fSo
@Override // java.util.function.Supplier
public final Object get() {
return AbstractC13163fSk.empty();
}
});
}
public static <T> AbstractC13163fSk<T> fromCompletionStage(CompletionStage<T> completionStage) {
Objects.requireNonNull(completionStage, "stage is null");
return new C13208fTv(completionStage);
}
public static <T> AbstractC13163fSk<T> fromStream(Stream<T> stream) {
Objects.requireNonNull(stream, "stream is null");
return new C13206fTt(stream);
}
public final <R> AbstractC13163fSk<R> mapOptional(fSS<? super T, Optional<? extends R>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13212fTz(this, fss);
}
public final <R, A> AbstractC13175fSw<R> collect(Collector<? super T, A, R> collector) {
Objects.requireNonNull(collector, "collector is null");
return new C13203fTq(this, collector);
}
public final CompletionStage<T> firstStage(T t) {
return (CompletionStage) subscribeWith(new C13205fTs(true, t));
}
public final CompletionStage<T> singleStage(T t) {
return (CompletionStage) subscribeWith(new C13180fTB(true, t));
}
public final CompletionStage<T> lastStage(T t) {
return (CompletionStage) subscribeWith(new C13210fTx(true, t));
}
public final CompletionStage<T> firstOrErrorStage() {
return (CompletionStage) subscribeWith(new C13205fTs(false, null));
}
public final CompletionStage<T> singleOrErrorStage() {
return (CompletionStage) subscribeWith(new C13180fTB(false, null));
}
public final CompletionStage<T> lastOrErrorStage() {
return (CompletionStage) subscribeWith(new C13210fTx(false, null));
}
public final Stream<T> blockingStream() {
return blockingStream(bufferSize());
}
public final Stream<T> blockingStream(int i) {
Iterator<T> it = blockingIterable(i).iterator();
Stream stream = StreamSupport.stream(Spliterators.spliteratorUnknownSize(it, 0), false);
final fSJ fsj = (fSJ) it;
return (Stream) stream.onClose(new Runnable(fsj) { // from class: o.fSj
private fSJ e;
@Override // java.lang.Runnable
public final void run() {
this.e.dispose();
}
{
this.e = fsj;
}
});
}
public final <R> AbstractC13163fSk<R> concatMapStream(fSS<? super T, ? extends Stream<? extends R>> fss) {
return flatMapStream(fss);
}
public final <R> AbstractC13163fSk<R> flatMapStream(fSS<? super T, ? extends Stream<? extends R>> fss) {
Objects.requireNonNull(fss, "mapper is null");
return new C13207fTu(this, fss);
}
public final void blockingSubscribe() {
fYJ fyj = new fYJ();
fTY fty = new fTY(C13194fTh.c(), fyj, fyj, C13194fTh.c());
subscribe(fty);
if (fyj.getCount() != 0) {
try {
fyj.await();
} catch (InterruptedException e) {
fty.dispose();
Thread.currentThread().interrupt();
throw new IllegalStateException("Interrupted while waiting for subscription to complete.", e);
}
}
Throwable th = fyj.b;
if (th != null) {
throw fYR.c(th);
}
}
}