package o.a;

import g.h.a.i;
import java.util.Objects;
import java.util.concurrent.TimeUnit;
import o.a.h.e.a.e;

/* JADX INFO: loaded from: classes.dex */
public abstract class b<T> {
    public static b<Long> b(long j2, long j3, TimeUnit timeUnit) {
        d dVar = o.a.i.a.a;
        Objects.requireNonNull(timeUnit, "unit is null");
        Objects.requireNonNull(dVar, "scheduler is null");
        return new o.a.h.e.a.c(Math.max(0L, j2), Math.max(0L, j3), timeUnit, dVar);
    }

    public final b<T> a(o.a.g.b<? super T> bVar) {
        o.a.g.b<Object> bVar2 = o.a.h.b.a.f5974c;
        o.a.g.a aVar = o.a.h.b.a.f5973b;
        return new o.a.h.e.a.b(this, bVar, bVar2, aVar, aVar);
    }

    public final b<T> c(d dVar) {
        int i2 = a.a;
        Objects.requireNonNull(dVar, "scheduler is null");
        if (i2 > 0) {
            return new e(this, dVar, false, i2);
        }
        throw new IllegalArgumentException("bufferSize > 0 required but it was " + i2);
    }

    public final o.a.e.b d(o.a.g.b<? super T> bVar, o.a.g.b<? super Throwable> bVar2) {
        o.a.g.a aVar = o.a.h.b.a.f5973b;
        o.a.g.b<Object> bVar3 = o.a.h.b.a.f5974c;
        Objects.requireNonNull(bVar, "onNext is null");
        Objects.requireNonNull(bVar2, "onError is null");
        o.a.h.d.b bVar4 = new o.a.h.d.b(bVar, bVar2, aVar, bVar3);
        e(bVar4);
        return bVar4;
    }

    public final void e(c<? super T> cVar) {
        Objects.requireNonNull(cVar, "observer is null");
        try {
            f(cVar);
        } catch (NullPointerException e2) {
            throw e2;
        } catch (Throwable th) {
            i.F3(th);
            i.P2(th);
            NullPointerException nullPointerException = new NullPointerException("Actually not, but can't throw other exceptions due to RS");
            nullPointerException.initCause(th);
            throw nullPointerException;
        }
    }

    public abstract void f(c<? super T> cVar);
}