package o;

import io.reactivex.rxjava3.exceptions.CompositeException;

/* renamed from: o.fUo, reason: case insensitive filesystem */
/* loaded from: classes6.dex */
public final class C13236fUo extends fRY {
    final InterfaceC13193fTg<? super Throwable> b;
    private fRZ e;

    public C13236fUo(fRZ frz, InterfaceC13193fTg<? super Throwable> interfaceC13193fTg) {
        this.e = frz;
        this.b = interfaceC13193fTg;
    }

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

    /* renamed from: o.fUo$IeS */
    /* loaded from: classes6.dex */
    final class IeS implements InterfaceC13154fSb {
        private C13236fUo c;
        private final InterfaceC13154fSb d;

        IeS(C13236fUo c13236fUo, InterfaceC13154fSb interfaceC13154fSb) {
            this.c = c13236fUo;
            this.d = interfaceC13154fSb;
        }

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

        @Override // o.InterfaceC13154fSb
        public final void onError(Throwable th) {
            try {
                if (this.c.b.a(th)) {
                    this.d.onComplete();
                } else {
                    this.d.onError(th);
                }
            } catch (Throwable th2) {
                C13147fSI.c(th2);
                this.d.onError(new CompositeException(th, th2));
            }
        }

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