package c.a;

import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: Single.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class h<T> implements l<T> {
    public static <T> h<T> c(k<T> kVar) {
        c.a.q.b.b.c(kVar, "source is null");
        return c.a.r.a.l(new c.a.q.e.b.a(kVar));
    }

    public static <T> h<T> f(T t) {
        c.a.q.b.b.c(t, "value is null");
        return c.a.r.a.l(new c.a.q.e.b.c(t));
    }

    private h<T> m(long j, TimeUnit timeUnit, g gVar, l<? extends T> lVar) {
        c.a.q.b.b.c(timeUnit, "unit is null");
        c.a.q.b.b.c(gVar, "scheduler is null");
        return c.a.r.a.l(new c.a.q.e.b.f(this, j, timeUnit, gVar, lVar));
    }

    @Override // c.a.l
    public final void a(j<? super T> jVar) {
        c.a.q.b.b.c(jVar, "subscriber is null");
        j<? super T> jVarS = c.a.r.a.s(this, jVar);
        c.a.q.b.b.c(jVarS, "subscriber returned by the RxJavaPlugins hook is null");
        try {
            k(jVarS);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            c.a.o.b.b(th);
            NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final T b() {
        c.a.q.d.b bVar = new c.a.q.d.b();
        a(bVar);
        return (T) bVar.e();
    }

    public final h<T> d(long j, TimeUnit timeUnit) {
        return e(j, timeUnit, c.a.s.a.a());
    }

    public final h<T> e(long j, TimeUnit timeUnit, g gVar) {
        c.a.q.b.b.c(timeUnit, "unit is null");
        c.a.q.b.b.c(gVar, "scheduler is null");
        return c.a.r.a.l(new c.a.q.e.b.b(this, j, timeUnit, gVar));
    }

    public final <R> h<R> g(c.a.p.f<? super T, ? extends R> fVar) {
        c.a.q.b.b.c(fVar, "mapper is null");
        return c.a.r.a.l(new c.a.q.e.b.d(this, fVar));
    }

    public final h<T> h(g gVar) {
        c.a.q.b.b.c(gVar, "scheduler is null");
        return c.a.r.a.l(new c.a.q.e.b.e(this, gVar));
    }

    public final c.a.n.b i(c.a.p.e<? super T> eVar) {
        return j(eVar, c.a.q.b.a.f1743f);
    }

    public final c.a.n.b j(c.a.p.e<? super T> eVar, c.a.p.e<? super Throwable> eVar2) {
        c.a.q.b.b.c(eVar, "onSuccess is null");
        c.a.q.b.b.c(eVar2, "onError is null");
        c.a.q.d.c cVar = new c.a.q.d.c(eVar, eVar2);
        a(cVar);
        return cVar;
    }

    protected abstract void k(j<? super T> jVar);

    public final h<T> l(long j, TimeUnit timeUnit, l<? extends T> lVar) {
        c.a.q.b.b.c(lVar, "other is null");
        return m(j, timeUnit, c.a.s.a.a(), lVar);
    }
}