package o;

import java.util.List;
import o.C2440aee;
import o.InterfaceC6627cYe;
import o.ZI;
import o.wRi;
import org.threeten.bp.OffsetDateTime;

/* renamed from: o.aee, reason: case insensitive filesystem */
/* loaded from: classes3.dex */
public class C2440aee extends ZI<InterfaceC6627cYe.saX> {
    public final C17558xn a;
    public final ggN b;
    private boolean c;
    private List<RK> d;
    private C15554gto e;

    @InterfaceC13391fZD
    public C2440aee(ggN ggn, C17558xn c17558xn, C16903sI c16903sI) {
        super(c16903sI);
        this.e = C15554gto.ofPattern("yyyy-MM-dd");
        this.b = ggn;
        this.a = c17558xn;
    }

    @Override // o.ZI
    public final void w_() {
        ggN ggn = this.b;
        if (!ggn.h.isDisposed()) {
            ggn.h.dispose();
        }
        super.w_();
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    /* renamed from: o.aee$3, reason: invalid class name */
    /* loaded from: classes3.dex */
    public final class AnonymousClass3 extends wRi.LWm<List<PuL>> {
        private C2440aee b;

        AnonymousClass3(C2440aee c2440aee) {
            this.b = c2440aee;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            List list = (List) obj;
            this.b.c = false;
            guQ.b("onNext -> merchantWalletSummaryList: %d items", Integer.valueOf(list.size()));
            C2440aee c2440aee = this.b;
            C17558xn c17558xn = c2440aee.a;
            boolean T = this.b.b.d.T();
            C14957gcv.e(list, "");
            List list2 = (List) C16157lj.c(new Object[]{list, new C17566xq(c17558xn, T, true)}, -1846295624, 1846295631, (int) System.currentTimeMillis());
            C14957gcv.c(list2, "");
            c2440aee.d = list2;
            C2440aee c2440aee2 = this.b;
            ZI.IeS ieS = new ZI.IeS(this) { // from class: o.aek
                private C2440aee.AnonymousClass3 e;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    ((InterfaceC6627cYe.saX) obj2).e(this.e.b.d);
                }

                {
                    this.e = this;
                }
            };
            if (c2440aee2.f != 0) {
                ieS.e(c2440aee2.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onComplete() {
            C2440aee.a(this.b);
            C2440aee.h(this.b);
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            this.b.c = false;
            if (this.b.f == 0 || this.b.i(th)) {
                return;
            }
            C2440aee.j(this.b);
            C2440aee c2440aee = this.b;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.aef
                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    ((InterfaceC6627cYe.saX) obj).aM_();
                }
            };
            if (c2440aee.f != 0) {
                ieS.e(c2440aee.f);
            }
        }
    }

    public final boolean a() {
        C7968cyO p = this.b.d.p();
        List<Wqa> list = p != null ? p.i : null;
        List<RK> list2 = this.d;
        return (list2 == null || list == null || list2.size() == list.size()) ? false : true;
    }

    public static /* synthetic */ void d(C2440aee c2440aee, List list, InterfaceC6627cYe.saX sax) {
        C17558xn c17558xn = c2440aee.a;
        boolean T = c2440aee.b.d.T();
        C14957gcv.e(list, "");
        List<RK> list2 = (List) C16157lj.c(new Object[]{list, new C17566xq(c17558xn, T, true)}, -1846295624, 1846295631, (int) System.currentTimeMillis());
        C14957gcv.c(list2, "");
        sax.e(list2);
    }

    static /* synthetic */ void a(C2440aee c2440aee) {
        if (c2440aee.f != 0) {
            c2440aee.f.aq_();
        }
    }

    static /* synthetic */ void h(C2440aee c2440aee) {
        if (c2440aee.f != 0) {
            c2440aee.f.u();
        }
    }

    static /* synthetic */ void j(C2440aee c2440aee) {
        if (c2440aee.f != 0) {
            c2440aee.f.u();
        }
    }

    public final void b() {
        if (this.c) {
            return;
        }
        this.c = true;
        if (this.f != 0) {
            this.f.v();
        }
        OffsetDateTime now = OffsetDateTime.now();
        this.b.d((Integer) null, now.withDayOfMonth(1).format(this.e), now.format(this.e));
        ggN ggn = this.b;
        ggn.d(ggn.i, new AnonymousClass3(this));
    }
}