package f.a;

import f.a.w.e.d.a0;
import f.a.w.e.d.c0;
import f.a.w.e.d.g0;
import f.a.w.e.d.i0;
import f.a.w.e.d.j0;
import f.a.w.e.d.k0;
import f.a.w.e.d.t;
import f.a.w.e.d.v;
import f.a.w.e.d.z;
import java.util.NoSuchElementException;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: Observable.java */
/* JADX INFO: loaded from: classes.dex */
public abstract class i<T> implements l<T> {
    public static i<Long> B(long j2, TimeUnit timeUnit) {
        o oVar = f.a.z.a.f4043b;
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(oVar, "scheduler is null");
        return new k0(Math.max(j2, 0L), timeUnit, oVar);
    }

    public static <T> i<T> h(k<T> kVar) {
        Objects.requireNonNull(kVar, "source is null");
        return new f.a.w.e.d.c(kVar);
    }

    public static i<Long> l(long j2, TimeUnit timeUnit) {
        o oVar = f.a.z.a.f4043b;
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(oVar, "scheduler is null");
        return new f.a.w.e.d.q(Math.max(0L, j2), Math.max(0L, j2), timeUnit, oVar);
    }

    public static <T> i<T> m(T t) {
        Objects.requireNonNull(t, "item is null");
        return new f.a.w.e.d.r(t);
    }

    public final i<T> A(long j2, TimeUnit timeUnit, l<? extends T> lVar, o oVar) {
        Objects.requireNonNull(timeUnit, "timeUnit is null");
        Objects.requireNonNull(oVar, "scheduler is null");
        return new j0(this, j2, timeUnit, oVar, lVar);
    }

    public final e<T> C(a aVar) {
        f.a.w.e.b.b bVar = new f.a.w.e.b.b(this);
        int iOrdinal = aVar.ordinal();
        if (iOrdinal == 0) {
            return bVar;
        }
        if (iOrdinal == 1) {
            return new f.a.w.e.b.e(bVar);
        }
        if (iOrdinal == 3) {
            return new f.a.w.e.b.d(bVar);
        }
        if (iOrdinal == 4) {
            return new f.a.w.e.b.f(bVar);
        }
        int i2 = e.f3697b;
        f.a.w.b.b.a(i2, "capacity");
        return new f.a.w.e.b.c(bVar, i2, true, false, f.a.w.b.a.f3725b);
    }

    @Override // f.a.l
    public final void d(n<? super T> nVar) {
        Objects.requireNonNull(nVar, "observer is null");
        try {
            v(nVar);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            d.i.c.a.L(th);
            f.a.y.a.C0(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() {
        f.a.w.d.c cVar = new f.a.w.d.c();
        d(cVar);
        if (cVar.getCount() != 0) {
            try {
                cVar.await();
            } catch (InterruptedException e2) {
                cVar.dispose();
                throw f.a.w.h.c.a(e2);
            }
        }
        Throwable th = cVar.f3737e;
        if (th != null) {
            throw f.a.w.h.c.a(th);
        }
        T t = cVar.f3736b;
        if (t != null) {
            return t;
        }
        throw new NoSuchElementException();
    }

    public final <R> i<R> g(m<? super T, ? extends R> mVar) {
        Objects.requireNonNull(mVar, "composer is null");
        l<? extends R> lVarApply = mVar.apply(this);
        Objects.requireNonNull(lVarApply, "source is null");
        return lVarApply instanceof i ? (i) lVarApply : new f.a.w.e.d.n(lVarApply);
    }

    public final i<T> i(f.a.v.c<? super T> cVar, f.a.v.c<? super Throwable> cVar2, f.a.v.a aVar, f.a.v.a aVar2) {
        Objects.requireNonNull(cVar, "onNext is null");
        Objects.requireNonNull(cVar2, "onError is null");
        Objects.requireNonNull(aVar, "onComplete is null");
        return new f.a.w.e.d.f(this, cVar, cVar2, aVar, aVar2);
    }

    public final i<T> j(f.a.v.e<? super T> eVar) {
        Objects.requireNonNull(eVar, "predicate is null");
        return new f.a.w.e.d.k(this, eVar);
    }

    /* JADX WARN: Multi-variable type inference failed */
    public final <R> i<R> k(f.a.v.d<? super T, ? extends l<? extends R>> dVar) {
        int i2 = e.f3697b;
        f.a.w.b.b.a(Integer.MAX_VALUE, "maxConcurrency");
        f.a.w.b.b.a(i2, "bufferSize");
        if (!(this instanceof f.a.w.c.b)) {
            return new f.a.w.e.d.l(this, dVar, false, Integer.MAX_VALUE, i2);
        }
        Object objCall = ((f.a.w.c.b) this).call();
        return objCall == null ? (i<R>) f.a.w.e.d.i.f3803b : new c0(objCall, dVar);
    }

    public final i<T> n(o oVar) {
        int i2 = e.f3697b;
        Objects.requireNonNull(oVar, "scheduler is null");
        f.a.w.b.b.a(i2, "bufferSize");
        return new t(this, oVar, false, i2);
    }

    public final i<T> o(f.a.v.d<? super Throwable, ? extends T> dVar) {
        Objects.requireNonNull(dVar, "valueSupplier is null");
        return new v(this, dVar);
    }

    public final i<T> p() {
        return r(Long.MAX_VALUE, f.a.w.b.a.f3728e);
    }

    public final i<T> q(long j2) {
        return r(j2, f.a.w.b.a.f3728e);
    }

    public final i<T> r(long j2, f.a.v.e<? super Throwable> eVar) {
        if (j2 >= 0) {
            return new z(this, j2, eVar);
        }
        throw new IllegalArgumentException(d.b.a.a.a.l("times >= 0 required but it was ", j2));
    }

    public final i<T> s(f.a.v.d<? super i<Throwable>, ? extends l<?>> dVar) {
        return new a0(this, dVar);
    }

    public final f.a.t.b t(f.a.v.c<? super T> cVar, f.a.v.c<? super Throwable> cVar2) {
        return u(cVar, cVar2, f.a.w.b.a.f3725b, f.a.w.b.a.f3726c);
    }

    public final f.a.t.b u(f.a.v.c<? super T> cVar, f.a.v.c<? super Throwable> cVar2, f.a.v.a aVar, f.a.v.c<? super f.a.t.b> cVar3) {
        Objects.requireNonNull(cVar, "onNext is null");
        Objects.requireNonNull(cVar2, "onError is null");
        Objects.requireNonNull(aVar, "onComplete is null");
        f.a.w.d.d dVar = new f.a.w.d.d(cVar, cVar2, aVar, cVar3);
        d(dVar);
        return dVar;
    }

    public abstract void v(n<? super T> nVar);

    public final i<T> w(o oVar) {
        Objects.requireNonNull(oVar, "scheduler is null");
        return new g0(this, oVar);
    }

    public final <U> i<T> x(l<U> lVar) {
        Objects.requireNonNull(lVar, "other is null");
        return new i0(this, lVar);
    }

    public final i<T> y(long j2, TimeUnit timeUnit) {
        return A(j2, timeUnit, null, f.a.z.a.f4043b);
    }

    public final i<T> z(long j2, TimeUnit timeUnit, l<? extends T> lVar) {
        return A(j2, timeUnit, lVar, f.a.z.a.f4043b);
    }
}