package d.a.s.e.c;

import a.a.a.a.c.n0;
import java.util.Objects;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: loaded from: classes.dex */
public final class k<T> extends d.a.s.e.c.a<T, T> {

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final d.a.r.c<? super d.a.h<Throwable>, ? extends d.a.k<?>> f5768c;

    public static final class a<T> extends AtomicInteger implements d.a.l<T>, d.a.p.b {

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

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public final d.a.w.c<Throwable> f5772e;

        /* JADX INFO: renamed from: h, reason: collision with root package name */
        public final d.a.k<T> f5775h;

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

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

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

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

        /* JADX INFO: renamed from: g, reason: collision with root package name */
        public final AtomicReference<d.a.p.b> f5774g = new AtomicReference<>();

        /* JADX INFO: renamed from: d.a.s.e.c.k$a$a, reason: collision with other inner class name */
        public final class C0080a extends AtomicReference<d.a.p.b> implements d.a.l<Object> {
            public C0080a() {
            }

            @Override // d.a.l
            public void a(Throwable th) {
                a aVar = a.this;
                d.a.s.a.b.dispose(aVar.f5774g);
                d.a.l<? super T> lVar = aVar.f5769b;
                d.a.s.h.b bVar = aVar.f5771d;
                if (!bVar.a(th)) {
                    d.a.u.a.w(th);
                } else if (aVar.getAndIncrement() == 0) {
                    lVar.a(bVar.b());
                }
            }

            @Override // d.a.l
            public void b() {
                a aVar = a.this;
                d.a.s.a.b.dispose(aVar.f5774g);
                d.a.l<? super T> lVar = aVar.f5769b;
                d.a.s.h.b bVar = aVar.f5771d;
                if (aVar.getAndIncrement() == 0) {
                    Throwable thB = bVar.b();
                    if (thB != null) {
                        lVar.a(thB);
                    } else {
                        lVar.b();
                    }
                }
            }

            @Override // d.a.l
            public void c(d.a.p.b bVar) {
                d.a.s.a.b.setOnce(this, bVar);
            }

            @Override // d.a.l
            public void d(Object obj) {
                a.this.e();
            }
        }

        public a(d.a.l<? super T> lVar, d.a.w.c<Throwable> cVar, d.a.k<T> kVar) {
            this.f5769b = lVar;
            this.f5772e = cVar;
            this.f5775h = kVar;
        }

        @Override // d.a.l
        public void a(Throwable th) {
            d.a.s.a.b.replace(this.f5774g, null);
            this.f5776i = false;
            this.f5772e.d(th);
        }

        @Override // d.a.l
        public void b() {
            d.a.s.a.b.dispose(this.f5773f);
            n0.n(this.f5769b, this, this.f5771d);
        }

        @Override // d.a.l
        public void c(d.a.p.b bVar) {
            d.a.s.a.b.replace(this.f5774g, bVar);
        }

        @Override // d.a.l
        public void d(T t) {
            d.a.l<? super T> lVar = this.f5769b;
            d.a.s.h.b bVar = this.f5771d;
            if (get() == 0 && compareAndSet(0, 1)) {
                lVar.d(t);
                if (decrementAndGet() != 0) {
                    Throwable thB = bVar.b();
                    if (thB != null) {
                        lVar.a(thB);
                    } else {
                        lVar.b();
                    }
                }
            }
        }

        @Override // d.a.p.b
        public void dispose() {
            d.a.s.a.b.dispose(this.f5774g);
            d.a.s.a.b.dispose(this.f5773f);
        }

        public void e() {
            if (this.f5770c.getAndIncrement() == 0) {
                while (!isDisposed()) {
                    if (!this.f5776i) {
                        this.f5776i = true;
                        this.f5775h.e(this);
                    }
                    if (this.f5770c.decrementAndGet() == 0) {
                        return;
                    }
                }
            }
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return d.a.s.a.b.isDisposed(this.f5774g.get());
        }
    }

    public k(d.a.k<T> kVar, d.a.r.c<? super d.a.h<Throwable>, ? extends d.a.k<?>> cVar) {
        super(kVar);
        this.f5768c = cVar;
    }

    @Override // d.a.h
    public void o(d.a.l<? super T> lVar) {
        d.a.w.c aVar = new d.a.w.a();
        if (!(aVar instanceof d.a.w.b)) {
            aVar = new d.a.w.b(aVar);
        }
        try {
            d.a.k<?> kVarA = this.f5768c.a(aVar);
            Objects.requireNonNull(kVarA, "The handler returned a null ObservableSource");
            d.a.k<?> kVar = kVarA;
            a aVar2 = new a(lVar, aVar, this.f5703b);
            lVar.c(aVar2);
            kVar.e(aVar2.f5773f);
            aVar2.e();
        } catch (Throwable th) {
            n0.y(th);
            d.a.s.a.c.error(th, lVar);
        }
    }
}