package dw2;
import iw2.g;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;
import kw2.b;
import ow2.b0;
import ow2.c;
import ow2.c0;
import ow2.d0;
import ow2.e;
import ow2.e0;
import ow2.f;
import ow2.h;
import ow2.j;
import ow2.l;
import ow2.m;
import ow2.n;
import ow2.o;
import ow2.p;
import ow2.q;
import ow2.r;
import ow2.t;
import ow2.w;
import ow2.x;
import ow2.y;
import rw2.g0;
import s13.a;
import vw2.d;
/* compiled from: Flowable */
public abstract class i<T> implements a<T> {
/* renamed from: a reason: collision with root package name */
public static final int f70120a = Math.max(1, Integer.getInteger("rx2.buffer-size", 128).intValue());
public static i<Long> S(long j14, TimeUnit timeUnit) {
return T(j14, timeUnit, cx2.a.a());
}
public static i<Long> T(long j14, TimeUnit timeUnit, z zVar) {
b.e(timeUnit, "unit is null");
b.e(zVar, "scheduler is null");
return zw2.a.l(new d0(Math.max(0L, j14), timeUnit, zVar));
}
public static int f() {
return f70120a;
}
public static <T> i<T> g(a<? extends T>... aVarArr) {
if (aVarArr.length == 0) {
return m();
}
if (aVarArr.length == 1) {
return v(aVarArr[0]);
}
return zw2.a.l(new ow2.b(aVarArr, false));
}
public static <T> i<T> h(l<T> lVar, a aVar) {
b.e(lVar, "source is null");
b.e(aVar, "mode is null");
return zw2.a.l(new c(lVar, aVar));
}
public static <T> i<T> m() {
return zw2.a.l(e.f116211b);
}
public static <T> i<T> n(Throwable th3) {
b.e(th3, "throwable is null");
return o(kw2.a.i(th3));
}
public static <T> i<T> o(Callable<? extends Throwable> callable) {
b.e(callable, "supplier is null");
return zw2.a.l(new f(callable));
}
public static <T> i<T> u(Iterable<? extends T> iterable) {
b.e(iterable, "source is null");
return zw2.a.l(new j(iterable));
}
public static <T> i<T> v(a<? extends T> aVar) {
if (aVar instanceof i) {
return zw2.a.l((i) aVar);
}
b.e(aVar, "source is null");
return zw2.a.l(new l(aVar));
}
public static <T> i<T> w(T t14) {
b.e(t14, "item is null");
return zw2.a.l(new n(t14));
}
public final i<T> A() {
return B(f(), false, true);
}
public final i<T> B(int i10, boolean z14, boolean z15) {
b.f(i10, "capacity");
return zw2.a.l(new q(this, i10, z15, z14, kw2.a.f99616c));
}
public final i<T> C() {
return zw2.a.l(new r(this));
}
public final i<T> D() {
return zw2.a.l(new t(this));
}
public final i<T> E(long j14) {
return F(j14, kw2.a.b());
}
public final i<T> F(long j14, iw2.l<? super Throwable> lVar) {
if (j14 >= 0) {
b.e(lVar, "predicate is null");
return zw2.a.l(new w(this, j14, lVar));
}
throw new IllegalArgumentException("times >= 0 required but it was " + j14);
}
public final i<T> G(iw2.j<? super i<Throwable>, ? extends a<?>> jVar) {
b.e(jVar, "handler is null");
return zw2.a.l(new x(this, jVar));
}
public final i<T> H(T t14) {
b.e(t14, "value is null");
return g(w(t14), this);
}
public final hw2.c I(g<? super T> gVar, g<? super Throwable> gVar2) {
return K(gVar, gVar2, kw2.a.f99616c, m.INSTANCE);
}
public final hw2.c J(g<? super T> gVar, g<? super Throwable> gVar2, iw2.a aVar) {
return K(gVar, gVar2, aVar, m.INSTANCE);
}
public final hw2.c K(g<? super T> gVar, g<? super Throwable> gVar2, iw2.a aVar, g<? super s13.c> gVar3) {
b.e(gVar, "onNext is null");
b.e(gVar2, "onError is null");
b.e(aVar, "onComplete is null");
b.e(gVar3, "onSubscribe is null");
vw2.c cVar = new vw2.c(gVar, gVar2, aVar, gVar3);
L(cVar);
return cVar;
}
public final void L(m<? super T> mVar) {
b.e(mVar, "s is null");
try {
s13.b<? super T> A = zw2.a.A(this, mVar);
b.e(A, "The RxJavaPlugins.onSubscribe hook returned a null FlowableSubscriber. Please check the handler provided to RxJavaPlugins.setOnFlowableSubscribe for invalid null returns. Further reading: https://github.com/ReactiveX/RxJava/wiki/Plugins");
M(A);
} catch (NullPointerException e14) {
throw e14;
} catch (Throwable th3) {
io.reactivex.exceptions.a.b(th3);
zw2.a.s(th3);
NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
nullPointerException.initCause(th3);
throw nullPointerException;
}
}
public abstract void M(s13.b<? super T> bVar);
public final i<T> N(z zVar) {
b.e(zVar, "scheduler is null");
return O(zVar, !(this instanceof c));
}
public final i<T> O(z zVar, boolean z14) {
b.e(zVar, "scheduler is null");
return zw2.a.l(new b0(this, zVar, z14));
}
public final <R> i<R> P(iw2.j<? super T, ? extends a<? extends R>> jVar) {
return Q(jVar, f());
}
public final <R> i<R> Q(iw2.j<? super T, ? extends a<? extends R>> jVar, int i10) {
return R(jVar, i10, false);
}
public <R> i<R> R(iw2.j<? super T, ? extends a<? extends R>> jVar, int i10, boolean z14) {
b.e(jVar, "mapper is null");
b.f(i10, "bufferSize");
if (!(this instanceof lw2.g)) {
return zw2.a.l(new c0(this, jVar, i10, z14));
}
Object call = ((lw2.g) this).call();
if (call == null) {
return m();
}
return y.a(call, jVar);
}
public final r<T> U() {
return zw2.a.n(new g0(this));
}
public final i<T> V(z zVar) {
b.e(zVar, "scheduler is null");
return zw2.a.l(new e0(this, zVar));
}
public final <R> R b(j<T, ? extends R> jVar) {
return (R) ((j) b.e(jVar, "converter is null")).b(this);
}
@Override // s13.a
public final void c(s13.b<? super T> bVar) {
if (bVar instanceof m) {
L((m) bVar);
return;
}
b.e(bVar, "s is null");
L(new d(bVar));
}
public final i<T> i(g<? super T> gVar, g<? super Throwable> gVar2, iw2.a aVar, iw2.a aVar2) {
b.e(gVar, "onNext is null");
b.e(gVar2, "onError is null");
b.e(aVar, "onComplete is null");
b.e(aVar2, "onAfterTerminate is null");
return zw2.a.l(new ow2.d(this, gVar, gVar2, aVar, aVar2));
}
public final i<T> k(g<? super Throwable> gVar) {
g<? super T> f14 = kw2.a.f();
iw2.a aVar = kw2.a.f99616c;
return i(f14, gVar, aVar, aVar);
}
public final i<T> l(g<? super T> gVar) {
g<? super Throwable> f14 = kw2.a.f();
iw2.a aVar = kw2.a.f99616c;
return i(gVar, f14, aVar, aVar);
}
public final i<T> p(iw2.l<? super T> lVar) {
b.e(lVar, "predicate is null");
return zw2.a.l(new ow2.g(this, lVar));
}
public final <R> i<R> q(iw2.j<? super T, ? extends a<? extends R>> jVar) {
return r(jVar, false, f(), f());
}
public final <R> i<R> r(iw2.j<? super T, ? extends a<? extends R>> jVar, boolean z14, int i10, int i14) {
b.e(jVar, "mapper is null");
b.f(i10, "maxConcurrency");
b.f(i14, "bufferSize");
if (!(this instanceof lw2.g)) {
return zw2.a.l(new h(this, jVar, z14, i10, i14));
}
Object call = ((lw2.g) this).call();
if (call == null) {
return m();
}
return y.a(call, jVar);
}
public final <R> i<R> s(iw2.j<? super T, ? extends q<? extends R>> jVar) {
return t(jVar, false, Integer.MAX_VALUE);
}
public final <R> i<R> t(iw2.j<? super T, ? extends q<? extends R>> jVar, boolean z14, int i10) {
b.e(jVar, "mapper is null");
b.f(i10, "maxConcurrency");
return zw2.a.l(new ow2.i(this, jVar, z14, i10));
}
public final <R> i<R> x(iw2.j<? super T, ? extends R> jVar) {
b.e(jVar, "mapper is null");
return zw2.a.l(new o(this, jVar));
}
public final i<T> y(z zVar) {
return z(zVar, false, f());
}
public final i<T> z(z zVar, boolean z14, int i10) {
b.e(zVar, "scheduler is null");
b.f(i10, "bufferSize");
return zw2.a.l(new p(this, zVar, z14, i10));
}
}