package o;

import io.reactivex.rxjava3.exceptions.CompositeException;

/* renamed from: o.fUm, reason: case insensitive filesystem */
/* loaded from: classes6.dex */
public final class C13234fUm extends fRY {
    final fSP a;
    final fSP b;
    final fSQ<? super Throwable> c;
    final fSQ<? super fSJ> d;
    final fSP e;
    final fSP i;
    private fRZ j;

    public C13234fUm(fRZ frz, fSQ<? super fSJ> fsq, fSQ<? super Throwable> fsq2, fSP fsp, fSP fsp2, fSP fsp3, fSP fsp4) {
        this.j = frz;
        this.d = fsq;
        this.c = fsq2;
        this.e = fsp;
        this.i = fsp2;
        this.a = fsp3;
        this.b = fsp4;
    }

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

    /* renamed from: o.fUm$Sts */
    /* loaded from: classes6.dex */
    final class Sts implements InterfaceC13154fSb, fSJ {
        private C13234fUm b;
        private InterfaceC13154fSb c;
        private fSJ d;

        Sts(C13234fUm c13234fUm, InterfaceC13154fSb interfaceC13154fSb) {
            this.b = c13234fUm;
            this.c = interfaceC13154fSb;
        }

        @Override // o.InterfaceC13154fSb
        public final void onSubscribe(fSJ fsj) {
            try {
                this.b.d.c(fsj);
                if (EnumC13192fTf.d(this.d, fsj)) {
                    this.d = fsj;
                    this.c.onSubscribe(this);
                }
            } catch (Throwable th) {
                C13147fSI.c(th);
                fsj.dispose();
                this.d = EnumC13192fTf.DISPOSED;
                EnumC13195fTi.c(th, this.c);
            }
        }

        @Override // o.InterfaceC13154fSb
        public final void onError(Throwable th) {
            if (this.d == EnumC13192fTf.DISPOSED) {
                C13418fZu.c(th);
                return;
            }
            try {
                this.b.c.c(th);
                this.b.i.c();
            } catch (Throwable th2) {
                C13147fSI.c(th2);
                th = new CompositeException(th, th2);
            }
            this.c.onError(th);
            try {
                this.b.a.c();
            } catch (Throwable th3) {
                C13147fSI.c(th3);
                C13418fZu.c(th3);
            }
        }

        @Override // o.InterfaceC13154fSb
        public final void onComplete() {
            if (this.d == EnumC13192fTf.DISPOSED) {
                return;
            }
            try {
                this.b.e.c();
                this.b.i.c();
                this.c.onComplete();
                try {
                    this.b.a.c();
                } catch (Throwable th) {
                    C13147fSI.c(th);
                    C13418fZu.c(th);
                }
            } catch (Throwable th2) {
                C13147fSI.c(th2);
                this.c.onError(th2);
            }
        }

        @Override // o.fSJ
        public final void dispose() {
            try {
                this.b.b.c();
            } catch (Throwable th) {
                C13147fSI.c(th);
                C13418fZu.c(th);
            }
            this.d.dispose();
        }

        @Override // o.fSJ
        public final boolean isDisposed() {
            return this.d.isDisposed();
        }
    }
}