package d.a;

import a.a.a.a.c.n0;
import d.a.s.e.c.p;
import d.a.s.e.c.q;
import d.a.s.e.c.r;
import java.util.NoSuchElementException;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: loaded from: classes.dex */
public abstract class h<T> implements k<T> {
    public static h<Long> i(long j2, long j3, TimeUnit timeUnit) {
        return j(j2, j3, timeUnit, d.a.v.a.f5912b);
    }

    public static h<Long> j(long j2, long j3, TimeUnit timeUnit, m mVar) {
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(mVar, "scheduler is null");
        return new d.a.s.e.c.g(Math.max(0L, j2), Math.max(0L, j3), timeUnit, mVar);
    }

    public static <T> h<T> k(T t) {
        Objects.requireNonNull(t, "The item is null");
        return new d.a.s.e.c.h(t);
    }

    public static h<Long> r(long j2, TimeUnit timeUnit) {
        m mVar = d.a.v.a.f5912b;
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(mVar, "scheduler is null");
        return new r(Math.max(j2, 0L), timeUnit, mVar);
    }

    @Override // d.a.k
    public final void e(l<? super T> lVar) {
        Objects.requireNonNull(lVar, "observer is null");
        try {
            o(lVar);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            n0.y(th);
            d.a.u.a.v(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public final T f() {
        d.a.s.d.b bVar = new d.a.s.d.b();
        e(bVar);
        T t = (T) bVar.e();
        if (t != null) {
            return t;
        }
        throw new NoSuchElementException();
    }

    public final void g() {
        d.a.s.h.c cVar = new d.a.s.h.c();
        d.a.r.b<Object> bVar = d.a.s.b.a.f5673c;
        d.a.s.d.d dVar = new d.a.s.d.d(bVar, cVar, cVar, bVar);
        e(dVar);
        if (cVar.getCount() != 0) {
            try {
                cVar.await();
            } catch (InterruptedException e2) {
                d.a.s.a.b.dispose(dVar);
                Thread.currentThread().interrupt();
                throw new IllegalStateException("Interrupted while waiting for subscription to complete.", e2);
            }
        }
        Throwable th = cVar.f5897b;
        if (th != null) {
            throw d.a.s.h.d.a(th);
        }
    }

    public final h<T> h(long j2, TimeUnit timeUnit) {
        m mVar = d.a.v.a.f5912b;
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(mVar, "scheduler is null");
        return new d.a.s.e.c.c(this, j2, timeUnit, mVar, false);
    }

    public final h<T> l(m mVar) {
        int i2 = e.f5647b;
        Objects.requireNonNull(mVar, "scheduler is null");
        d.a.s.b.b.a(i2, "bufferSize");
        return new d.a.s.e.c.i(this, mVar, false, i2);
    }

    public final h<T> m(d.a.r.c<? super h<Throwable>, ? extends k<?>> cVar) {
        return new d.a.s.e.c.k(this, cVar);
    }

    public final d.a.p.b n(d.a.r.b<? super T> bVar, d.a.r.b<? super Throwable> bVar2, d.a.r.a aVar, d.a.r.b<? super d.a.p.b> bVar3) {
        Objects.requireNonNull(bVar, "onNext is null");
        Objects.requireNonNull(bVar2, "onError is null");
        Objects.requireNonNull(aVar, "onComplete is null");
        Objects.requireNonNull(bVar3, "onSubscribe is null");
        d.a.s.d.d dVar = new d.a.s.d.d(bVar, bVar2, aVar, bVar3);
        e(dVar);
        return dVar;
    }

    public abstract void o(l<? super T> lVar);

    public final h<T> p(m mVar) {
        Objects.requireNonNull(mVar, "scheduler is null");
        return new p(this, mVar);
    }

    public final h<T> q(long j2, TimeUnit timeUnit, k<? extends T> kVar, m mVar) {
        Objects.requireNonNull(timeUnit, "timeUnit is null");
        Objects.requireNonNull(mVar, "scheduler is null");
        return new q(this, j2, timeUnit, mVar, kVar);
    }
}