package o;

import android.text.TextUtils;
import com.scb.phone.domain.errors.RetrofitException;
import o.DeI;
import o.EAF;
import o.InterfaceC6621cYR;
import o.ZI;
import o.aSA;
import o.wRi;

/* loaded from: classes4.dex */
public class aSA extends ZI<InterfaceC6621cYR.RNg> {
    public final FCh b;
    private final C16949se c;
    private C16677qL d;
    private C0618Ku e;

    @InterfaceC13391fZD
    public aSA(C16903sI c16903sI, FCh fCh, C16949se c16949se, C16677qL c16677qL) {
        super(c16903sI);
        this.b = fCh;
        this.c = c16949se;
        this.d = c16677qL;
    }

    public final EAF c() {
        EAF.HBt hBt = new EAF.HBt(this.e.i, this.e.b);
        DeI.HBt hBt2 = new DeI.HBt();
        hBt2.e = this.e.d.get("NCB_CONSENT");
        hBt.c = new DeI(hBt2, (byte) 0);
        return new EAF(hBt, (byte) 0);
    }

    /* loaded from: classes4.dex */
    public class HBt extends wRi.LWm<kfx> {
        private aSA b;

        private HBt(aSA asa) {
            this.b = asa;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final kfx kfxVar = (kfx) obj;
            aSA.j(this.b);
            aSA asa = this.b;
            ZI.IeS ieS = new ZI.IeS(this, kfxVar) { // from class: o.aSI
                private aSA.HBt b;
                private kfx e;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    ((InterfaceC6621cYR.RNg) obj2).d(r0.b.e, this.b.b.d.b(this.e));
                }

                {
                    this.b = this;
                    this.e = kfxVar;
                }
            };
            if (asa.f != 0) {
                ieS.e(asa.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(final Throwable th) {
            aSA.d(this.b);
            aSA asa = this.b;
            ZI.IeS ieS = new ZI.IeS(this, th) { // from class: o.aSG
                private Throwable a;
                private aSA.HBt d;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    aSA.HBt.c(this.d, this.a, (InterfaceC6621cYR.RNg) obj);
                }

                {
                    this.d = this;
                    this.a = th;
                }
            };
            if (asa.f != 0) {
                ieS.e(asa.f);
            }
        }

        private void c(InterfaceC6621cYR.RNg rNg, String str, String str2) {
            rNg.e(this.b.c.d(str, str2, this.b.b.c()));
        }

        public static /* synthetic */ void c(final HBt hBt, Throwable th, InterfaceC6621cYR.RNg rNg) {
            if ((th instanceof RetrofitException) && rNg.a() != null) {
                String h = rNg.a().h();
                RetrofitException retrofitException = (RetrofitException) th;
                if (retrofitException.e == null || retrofitException.e.c == null) {
                    return;
                }
                String str = retrofitException.e.c.e;
                String str2 = retrofitException.e.c.d;
                String str3 = retrofitException.e.c.c;
                h.hashCode();
                if (h.equals("PURPOSEFUL")) {
                    if ("9205".equals(str)) {
                        hBt.c(rNg, str2, str3);
                        return;
                    } else {
                        aSA.e(hBt.b, th, new Runnable(hBt) { // from class: o.aSH
                            private aSA.HBt e;

                            @Override // java.lang.Runnable
                            public final void run() {
                                aSA.HBt.c(this.e);
                            }

                            {
                                this.e = hBt;
                            }
                        });
                        return;
                    }
                }
                if (h.equals("HOME")) {
                    if ("9202".equals(str) || "9201".equals(str)) {
                        hBt.c(rNg, str2, str3);
                        return;
                    } else {
                        aSA.e(hBt.b, th, new Runnable(hBt) { // from class: o.aSH
                            private aSA.HBt e;

                            @Override // java.lang.Runnable
                            public final void run() {
                                aSA.HBt.c(this.e);
                            }

                            {
                                this.e = hBt;
                            }
                        });
                        return;
                    }
                }
                aSA.e(hBt.b, th, new Runnable(hBt) { // from class: o.aSH
                    private aSA.HBt e;

                    @Override // java.lang.Runnable
                    public final void run() {
                        aSA.HBt.c(this.e);
                    }

                    {
                        this.e = hBt;
                    }
                });
                return;
            }
            aSA.e(hBt.b, th, new Runnable(hBt) { // from class: o.aSH
                private aSA.HBt e;

                @Override // java.lang.Runnable
                public final void run() {
                    aSA.HBt.c(this.e);
                }

                {
                    this.e = hBt;
                }
            });
        }

        public static /* synthetic */ void c(HBt hBt) {
            aSA asa = hBt.b;
            aSF asf = new aSF();
            if (asa.f != 0) {
                asf.e(asa.f);
            }
        }

        public /* synthetic */ HBt(aSA asa, byte b) {
            this(asa);
        }
    }

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

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

    static /* synthetic */ void e(aSA asa, Throwable th, Runnable runnable) {
        if (asa.b(th)) {
            asa.d(asa.j.c(th, runnable));
        }
    }

    static /* synthetic */ void j(aSA asa) {
        if (asa.f != 0) {
            asa.f.ar_();
        }
    }

    public final void e(final C0618Ku c0618Ku) {
        this.e = c0618Ku;
        for (final int i = 0; i < c0618Ku.f.size(); i++) {
            ZI.IeS ieS = new ZI.IeS(c0618Ku, i) { // from class: o.aSE
                private C0618Ku a;
                private int b;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    ((InterfaceC6621cYR.RNg) obj).b(this.a.f.get(r1), this.b + 1);
                }

                {
                    this.a = c0618Ku;
                    this.b = i;
                }
            };
            if (this.f != 0) {
                ieS.e(this.f);
            }
        }
        if (TextUtils.isEmpty(c0618Ku.h) || TextUtils.isEmpty(c0618Ku.c)) {
            return;
        }
        ZI.IeS ieS2 = new ZI.IeS(c0618Ku) { // from class: o.aSD
            private C0618Ku c;

            @Override // o.ZI.IeS
            public final void e(Object obj) {
                ((InterfaceC6621cYR.RNg) obj).c(r0.h, this.c.c);
            }

            {
                this.c = c0618Ku;
            }
        };
        if (this.f != 0) {
            ieS2.e(this.f);
        }
    }
}