package o;

import java.util.concurrent.atomic.AtomicReference;

/* renamed from: o.fXl, reason: case insensitive filesystem */
/* loaded from: classes.dex */
public final class C13338fXl<T> extends fUX<T, T> {
    private AbstractC13173fSu d;

    public C13338fXl(InterfaceC13169fSq<T> interfaceC13169fSq, AbstractC13173fSu abstractC13173fSu) {
        super(interfaceC13169fSq);
        this.d = abstractC13173fSu;
    }

    @Override // o.AbstractC13163fSk
    public final void subscribeActual(InterfaceC13174fSv<? super T> interfaceC13174fSv) {
        RVV rvv = new RVV(interfaceC13174fSv);
        interfaceC13174fSv.onSubscribe(rvv);
        EnumC13192fTf.a(rvv, this.d.a(new IeS(this, rvv)));
    }

    /* renamed from: o.fXl$RVV */
    /* loaded from: classes6.dex */
    static final class RVV<T> extends AtomicReference<fSJ> implements InterfaceC13174fSv<T>, fSJ {
        private InterfaceC13174fSv<? super T> b;
        private AtomicReference<fSJ> e = new AtomicReference<>();

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

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

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

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

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

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

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

    /* renamed from: o.fXl$IeS */
    /* loaded from: classes6.dex */
    final class IeS implements Runnable {
        private final RVV<T> b;
        private C13338fXl c;

        IeS(C13338fXl c13338fXl, RVV<T> rvv) {
            this.c = c13338fXl;
            this.b = rvv;
        }

        @Override // java.lang.Runnable
        public final void run() {
            this.c.c.subscribe(this.b);
        }
    }
}