package o;

import o.C0217Bo;
import o.InterfaceC9010dbe;
import o.ZI;
import o.cPU;
import o.wRi;

/* loaded from: classes4.dex */
public final class cPU extends AbstractC6226cMj {
    private final REU a;
    final C17515xRi b;
    final C0217Bo c;
    final C0314Dz d;
    private C17434wjF e;
    private int g;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    @InterfaceC13391fZD
    public cPU(REU reu, C0217Bo c0217Bo, C0314Dz c0314Dz, C17515xRi c17515xRi, C16903sI c16903sI) {
        super(c16903sI);
        C14957gcv.e(reu, "");
        C14957gcv.e(c0217Bo, "");
        C14957gcv.e(c0314Dz, "");
        C14957gcv.e(c17515xRi, "");
        C14957gcv.e(c16903sI, "");
        this.a = reu;
        this.c = c0217Bo;
        this.d = c0314Dz;
        this.b = c17515xRi;
    }

    @Override // o.ZI
    public final void w_() {
        super.w_();
        this.e = null;
        REU reu = this.a;
        if (reu.h.isDisposed()) {
            return;
        }
        reu.h.dispose();
    }

    @Override // o.AbstractC6226cMj
    public final void b() {
        ZI.IeS ieS = new ZI.IeS() { // from class: o.cQc
            @Override // o.ZI.IeS
            public final void e(Object obj) {
                ((InterfaceC9010dbe.IeS) obj).e();
            }
        };
        if (this.f != 0) {
            ieS.e(this.f);
        }
        this.a.c(Integer.valueOf(this.g));
        REU reu = this.a;
        reu.d(reu.i, new RVV(this));
    }

    @Override // o.AbstractC6226cMj
    public final void b(C1089Vj c1089Vj) {
        C14957gcv.e(c1089Vj, "");
        ZI.IeS ieS = new ZI.IeS() { // from class: o.cPW
            @Override // o.ZI.IeS
            public final void e(Object obj) {
                ((InterfaceC9010dbe.IeS) obj).y();
            }
        };
        if (this.f != 0) {
            ieS.e(this.f);
        }
        REU reu = this.a;
        C12949fM c12949fM = new C12949fM();
        String str = c1089Vj.f;
        C14957gcv.e(str, "");
        c12949fM.d = str;
        reu.e(c12949fM);
        REU reu2 = this.a;
        reu2.d(reu2.i, new LWm(this));
    }

