package f.a.w.e.d;

import java.util.Objects;
import java.util.concurrent.atomic.AtomicInteger;

/* JADX INFO: compiled from: ObservableRetryPredicate.java */
/* JADX INFO: loaded from: classes.dex */
public final class z<T> extends f.a.w.e.d.a<T, T> {

    /* JADX INFO: renamed from: e, reason: collision with root package name */
    public final f.a.v.e<? super Throwable> f3913e;

    /* JADX INFO: renamed from: f, reason: collision with root package name */
    public final long f3914f;

    /* JADX INFO: compiled from: ObservableRetryPredicate.java */
    public static final class a<T> extends AtomicInteger implements f.a.n<T> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final f.a.n<? super T> f3915b;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final f.a.w.a.f f3916e;

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final f.a.l<? extends T> f3917f;

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public final f.a.v.e<? super Throwable> f3918g;

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        public long f3919h;

        public a(f.a.n<? super T> nVar, long j2, f.a.v.e<? super Throwable> eVar, f.a.w.a.f fVar, f.a.l<? extends T> lVar) {
            this.f3915b = nVar;
            this.f3916e = fVar;
            this.f3917f = lVar;
            this.f3918g = eVar;
            this.f3919h = j2;
        }

        @Override // f.a.n
        public void a(Throwable th) {
            long j2 = this.f3919h;
            if (j2 != Long.MAX_VALUE) {
                this.f3919h = j2 - 1;
            }
            if (j2 == 0) {
                this.f3915b.a(th);
                return;
            }
            try {
                if (this.f3918g.test(th)) {
                    d();
                } else {
                    this.f3915b.a(th);
                }
            } catch (Throwable th2) {
                d.i.c.a.L(th2);
                this.f3915b.a(new f.a.u.a(th, th2));
            }
        }

        @Override // f.a.n
        public void b(f.a.t.b bVar) {
            f.a.w.a.f fVar = this.f3916e;
            Objects.requireNonNull(fVar);
            f.a.w.a.b.replace(fVar, bVar);
        }

        @Override // f.a.n
        public void c(T t) {
            this.f3915b.c(t);
        }

        public void d() {
            if (getAndIncrement() == 0) {
                int iAddAndGet = 1;
                while (!f.a.w.a.b.isDisposed(this.f3916e.get())) {
                    this.f3917f.d(this);
                    iAddAndGet = addAndGet(-iAddAndGet);
                    if (iAddAndGet == 0) {
                        return;
                    }
                }
            }
        }

        @Override // f.a.n
        public void onComplete() {
            this.f3915b.onComplete();
        }
    }

    public z(f.a.i<T> iVar, long j2, f.a.v.e<? super Throwable> eVar) {
        super(iVar);
        this.f3913e = eVar;
        this.f3914f = j2;
    }

    @Override // f.a.i
    public void v(f.a.n<? super T> nVar) {
        f.a.w.a.f fVar = new f.a.w.a.f();
        nVar.b(fVar);
        new a(nVar, this.f3914f, this.f3913e, fVar, this.f3744b).d();
    }
}