package e.a;

import e.a.u.e.b.q;
import e.a.u.e.b.r;
import e.a.u.e.b.s;
import e.a.u.e.b.t;
import e.a.u.e.b.u;
import e.a.u.e.b.v;
import e.a.u.e.b.w;
import e.a.u.e.b.x;
import e.a.u.e.b.y;
import java.util.concurrent.Callable;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: Observable.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class h<T> implements k<T> {

    /* JADX INFO: compiled from: Observable.java */
    static /* synthetic */ class a {
        static final /* synthetic */ int[] a;

        static {
            int[] iArr = new int[e.a.a.values().length];
            a = iArr;
            try {
                iArr[e.a.a.DROP.ordinal()] = 1;
            } catch (NoSuchFieldError unused) {
            }
            try {
                a[e.a.a.LATEST.ordinal()] = 2;
            } catch (NoSuchFieldError unused2) {
            }
            try {
                a[e.a.a.MISSING.ordinal()] = 3;
            } catch (NoSuchFieldError unused3) {
            }
            try {
                a[e.a.a.ERROR.ordinal()] = 4;
            } catch (NoSuchFieldError unused4) {
            }
        }
    }

    public static h<Long> A(long j2, long j3, TimeUnit timeUnit, n nVar) {
        e.a.u.b.b.d(timeUnit, "unit is null");
        e.a.u.b.b.d(nVar, "scheduler is null");
        return e.a.w.a.m(new e.a.u.e.b.m(Math.max(0L, j2), Math.max(0L, j3), timeUnit, nVar));
    }

    public static h<Long> B(long j2, TimeUnit timeUnit) {
        return A(j2, j2, timeUnit, e.a.x.a.a());
    }

    public static h<Long> C(long j2, long j3, long j4, long j5, TimeUnit timeUnit) {
        return D(j2, j3, j4, j5, timeUnit, e.a.x.a.a());
    }

    public static h<Long> D(long j2, long j3, long j4, long j5, TimeUnit timeUnit, n nVar) {
        if (j3 < 0) {
            throw new IllegalArgumentException("count >= 0 required but it was " + j3);
        }
        if (j3 == 0) {
            return q().j(j4, timeUnit, nVar);
        }
        long j6 = j2 + (j3 - 1);
        if (j2 > 0 && j6 < 0) {
            throw new IllegalArgumentException("Overflow! start + count is bigger than Long.MAX_VALUE");
        }
        e.a.u.b.b.d(timeUnit, "unit is null");
        e.a.u.b.b.d(nVar, "scheduler is null");
        return e.a.w.a.m(new e.a.u.e.b.n(j2, j6, Math.max(0L, j4), Math.max(0L, j5), timeUnit, nVar));
    }

    public static <T> h<T> E(T t) {
        e.a.u.b.b.d(t, "The item is null");
        return e.a.w.a.m(new e.a.u.e.b.o(t));
    }

    public static h<Long> V(long j2, TimeUnit timeUnit) {
        return W(j2, timeUnit, e.a.x.a.a());
    }

    public static h<Long> W(long j2, TimeUnit timeUnit, n nVar) {
        e.a.u.b.b.d(timeUnit, "unit is null");
        e.a.u.b.b.d(nVar, "scheduler is null");
        return e.a.w.a.m(new y(Math.max(j2, 0L), timeUnit, nVar));
    }

    public static <T> h<T> Y(k<T> kVar) {
        e.a.u.b.b.d(kVar, "source is null");
        return kVar instanceof h ? e.a.w.a.m((h) kVar) : e.a.w.a.m(new e.a.u.e.b.k(kVar));
    }

    public static int f() {
        return e.a();
    }

    public static <T> h<T> h(j<T> jVar) {
        e.a.u.b.b.d(jVar, "source is null");
        return e.a.w.a.m(new e.a.u.e.b.b(jVar));
    }

    private h<T> l(e.a.t.c<? super T> cVar, e.a.t.c<? super Throwable> cVar2, e.a.t.a aVar, e.a.t.a aVar2) {
        e.a.u.b.b.d(cVar, "onNext is null");
        e.a.u.b.b.d(cVar2, "onError is null");
        e.a.u.b.b.d(aVar, "onComplete is null");
        e.a.u.b.b.d(aVar2, "onAfterTerminate is null");
        return e.a.w.a.m(new e.a.u.e.b.d(this, cVar, cVar2, aVar, aVar2));
    }

    public static <T> h<T> q() {
        return e.a.w.a.m(e.a.u.e.b.f.f3689b);
    }

    public static <T> h<T> r(Throwable th) {
        e.a.u.b.b.d(th, "e is null");
        return s(e.a.u.b.a.b(th));
    }

    public static <T> h<T> s(Callable<? extends Throwable> callable) {
        e.a.u.b.b.d(callable, "errorSupplier is null");
        return e.a.w.a.m(new e.a.u.e.b.g(callable));
    }

    public static <T> h<T> y(Iterable<? extends T> iterable) {
        e.a.u.b.b.d(iterable, "source is null");
        return e.a.w.a.m(new e.a.u.e.b.j(iterable));
    }

    public final <R> h<R> F(e.a.t.d<? super T, ? extends R> dVar) {
        e.a.u.b.b.d(dVar, "mapper is null");
        return e.a.w.a.m(new e.a.u.e.b.p(this, dVar));
    }

    public final h<T> G(n nVar) {
        return H(nVar, false, f());
    }

    public final h<T> H(n nVar, boolean z, int i2) {
        e.a.u.b.b.d(nVar, "scheduler is null");
        e.a.u.b.b.e(i2, "bufferSize");
        return e.a.w.a.m(new q(this, nVar, z, i2));
    }

    public final h<T> I(e.a.t.d<? super Throwable, ? extends T> dVar) {
        e.a.u.b.b.d(dVar, "valueSupplier is null");
        return e.a.w.a.m(new r(this, dVar));
    }

    public final h<T> J(T t) {
        e.a.u.b.b.d(t, "item is null");
        return I(e.a.u.b.a.c(t));
    }

    public final h<T> K(e.a.t.d<? super h<Throwable>, ? extends k<?>> dVar) {
        e.a.u.b.b.d(dVar, "handler is null");
        return e.a.w.a.m(new s(this, dVar));
    }

    public final f<T> L() {
        return e.a.w.a.l(new u(this));
    }

    public final o<T> M() {
        return e.a.w.a.n(new v(this, null));
    }

    public final e.a.r.b N() {
        return R(e.a.u.b.a.a(), e.a.u.b.a.f3643d, e.a.u.b.a.f3641b, e.a.u.b.a.a());
    }

    public final e.a.r.b O(e.a.t.c<? super T> cVar) {
        return R(cVar, e.a.u.b.a.f3643d, e.a.u.b.a.f3641b, e.a.u.b.a.a());
    }

    public final e.a.r.b P(e.a.t.c<? super T> cVar, e.a.t.c<? super Throwable> cVar2) {
        return R(cVar, cVar2, e.a.u.b.a.f3641b, e.a.u.b.a.a());
    }

    public final e.a.r.b Q(e.a.t.c<? super T> cVar, e.a.t.c<? super Throwable> cVar2, e.a.t.a aVar) {
        return R(cVar, cVar2, aVar, e.a.u.b.a.a());
    }

    public final e.a.r.b R(e.a.t.c<? super T> cVar, e.a.t.c<? super Throwable> cVar2, e.a.t.a aVar, e.a.t.c<? super e.a.r.b> cVar3) {
        e.a.u.b.b.d(cVar, "onNext is null");
        e.a.u.b.b.d(cVar2, "onError is null");
        e.a.u.b.b.d(aVar, "onComplete is null");
        e.a.u.b.b.d(cVar3, "onSubscribe is null");
        e.a.u.d.e eVar = new e.a.u.d.e(cVar, cVar2, aVar, cVar3);
        e(eVar);
        return eVar;
    }

    protected abstract void S(m<? super T> mVar);

    public final h<T> T(n nVar) {
        e.a.u.b.b.d(nVar, "scheduler is null");
        return e.a.w.a.m(new w(this, nVar));
    }

    public final h<T> U(long j2) {
        if (j2 >= 0) {
            return e.a.w.a.m(new x(this, j2));
        }
        throw new IllegalArgumentException("count >= 0 required but it was " + j2);
    }

    public final e<T> X(e.a.a aVar) {
        e.a.u.e.a.b bVar = new e.a.u.e.a.b(this);
        int i2 = a.a[aVar.ordinal()];
        return i2 != 1 ? i2 != 2 ? i2 != 3 ? i2 != 4 ? bVar.b() : e.a.w.a.k(new e.a.u.e.a.e(bVar)) : bVar : bVar.e() : bVar.d();
    }

    @Override // e.a.k
    public final void e(m<? super T> mVar) {
        e.a.u.b.b.d(mVar, "observer is null");
        try {
            m<? super T> mVarT = e.a.w.a.t(this, mVar);
            e.a.u.b.b.d(mVarT, "Plugin returned null Observer");
            S(mVarT);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            e.a.s.b.b(th);
            e.a.w.a.p(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final <R> h<R> g(l<? super T, ? extends R> lVar) {
        e.a.u.b.b.d(lVar, "composer is null");
        return Y(lVar.a(this));
    }

    public final h<T> i(long j2, TimeUnit timeUnit) {
        return k(j2, timeUnit, e.a.x.a.a(), false);
    }

    public final h<T> j(long j2, TimeUnit timeUnit, n nVar) {
        return k(j2, timeUnit, nVar, false);
    }

    public final h<T> k(long j2, TimeUnit timeUnit, n nVar, boolean z) {
        e.a.u.b.b.d(timeUnit, "unit is null");
        e.a.u.b.b.d(nVar, "scheduler is null");
        return e.a.w.a.m(new e.a.u.e.b.c(this, j2, timeUnit, nVar, z));
    }

    public final h<T> m(e.a.t.c<? super Throwable> cVar) {
        e.a.t.c<? super T> cVarA = e.a.u.b.a.a();
        e.a.t.a aVar = e.a.u.b.a.f3641b;
        return l(cVarA, cVar, aVar, aVar);
    }

    public final h<T> n(e.a.t.c<? super e.a.r.b> cVar, e.a.t.a aVar) {
        e.a.u.b.b.d(cVar, "onSubscribe is null");
        e.a.u.b.b.d(aVar, "onDispose is null");
        return e.a.w.a.m(new e.a.u.e.b.e(this, cVar, aVar));
    }

    public final h<T> o(e.a.t.c<? super T> cVar) {
        e.a.t.c<? super Throwable> cVarA = e.a.u.b.a.a();
        e.a.t.a aVar = e.a.u.b.a.f3641b;
        return l(cVar, cVarA, aVar, aVar);
    }

    public final h<T> p(e.a.t.c<? super e.a.r.b> cVar) {
        return n(cVar, e.a.u.b.a.f3641b);
    }

    public final h<T> t(e.a.t.e<? super T> eVar) {
        e.a.u.b.b.d(eVar, "predicate is null");
        return e.a.w.a.m(new e.a.u.e.b.h(this, eVar));
    }

    public final <R> h<R> u(e.a.t.d<? super T, ? extends k<? extends R>> dVar) {
        return v(dVar, false);
    }

    public final <R> h<R> v(e.a.t.d<? super T, ? extends k<? extends R>> dVar, boolean z) {
        return w(dVar, z, Integer.MAX_VALUE);
    }

    public final <R> h<R> w(e.a.t.d<? super T, ? extends k<? extends R>> dVar, boolean z, int i2) {
        return x(dVar, z, i2, f());
    }

    /* JADX WARN: Multi-variable type inference failed */
    public final <R> h<R> x(e.a.t.d<? super T, ? extends k<? extends R>> dVar, boolean z, int i2, int i3) {
        e.a.u.b.b.d(dVar, "mapper is null");
        e.a.u.b.b.e(i2, "maxConcurrency");
        e.a.u.b.b.e(i3, "bufferSize");
        if (!(this instanceof e.a.u.c.c)) {
            return e.a.w.a.m(new e.a.u.e.b.i(this, dVar, z, i2, i3));
        }
        Object objCall = ((e.a.u.c.c) this).call();
        return objCall == null ? q() : t.a(objCall, dVar);
    }

    public final b z() {
        return e.a.w.a.j(new e.a.u.e.b.l(this));
    }
}