    @Override // o.AbstractC6226cMj
    public final void a(final C1089Vj c1089Vj) {
        C14957gcv.e(c1089Vj, "");
        ZI.IeS ieS = new ZI.IeS(c1089Vj) { // from class: o.cPX
            private C1089Vj e;

            @Override // o.ZI.IeS
            public final void e(Object obj) {
                cPU.b(this.e, (InterfaceC9010dbe.IeS) obj);
            }

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

    /* loaded from: classes4.dex */
    public final class RVV extends wRi.LWm<C17434wjF> {
        private cPU d;

        public RVV(cPU cpu) {
            this.d = cpu;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            C17434wjF c17434wjF = (C17434wjF) obj;
            C14957gcv.e(c17434wjF, "");
            this.d.e = c17434wjF;
            if (this.d.f != 0) {
                final C1093Vl b = this.d.c.b(c17434wjF);
                if (b.d == 0) {
                    if (this.d.g == 0) {
                        cPU cpu = this.d;
                        ZI.IeS ieS = new ZI.IeS() { // from class: o.cPY
                            @Override // o.ZI.IeS
                            public final void e(Object obj2) {
                                ((InterfaceC9010dbe.IeS) obj2).c();
                            }
                        };
                        if (cpu.f != 0) {
                            ieS.e(cpu.f);
                            return;
                        }
                        return;
                    }
                    cPU cpu2 = this.d;
                    ZI.IeS ieS2 = new ZI.IeS() { // from class: o.cQi
                        @Override // o.ZI.IeS
                        public final void e(Object obj2) {
                            ((InterfaceC9010dbe.IeS) obj2).b();
                        }
                    };
                    if (cpu2.f != 0) {
                        ieS2.e(cpu2.f);
                        return;
                    }
                    return;
                }
                if (this.d.g > 0) {
                    cPU cpu3 = this.d;
                    ZI.IeS ieS3 = new ZI.IeS(b) { // from class: o.cQe
                        private C1093Vl e;

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

                        {
                            this.e = b;
                        }
                    };
                    if (cpu3.f != 0) {
                        ieS3.e(cpu3.f);
                    }
                } else {
                    cPU cpu4 = this.d;
                    ZI.IeS ieS4 = new ZI.IeS(b) { // from class: o.cQg
                        private C1093Vl b;

                        @Override // o.ZI.IeS
                        public final void e(Object obj2) {
                            cPU.RVV.c(this.b, (InterfaceC9010dbe.IeS) obj2);
                        }

                        {
                            this.b = b;
                        }
                    };
                    if (cpu4.f != 0) {
                        ieS4.e(cpu4.f);
                    }
                }
                this.d.g += b.c.size();
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onComplete() {
            cPU.c(this.d);
        }

        public static /* synthetic */ void c(C1093Vl c1093Vl, InterfaceC9010dbe.IeS ieS) {
            C14957gcv.e(c1093Vl, "");
            ieS.d(c1093Vl);
        }

        public static /* synthetic */ void b(C1093Vl c1093Vl, InterfaceC9010dbe.IeS ieS) {
            C14957gcv.e(c1093Vl, "");
            ieS.a(c1093Vl);
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            C14957gcv.e(th, "");
            if (this.d.f == 0 || this.d.i(th)) {
                return;
            }
            cPU.c(this.d);
            cPU cpu = this.d;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.cQb
                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    ((InterfaceC9010dbe.IeS) obj).a();
                }
            };
            if (cpu.f != 0) {
                ieS.e(cpu.f);
            }
        }
    }

    /* loaded from: classes4.dex */
    public final class LWm extends wRi.LWm<ERW> {
        private cPU e;

        public LWm(cPU cpu) {
            this.e = cpu;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            ERW erw = (ERW) obj;
            C14957gcv.e(erw, "");
            cPU.d(this.e);
            C0314Dz c0314Dz = this.e.d;
            C1200Xw d = C0314Dz.d(erw);
            C1019Twi c1019Twi = new C1019Twi();
            c1019Twi.a = d.a;
            c1019Twi.t = "BILLPAYMENT";
            c1019Twi.z = "ALL";
            c1019Twi.x = d.b;
            c1019Twi.b = d.b;
            c1019Twi.C = d.e;
            c1019Twi.w = d.d;
            C14957gcv.c(c1019Twi, "");
            if (d.c != null) {
                c1019Twi.h = Double.parseDouble(d.c);
                C14957gcv.c(c1019Twi, "");
            }
            if (d.g != null) {
                c1019Twi.D = d.g;
                C14957gcv.c(c1019Twi, "");
            }
            if (d.h != null) {
                c1019Twi.B = d.h;
                C14957gcv.c(c1019Twi, "");
            }
            this.e.b.e.d(c1019Twi);
            cPU cpu = this.e;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.cQf
                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    ((InterfaceC9010dbe.IeS) obj2).bq_();
                }
            };
            if (cpu.f != 0) {
                ieS.e(cpu.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onComplete() {
            cPU.d(this.e);
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(final Throwable th) {
            C14957gcv.e(th, "");
            if (this.e.i(th)) {
                return;
            }
            cPU.d(this.e);
            final cPU cpu = this.e;
            ZI.IeS ieS = new ZI.IeS(cpu, th) { // from class: o.cQh
                private Throwable c;
                private cPU e;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    cPU.LWm.b(this.e, this.c);
                }

                {
                    this.e = cpu;
                    this.c = th;
                }
            };
            if (cpu.f != 0) {
                ieS.e(cpu.f);
            }
        }

        public static /* synthetic */ void b(cPU cpu, Throwable th) {
            C14957gcv.e(cpu, "");
            C14957gcv.e(th, "");
            cPU.e(cpu, th);
        }
    }

    public static /* synthetic */ void b(C1089Vj c1089Vj, InterfaceC9010dbe.IeS ieS) {
        C14957gcv.e(c1089Vj, "");
        ieS.a(c1089Vj.f, QJy.BILLPAYMENT);
    }

    public static final /* synthetic */ void d(cPU cpu) {
        if (cpu.f != 0) {
            cpu.f.ar_();
        }
    }

    public static final /* synthetic */ void c(cPU cpu) {
        if (cpu.f != 0) {
            cpu.f.aq_();
        }
    }

    public static final /* synthetic */ void e(cPU cpu, Throwable th) {
        if (cpu.b(th)) {
            cpu.d(cpu.j.e(th));
        }
    }

    @Override // o.AbstractC6226cMj
    public final void c() {
        this.g = 0;
        if (this.e == null) {
            if (this.f != 0) {
                this.f.v();
            }
            C0217Bo c0217Bo = this.c;
            C0217Bo.Sts sts = C0217Bo.Sts.BILLPAYMENT;
            C14957gcv.e(sts, "");
            c0217Bo.b = sts;
            this.a.c(Integer.valueOf(this.g));
            REU reu = this.a;
            reu.d(reu.i, new RVV(this));
        }
    }
}