package i.a;

import i.a.n.e.a.j;
import i.a.n.e.a.k;
import i.a.n.e.a.l;
import i.a.n.e.a.m;
import i.a.n.e.a.n;
import i.a.n.e.a.o;
import i.a.n.e.a.p;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: Observable.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class d<T> implements e<T> {
    public static <T> d<T> F(e<T> eVar) {
        i.a.n.b.b.d(eVar, "source is null");
        return eVar instanceof d ? i.a.p.a.j((d) eVar) : i.a.p.a.j(new i.a.n.e.a.h(eVar));
    }

    public static int b() {
        return b.a();
    }

    private d<T> f(i.a.m.c<? super T> cVar, i.a.m.c<? super Throwable> cVar2, i.a.m.a aVar, i.a.m.a aVar2) {
        i.a.n.b.b.d(cVar, "onNext is null");
        i.a.n.b.b.d(cVar2, "onError is null");
        i.a.n.b.b.d(aVar, "onComplete is null");
        i.a.n.b.b.d(aVar2, "onAfterTerminate is null");
        return i.a.p.a.j(new i.a.n.e.a.c(this, cVar, cVar2, aVar, aVar2));
    }

    public static <T> d<T> j() {
        return i.a.p.a.j(i.a.n.e.a.e.b);
    }

    public static d<Long> p(long j2, long j3, TimeUnit timeUnit) {
        return q(j2, j3, timeUnit, i.a.q.a.a());
    }

    public static d<Long> q(long j2, long j3, TimeUnit timeUnit, h hVar) {
        i.a.n.b.b.d(timeUnit, "unit is null");
        i.a.n.b.b.d(hVar, "scheduler is null");
        return i.a.p.a.j(new i.a.n.e.a.i(Math.max(0L, j2), Math.max(0L, j3), timeUnit, hVar));
    }

    public static d<Long> r(long j2, TimeUnit timeUnit) {
        return q(j2, j2, timeUnit, i.a.q.a.a());
    }

    public static <T> d<T> s(T t) {
        i.a.n.b.b.d(t, "The item is null");
        return i.a.p.a.j(new j(t));
    }

    public final i.a.k.b A(i.a.m.c<? super T> cVar, i.a.m.c<? super Throwable> cVar2, i.a.m.a aVar, i.a.m.c<? super i.a.k.b> cVar3) {
        i.a.n.b.b.d(cVar, "onNext is null");
        i.a.n.b.b.d(cVar2, "onError is null");
        i.a.n.b.b.d(aVar, "onComplete is null");
        i.a.n.b.b.d(cVar3, "onSubscribe is null");
        i.a.n.d.d dVar = new i.a.n.d.d(cVar, cVar2, aVar, cVar3);
        a(dVar);
        return dVar;
    }

    protected abstract void B(g<? super T> gVar);

    public final d<T> C(h hVar) {
        i.a.n.b.b.d(hVar, "scheduler is null");
        return i.a.p.a.j(new n(this, hVar));
    }

    public final d<T> D(long j2) {
        if (j2 >= 0) {
            return i.a.p.a.j(new o(this, j2));
        }
        throw new IllegalArgumentException("count >= 0 required but it was " + j2);
    }

    public final d<T> E(i.a.m.e<? super T> eVar) {
        i.a.n.b.b.d(eVar, "predicate is null");
        return i.a.p.a.j(new p(this, eVar));
    }

    @Override // i.a.e
    public final void a(g<? super T> gVar) {
        i.a.n.b.b.d(gVar, "observer is null");
        try {
            g<? super T> gVarP = i.a.p.a.p(this, gVar);
            i.a.n.b.b.d(gVarP, "Plugin returned null Observer");
            B(gVarP);
        } catch (NullPointerException e) {
            throw e;
        } catch (Throwable th) {
            i.a.l.b.b(th);
            i.a.p.a.l(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final <R> d<R> c(f<? super T, ? extends R> fVar) {
        i.a.n.b.b.d(fVar, "composer is null");
        return F(fVar.a(this));
    }

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

    public final d<T> e(long j2, TimeUnit timeUnit, h hVar, boolean z) {
        i.a.n.b.b.d(timeUnit, "unit is null");
        i.a.n.b.b.d(hVar, "scheduler is null");
        return i.a.p.a.j(new i.a.n.e.a.b(this, j2, timeUnit, hVar, z));
    }

    public final d<T> g(i.a.m.c<? super i.a.k.b> cVar, i.a.m.a aVar) {
        i.a.n.b.b.d(cVar, "onSubscribe is null");
        i.a.n.b.b.d(aVar, "onDispose is null");
        return i.a.p.a.j(new i.a.n.e.a.d(this, cVar, aVar));
    }

    public final d<T> h(i.a.m.c<? super T> cVar) {
        i.a.m.c<? super Throwable> cVarA = i.a.n.b.a.a();
        i.a.m.a aVar = i.a.n.b.a.b;
        return f(cVar, cVarA, aVar, aVar);
    }

    public final d<T> i(i.a.m.c<? super i.a.k.b> cVar) {
        return g(cVar, i.a.n.b.a.b);
    }

    public final d<T> k(i.a.m.e<? super T> eVar) {
        i.a.n.b.b.d(eVar, "predicate is null");
        return i.a.p.a.j(new i.a.n.e.a.f(this, eVar));
    }

    public final <R> d<R> l(i.a.m.d<? super T, ? extends e<? extends R>> dVar) {
        return m(dVar, false);
    }

    public final <R> d<R> m(i.a.m.d<? super T, ? extends e<? extends R>> dVar, boolean z) {
        return n(dVar, z, Integer.MAX_VALUE);
    }

    public final <R> d<R> n(i.a.m.d<? super T, ? extends e<? extends R>> dVar, boolean z, int i2) {
        return o(dVar, z, i2, b());
    }

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

    public final <R> d<R> t(i.a.m.d<? super T, ? extends R> dVar) {
        i.a.n.b.b.d(dVar, "mapper is null");
        return i.a.p.a.j(new k(this, dVar));
    }

    public final d<T> u(h hVar) {
        return v(hVar, false, b());
    }

    public final d<T> v(h hVar, boolean z, int i2) {
        i.a.n.b.b.d(hVar, "scheduler is null");
        i.a.n.b.b.e(i2, "bufferSize");
        return i.a.p.a.j(new l(this, hVar, z, i2));
    }

    public final i.a.k.b w() {
        return A(i.a.n.b.a.a(), i.a.n.b.a.d, i.a.n.b.a.b, i.a.n.b.a.a());
    }

    public final i.a.k.b x(i.a.m.c<? super T> cVar) {
        return A(cVar, i.a.n.b.a.d, i.a.n.b.a.b, i.a.n.b.a.a());
    }

    public final i.a.k.b y(i.a.m.c<? super T> cVar, i.a.m.c<? super Throwable> cVar2) {
        return A(cVar, cVar2, i.a.n.b.a.b, i.a.n.b.a.a());
    }

    public final i.a.k.b z(i.a.m.c<? super T> cVar, i.a.m.c<? super Throwable> cVar2, i.a.m.a aVar) {
        return A(cVar, cVar2, aVar, i.a.n.b.a.a());
    }
}