package o;

import java.util.ArrayList;
import java.util.List;
import o.C7308clo;
import o.InterfaceC9480dkY;
import o.ZI;
import o.wRi;

/* renamed from: o.clo, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public final class C7308clo extends ZI<InterfaceC9480dkY.LWm> {
    public final C17431wiQ b;
    private final C16184ly d;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    @InterfaceC13391fZD
    public C7308clo(C16903sI c16903sI, C17431wiQ c17431wiQ, C16184ly c16184ly) {
        super(c16903sI);
        C14957gcv.e(c16903sI, "");
        C14957gcv.e(c17431wiQ, "");
        C14957gcv.e(c16184ly, "");
        this.b = c17431wiQ;
        this.d = c16184ly;
    }

    /* renamed from: o.clo$HBt */
    /* loaded from: classes4.dex */
    public final class HBt extends wRi.LWm<List<? extends Dzn>> {
        private C7308clo e;

        public HBt(C7308clo c7308clo) {
            this.e = c7308clo;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final List list = (List) obj;
            C14957gcv.e(list, "");
            final C7308clo c7308clo = this.e;
            ZI.IeS ieS = new ZI.IeS(list, c7308clo) { // from class: o.clu
                private C7308clo a;
                private List b;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    C7308clo.HBt.a(this.b, this.a, (InterfaceC9480dkY.LWm) obj2);
                }

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

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            C14957gcv.e(th, "");
            C7308clo c7308clo = this.e;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.cls
                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    ((InterfaceC9480dkY.LWm) obj).a();
                }
            };
            if (c7308clo.f != 0) {
                ieS.e(c7308clo.f);
            }
        }

        public static /* synthetic */ void a(List list, C7308clo c7308clo, InterfaceC9480dkY.LWm lWm) {
            C14957gcv.e(list, "");
            C14957gcv.e(c7308clo, "");
            ArrayList arrayList = new ArrayList();
            for (Object obj : list) {
                if (((Dzn) obj).i) {
                    arrayList.add(obj);
                }
            }
            ArrayList arrayList2 = arrayList;
            if (!arrayList2.isEmpty()) {
                final ArrayList<C0367Fb> arrayList3 = new ArrayList<>(c7308clo.d.e(arrayList2));
                lWm.e(arrayList3);
                C14957gcv.e(arrayList3, "");
                ZI.IeS ieS = new ZI.IeS(arrayList3) { // from class: o.clr
                    private ArrayList d;

                    @Override // o.ZI.IeS
                    public final void e(Object obj2) {
                        C7308clo.e(this.d, (InterfaceC9480dkY.LWm) obj2);
                    }

                    {
                        this.d = arrayList3;
                    }
                };
                if (c7308clo.f != 0) {
                    ieS.e(c7308clo.f);
                    return;
                }
                return;
            }
            lWm.c();
        }
    }

    public static /* synthetic */ void e(ArrayList arrayList, InterfaceC9480dkY.LWm lWm) {
        C14957gcv.e(arrayList, "");
        if (arrayList.size() <= 10) {
            lWm.d();
        } else {
            lWm.e();
        }
    }
}