package f.a;

import java.util.concurrent.TimeUnit;

/* JADX WARN: Unexpected interfaces in signature: [java.lang.Object<T>] */
/* JADX INFO: compiled from: Single.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class h<T> {
    public static h<Long> e(long j2, TimeUnit timeUnit) {
        return f(j2, timeUnit, f.a.q.a.a());
    }

    public static h<Long> f(long j2, TimeUnit timeUnit, g gVar) {
        f.a.n.b.b.d(timeUnit, "unit is null");
        f.a.n.b.b.d(gVar, "scheduler is null");
        return f.a.p.a.k(new f.a.n.e.b.a(j2, timeUnit, gVar));
    }

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

    public final f.a.k.b b(f.a.m.c<? super T> cVar, f.a.m.c<? super Throwable> cVar2) {
        f.a.n.b.b.d(cVar, "onSuccess is null");
        f.a.n.b.b.d(cVar2, "onError is null");
        f.a.n.d.b bVar = new f.a.n.d.b(cVar, cVar2);
        c(bVar);
        return bVar;
    }

    public final void c(i<? super T> iVar) {
        f.a.n.b.b.d(iVar, "subscriber is null");
        i<? super T> iVarQ = f.a.p.a.q(this, iVar);
        f.a.n.b.b.d(iVarQ, "subscriber returned by the RxJavaPlugins hook is null");
        try {
            d(iVarQ);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            f.a.l.b.b(th);
            NullPointerException nullPointerException = new NullPointerException("subscribeActual failed");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    protected abstract void d(i<? super T> iVar);
}