what-the-bank/sources/o/C13352fXz.java

package o;

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

/* renamed from: o.fXz, reason: case insensitive filesystem */
/* loaded from: classes6.dex */
public final class C13352fXz<T, U> extends fUX<T, T> {
    private InterfaceC13169fSq<? extends U> b;

    public C13352fXz(InterfaceC13169fSq<T> interfaceC13169fSq, InterfaceC13169fSq<? extends U> interfaceC13169fSq2) {
        super(interfaceC13169fSq);
        this.b = interfaceC13169fSq2;
    }

    @Override // o.AbstractC13163fSk
    public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
        RVV rvv = new RVV(interfaceC13174fSv);
        interfaceC13174fSv.onSubscribe(rvv);
        this.b.subscribe(rvv.c);
        this.c.subscribe(rvv);
    }

    /* renamed from: o.fXz$RVV */
    /* loaded from: classes6.dex */
    static final class RVV<T, U> extends AtomicInteger implements InterfaceC13174fSv<T>, fSJ {
        final InterfaceC13174fSv<? super T> a;
        final AtomicReference<fSJ> b = new AtomicReference<>();
        final RVV<T, U>.HBt c = new HBt(this);
        final C13355fYI d = new C13355fYI();

        RVV(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
            this.a = interfaceC13174fSv;
        }

        @Override // o.fSJ
        public final void dispose() {
            EnumC13192fTf.e(this.b);
            EnumC13192fTf.e(this.c);
        }

        @Override // o.fSJ
        public final boolean isDisposed() {
            return EnumC13192fTf.c(this.b.get());
        }

        @Override // o.InterfaceC13174fSv
        public final void onSubscribe(fSJ fsj) {
            EnumC13192fTf.a(this.b, fsj);
        }

        @Override // o.InterfaceC13174fSv
        public final void onNext(T t) {
            fYQ.b(this.a, t, this, this.d);
        }

        @Override // o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            EnumC13192fTf.e(this.c);
            InterfaceC13174fSv<? super T> interfaceC13174fSv = this.a;
            C13355fYI c13355fYI = this.d;
            if (fYR.c(c13355fYI, th)) {
                if (getAndIncrement() == 0) {
                    Throwable b = fYR.b(c13355fYI);
                    if (b == null) {
                        interfaceC13174fSv.onComplete();
                        return;
                    } else {
                        if (b != fYR.b) {
                            interfaceC13174fSv.onError(b);
                            return;
                        }
                        return;
                    }
                }
                return;
            }
            C13418fZu.c(th);
        }

        @Override // o.InterfaceC13174fSv
        public final void onComplete() {
            EnumC13192fTf.e(this.c);
            InterfaceC13174fSv<? super T> interfaceC13174fSv = this.a;
            C13355fYI c13355fYI = this.d;
            if (getAndIncrement() == 0) {
                Throwable b = fYR.b(c13355fYI);
                if (b == null) {
                    interfaceC13174fSv.onComplete();
                } else if (b != fYR.b) {
                    interfaceC13174fSv.onError(b);
                }
            }
        }

        final void a() {
            EnumC13192fTf.e(this.b);
            InterfaceC13174fSv<? super T> interfaceC13174fSv = this.a;
            C13355fYI c13355fYI = this.d;
            if (getAndIncrement() == 0) {
                Throwable b = fYR.b(c13355fYI);
                if (b == null) {
                    interfaceC13174fSv.onComplete();
                } else if (b != fYR.b) {
                    interfaceC13174fSv.onError(b);
                }
            }
        }

        /* renamed from: o.fXz$RVV$HBt */
        /* loaded from: classes6.dex */
        final class HBt extends AtomicReference<fSJ> implements InterfaceC13174fSv<U> {
            private RVV e;

            HBt(RVV rvv) {
                this.e = rvv;
            }

            @Override // o.InterfaceC13174fSv
            public final void onSubscribe(fSJ fsj) {
                EnumC13192fTf.a(this, fsj);
            }

            @Override // o.InterfaceC13174fSv
            public final void onNext(U u) {
                EnumC13192fTf.e(this);
                this.e.a();
            }

            @Override // o.InterfaceC13174fSv
            public final void onError(Throwable th) {
                RVV rvv = this.e;
                EnumC13192fTf.e(rvv.b);
                InterfaceC13174fSv<? super T> interfaceC13174fSv = rvv.a;
                C13355fYI c13355fYI = rvv.d;
                if (fYR.c(c13355fYI, th)) {
                    if (rvv.getAndIncrement() == 0) {
                        Throwable b = fYR.b(c13355fYI);
                        if (b == null) {
                            interfaceC13174fSv.onComplete();
                            return;
                        } else {
                            if (b != fYR.b) {
                                interfaceC13174fSv.onError(b);
                                return;
                            }
                            return;
                        }
                    }
                    return;
                }
                C13418fZu.c(th);
            }

            @Override // o.InterfaceC13174fSv
            public final void onComplete() {
                this.e.a();
            }
        }
    }
}