package o;

import java.util.Collection;
import java.util.Iterator;
import java.util.List;
import o.wRi;

/* renamed from: o.hJ, reason: case insensitive filesystem */
/* loaded from: classes3.dex */
public final class C15628hJ extends C15620hF {
    private final REU b;
    InterfaceC14894gbR<? super FF, C14866gag> c;
    public final InterfaceC3521azC d;
    InterfaceC14894gbR<? super Throwable, C14866gag> e;

    /* renamed from: o.hJ$LWm */
    /* loaded from: classes3.dex */
    public static final class LWm {
        private LWm() {
        }

        public /* synthetic */ LWm(byte b) {
            this();
        }
    }

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    @InterfaceC13391fZD
    public C15628hJ(InterfaceC3521azC interfaceC3521azC, REU reu) {
        super((byte) 0);
        C14957gcv.e(interfaceC3521azC, "");
        C14957gcv.e(reu, "");
        this.d = interfaceC3521azC;
        this.b = reu;
        this.c = HBt.b;
        this.e = Sts.c;
    }

    /* renamed from: o.hJ$HBt */
    /* loaded from: classes3.dex */
    static final class HBt extends AbstractC14961gcz implements InterfaceC14894gbR<FF, C14866gag> {
        public static final HBt b = new HBt();

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C14866gag invoke(FF ff) {
            C14957gcv.e(ff, "");
            return C14866gag.c;
        }

        HBt() {
            super(1);
        }
    }

    /* renamed from: o.hJ$Sts */
    /* loaded from: classes3.dex */
    static final class Sts extends AbstractC14961gcz implements InterfaceC14894gbR<Throwable, C14866gag> {
        public static final Sts c = new Sts();

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C14866gag invoke(Throwable th) {
            C14957gcv.e(th, "");
            return C14866gag.c;
        }

        Sts() {
            super(1);
        }
    }

    public final void d(InterfaceC14894gbR<? super FF, C14866gag> interfaceC14894gbR, InterfaceC14894gbR<? super Throwable, C14866gag> interfaceC14894gbR2) {
        C14957gcv.e(interfaceC14894gbR, "");
        C14957gcv.e(interfaceC14894gbR2, "");
        this.c = interfaceC14894gbR;
        this.e = interfaceC14894gbR2;
        this.b.d();
        REU reu = this.b;
        reu.d(reu.i, new IeS(this));
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    /* renamed from: o.hJ$IeS */
    /* loaded from: classes3.dex */
    public final class IeS extends wRi.LWm<jJR> {
        private C15628hJ e;

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            boolean z;
            jJR jjr = (jJR) obj;
            C14957gcv.e(jjr, "");
            super.onNext(jjr);
            if (!(!jjr.e.isEmpty())) {
                this.e.c.invoke(new FF(false, false, "", "", ""));
                return;
            }
            List<IDx> list = jjr.e;
            if (!(list instanceof Collection) || !list.isEmpty()) {
                Iterator<T> it = list.iterator();
                while (it.hasNext()) {
                    if (!(!((IDx) it.next()).c)) {
                        z = false;
                        break;
                    }
                }
            }
            z = true;
            boolean z2 = !z;
            this.e.c.invoke(new FF(z2, !jjr.b.e && z2, jjr.b.c, jjr.b.d, ((IDx) C14881gav.e((List) jjr.e)).b));
        }

        public IeS(C15628hJ c15628hJ) {
            this.e = c15628hJ;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            C14957gcv.e(th, "");
            super.onError(th);
            this.e.e.invoke(th);
        }
    }

    static {
        new LWm((byte) 0);
    }
}