package o;

import java.util.List;
import java.util.Objects;
import o.C6154cKe;
import o.InterfaceC6673cZp;
import o.ZI;
import o.wRi;

/* renamed from: o.cKe, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public class C6154cKe extends ZI<InterfaceC6673cZp.IeS> {
    public final C16124lSp a;
    private final C0289Dh c;
    private final CN e;

    @InterfaceC13391fZD
    public C6154cKe(C16124lSp c16124lSp, CN cn, C16903sI c16903sI, C0289Dh c0289Dh) {
        super(c16903sI);
        this.c = c0289Dh;
        this.e = cn;
        this.a = c16124lSp;
    }

    /* renamed from: o.cKe$RVV */
    /* loaded from: classes4.dex */
    public final class RVV extends wRi.LWm<List<C1019Twi>> {
        private C6154cKe d;

        private RVV(C6154cKe c6154cKe) {
            this.d = c6154cKe;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final List list = (List) obj;
            C6154cKe.d(this.d);
            if (this.d.f != 0) {
                if (list == null || list.isEmpty()) {
                    C6154cKe c6154cKe = this.d;
                    ZI.IeS ieS = new ZI.IeS() { // from class: o.cKn
                        @Override // o.ZI.IeS
                        public final void e(Object obj2) {
                            ((InterfaceC6673cZp.IeS) obj2).c();
                        }
                    };
                    if (c6154cKe.f != 0) {
                        ieS.e(c6154cKe.f);
                        return;
                    }
                    return;
                }
                C6154cKe c6154cKe2 = this.d;
                ZI.IeS ieS2 = new ZI.IeS(this, list) { // from class: o.cKl
                    private List a;
                    private C6154cKe.RVV b;

                    @Override // o.ZI.IeS
                    public final void e(Object obj2) {
                        C6154cKe.RVV.e(this.b, this.a, (InterfaceC6673cZp.IeS) obj2);
                    }

                    {
                        this.b = this;
                        this.a = list;
                    }
                };
                if (c6154cKe2.f != 0) {
                    ieS2.e(c6154cKe2.f);
                }
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            C6154cKe.c(this.d, th);
        }

        public static /* synthetic */ void e(RVV rvv, List list, InterfaceC6673cZp.IeS ieS) {
            C0289Dh unused = rvv.d.c;
            C0289Dh c0289Dh = rvv.d.c;
            Objects.requireNonNull(c0289Dh);
            ieS.b((List) C16157lj.c(new Object[]{list, new C17631yW(c0289Dh)}, -1846295624, 1846295631, (int) System.currentTimeMillis()));
        }

        public /* synthetic */ RVV(C6154cKe c6154cKe, byte b) {
            this(c6154cKe);
        }
    }

    public static /* synthetic */ void e(C6154cKe c6154cKe, C1182Xi c1182Xi, InterfaceC6673cZp.IeS ieS) {
        CN cn = c6154cKe.e;
        ieS.d(CN.c(c1182Xi));
    }

    static /* synthetic */ void c(C6154cKe c6154cKe, Throwable th) {
        if (c6154cKe.b(th)) {
            c6154cKe.d(c6154cKe.j.e(th));
        }
    }

    static /* synthetic */ void d(C6154cKe c6154cKe) {
        if (c6154cKe.f != 0) {
            c6154cKe.f.ar_();
        }
    }
}