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

package o;

import java.util.concurrent.atomic.AtomicReference;

/* renamed from: o.fUf, reason: case insensitive filesystem */
/* loaded from: classes6.dex */
public final class C13227fUf extends fRY {
    private fRZ c;
    private fRZ d;

    public C13227fUf(fRZ frz, fRZ frz2) {
        this.c = frz;
        this.d = frz2;
    }

    @Override // o.fRY
    public final void c(InterfaceC13154fSb interfaceC13154fSb) {
        this.c.e(new Sts(interfaceC13154fSb, this.d));
    }

    /* renamed from: o.fUf$Sts */
    /* loaded from: classes6.dex */
    static final class Sts extends AtomicReference<fSJ> implements InterfaceC13154fSb, fSJ {
        private fRZ b;
        private InterfaceC13154fSb d;

        Sts(InterfaceC13154fSb interfaceC13154fSb, fRZ frz) {
            this.d = interfaceC13154fSb;
            this.b = frz;
        }

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

        @Override // o.InterfaceC13154fSb
        public final void onError(Throwable th) {
            this.d.onError(th);
        }

        @Override // o.InterfaceC13154fSb
        public final void onComplete() {
            this.b.e(new RVV(this, this.d));
        }

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

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

    /* renamed from: o.fUf$RVV */
    /* loaded from: classes6.dex */
    static final class RVV implements InterfaceC13154fSb {
        private AtomicReference<fSJ> c;
        private InterfaceC13154fSb d;

        RVV(AtomicReference<fSJ> atomicReference, InterfaceC13154fSb interfaceC13154fSb) {
            this.c = atomicReference;
            this.d = interfaceC13154fSb;
        }

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

        @Override // o.InterfaceC13154fSb
        public final void onComplete() {
            this.d.onComplete();
        }

        @Override // o.InterfaceC13154fSb
        public final void onError(Throwable th) {
            this.d.onError(th);
        }
    }
}