package f.a.w.e.d;

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

/* JADX INFO: compiled from: ObservableRetryWhen.java */
/* JADX INFO: loaded from: classes.dex */
public final class a0<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.d<? super f.a.i<Throwable>, ? extends f.a.l<?>> f3745e;

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

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

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public final f.a.a0.d<Throwable> f3749g;

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

        /* JADX INFO: renamed from: k, reason: collision with root package name */
        public volatile boolean f3753k;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final AtomicInteger f3747e = new AtomicInteger();

        /* JADX INFO: renamed from: f, reason: collision with root package name */
        public final f.a.w.h.b f3748f = new f.a.w.h.b();

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        public final a<T>.C0067a f3750h = new C0067a();

        /* JADX INFO: renamed from: i, reason: collision with root package name */
        public final AtomicReference<f.a.t.b> f3751i = new AtomicReference<>();

        /* JADX INFO: renamed from: f.a.w.e.d.a0$a$a, reason: collision with other inner class name */
        /* JADX INFO: compiled from: ObservableRetryWhen.java */
        public final class C0067a extends AtomicReference<f.a.t.b> implements f.a.n<Object> {
            public C0067a() {
            }

            @Override // f.a.n
            public void a(Throwable th) {
                a aVar = a.this;
                f.a.w.a.b.dispose(aVar.f3751i);
                d.i.c.a.D(aVar.f3746b, th, aVar, aVar.f3748f);
            }

            @Override // f.a.n
            public void b(f.a.t.b bVar) {
                f.a.w.a.b.setOnce(this, bVar);
            }

            @Override // f.a.n
            public void c(Object obj) {
                a.this.d();
            }

            @Override // f.a.n
            public void onComplete() {
                a aVar = a.this;
                f.a.w.a.b.dispose(aVar.f3751i);
                d.i.c.a.C(aVar.f3746b, aVar, aVar.f3748f);
            }
        }

        public a(f.a.n<? super T> nVar, f.a.a0.d<Throwable> dVar, f.a.l<T> lVar) {
            this.f3746b = nVar;
            this.f3749g = dVar;
            this.f3752j = lVar;
        }

        @Override // f.a.n
        public void a(Throwable th) {
            f.a.w.a.b.replace(this.f3751i, null);
            this.f3753k = false;
            this.f3749g.c(th);
        }

        @Override // f.a.n
        public void b(f.a.t.b bVar) {
            f.a.w.a.b.replace(this.f3751i, bVar);
        }

        @Override // f.a.n
        public void c(T t) {
            d.i.c.a.E(this.f3746b, t, this, this.f3748f);
        }

        public void d() {
            if (this.f3747e.getAndIncrement() == 0) {
                while (!f.a.w.a.b.isDisposed(this.f3751i.get())) {
                    if (!this.f3753k) {
                        this.f3753k = true;
                        this.f3752j.d(this);
                    }
                    if (this.f3747e.decrementAndGet() == 0) {
                        return;
                    }
                }
            }
        }

        @Override // f.a.t.b
        public void dispose() {
            f.a.w.a.b.dispose(this.f3751i);
            f.a.w.a.b.dispose(this.f3750h);
        }

        @Override // f.a.n
        public void onComplete() {
            f.a.w.a.b.dispose(this.f3750h);
            d.i.c.a.C(this.f3746b, this, this.f3748f);
        }
    }

    public a0(f.a.l<T> lVar, f.a.v.d<? super f.a.i<Throwable>, ? extends f.a.l<?>> dVar) {
        super(lVar);
        this.f3745e = dVar;
    }

    @Override // f.a.i
    public void v(f.a.n<? super T> nVar) {
        f.a.a0.d bVar = new f.a.a0.b();
        if (!(bVar instanceof f.a.a0.c)) {
            bVar = new f.a.a0.c(bVar);
        }
        try {
            f.a.l<?> lVarApply = this.f3745e.apply(bVar);
            Objects.requireNonNull(lVarApply, "The handler returned a null ObservableSource");
            f.a.l<?> lVar = lVarApply;
            a aVar = new a(nVar, bVar, this.f3744b);
            nVar.b(aVar);
            lVar.d(aVar.f3750h);
            aVar.d();
        } catch (Throwable th) {
            d.i.c.a.L(th);
            f.a.w.a.c.error(th, nVar);
        }
    }
}