package o;

import o.ZI;
import o.bHN;
import o.wRi;

/* loaded from: classes4.dex */
public class bHN extends ZI<InterfaceC9360diK> {
    public C0869Qj a;
    public C1052UoH b;
    public C17251vI c;
    public sox d;
    private String e;

    @InterfaceC13391fZD
    public bHN(C16903sI c16903sI, sox soxVar, C1052UoH c1052UoH, C17251vI c17251vI) {
        super(c16903sI);
        this.d = soxVar;
        this.b = c1052UoH;
        this.c = c17251vI;
    }

    @Override // o.ZI
    public final void w_() {
        sox soxVar = this.d;
        if (!soxVar.h.isDisposed()) {
            soxVar.h.dispose();
        }
        C1052UoH c1052UoH = this.b;
        if (!c1052UoH.h.isDisposed()) {
            c1052UoH.h.dispose();
        }
        super.w_();
    }

    /* loaded from: classes4.dex */
    public class Sts extends wRi.LWm<IwU> {
        private bHN b;

        private Sts(bHN bhn) {
            this.b = bhn;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            IwU iwU = (IwU) obj;
            super.onNext(iwU);
            bHN.f(this.b);
            bHN bhn = this.b;
            C17251vI unused = bhn.c;
            bhn.a = C17251vI.e(iwU);
            bHN bhn2 = this.b;
            ZI.IeS ieS = new ZI.IeS(this) { // from class: o.bIf
                private bHN.Sts c;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    bHN.Sts.e(this.c, (InterfaceC9360diK) obj2);
                }

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

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            super.onError(th);
            bHN.e(this.b, th);
        }

        public static /* synthetic */ void e(Sts sts, InterfaceC9360diK interfaceC9360diK) {
            interfaceC9360diK.c(sts.b.a.b);
            bHN.c(sts.b);
            interfaceC9360diK.e();
        }

        public /* synthetic */ Sts(bHN bhn, byte b) {
            this(bhn);
        }
    }

    /* loaded from: classes4.dex */
    public class LWm extends wRi.LWm<IwU> {
        private bHN c;

        private LWm(bHN bhn) {
            this.c = bhn;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            IwU iwU = (IwU) obj;
            super.onNext(iwU);
            bHN.i(this.c);
            C17251vI unused = this.c.c;
            C0869Qj e = C17251vI.e(iwU);
            bHN bhn = this.c;
            ZI.IeS ieS = new ZI.IeS(this, e) { // from class: o.bIj
                private C0869Qj c;
                private bHN.LWm d;

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

                {
                    this.d = this;
                    this.c = e;
                }
            };
            if (bhn.f != 0) {
                ieS.e(bhn.f);
            }
        }

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

        public static /* synthetic */ void e(LWm lWm, C0869Qj c0869Qj, InterfaceC9360diK interfaceC9360diK) {
            char c;
            String str = lWm.c.e;
            str.hashCode();
            int hashCode = str.hashCode();
            if (hashCode == 2223327) {
                if (str.equals("HOME")) {
                    c = 0;
                }
                c = 65535;
            } else if (hashCode != 2670353) {
                if (hashCode == 1844922713 && str.equals("CURRENT")) {
                    c = 2;
                }
                c = 65535;
            } else {
                if (str.equals("WORK")) {
                    c = 1;
                }
                c = 65535;
            }
            if (c == 0) {
                C0869Qj c0869Qj2 = lWm.c.a;
                C0877Qo c0877Qo = c0869Qj.h;
                C14957gcv.e(c0877Qo, "");
                c0869Qj2.h = c0877Qo;
            } else if (c == 1) {
                C0869Qj c0869Qj3 = lWm.c.a;
                C0877Qo c0877Qo2 = c0869Qj.n;
                C14957gcv.e(c0877Qo2, "");
                c0869Qj3.n = c0877Qo2;
            } else if (c == 2) {
                C0869Qj c0869Qj4 = lWm.c.a;
                C0877Qo c0877Qo3 = c0869Qj.c;
                C14957gcv.e(c0877Qo3, "");
                c0869Qj4.c = c0877Qo3;
            }
            interfaceC9360diK.c();
            bHN.c(lWm.c);
        }

        public /* synthetic */ LWm(bHN bhn, byte b) {
            this(bhn);
        }
    }

    /* loaded from: classes4.dex */
    public class IeS extends wRi.LWm<Boolean> {
        private bHN c;

        private IeS(bHN bhn) {
            this.c = bhn;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            super.onNext((Boolean) obj);
            bHN.j(this.c);
            bHN bhn = this.c;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.bIm
                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    ((InterfaceC9360diK) obj2).a();
                }
            };
            if (bhn.f != 0) {
                ieS.e(bhn.f);
            }
        }

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

        public /* synthetic */ IeS(bHN bhn, byte b) {
            this(bhn);
        }
    }

    public static /* synthetic */ void d(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.e = "HOME";
        interfaceC9360diK.a(bhn.a.h, bhn.e);
    }

    public static /* synthetic */ void b(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.e = "WORK";
        interfaceC9360diK.a(bhn.a.n, bhn.e);
    }

    public static /* synthetic */ void a(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.j = !r0.j;
        if (bhn.a.j) {
            interfaceC9360diK.b(1);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void c(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.e = "CURRENT";
        interfaceC9360diK.a(bhn.a.c, bhn.e);
    }

    public static /* synthetic */ void e(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.l = !r0.l;
        if (bhn.a.l) {
            C0877Qo c0877Qo = bhn.a.n;
            C14957gcv.e("", "");
            c0877Qo.c = "";
            bhn.a.a = false;
            bhn.a.j = false;
            interfaceC9360diK.d(1);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void i(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.g = !r0.g;
        if (bhn.a.g) {
            interfaceC9360diK.b(0);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void j(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.m = !r0.m;
        if (bhn.a.m) {
            C0869Qj c0869Qj = bhn.a;
            C0877Qo c0877Qo = new C0877Qo();
            C14957gcv.e(c0877Qo, "");
            c0869Qj.n = c0877Qo;
            C0877Qo c0877Qo2 = bhn.a.n;
            C14957gcv.e("", "");
            c0877Qo2.c = "";
            bhn.a.a = false;
            bhn.a.j = false;
            interfaceC9360diK.d(0);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void h(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.f = !r0.f;
        if (bhn.a.f) {
            interfaceC9360diK.b(2);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void n(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.e = !r0.e;
        if (bhn.a.e) {
            C0877Qo c0877Qo = bhn.a.c;
            C14957gcv.e("", "");
            c0877Qo.c = "";
            bhn.a.f = false;
            interfaceC9360diK.e(1);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void d(bHN bhn) {
        bhn.a.i = !r0.i;
        if (bhn.a.i) {
            C0869Qj c0869Qj = bhn.a;
            C0877Qo c0877Qo = new C0877Qo();
            C14957gcv.e(c0877Qo, "");
            c0869Qj.h = c0877Qo;
            C0877Qo c0877Qo2 = bhn.a.h;
            C14957gcv.e("", "");
            c0877Qo2.c = "";
            bhn.a.l = false;
            bhn.a.e = false;
            bhn.a.g = false;
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void o(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.d = !r0.d;
        if (bhn.a.d) {
            C0869Qj c0869Qj = bhn.a;
            C0877Qo c0877Qo = new C0877Qo();
            C14957gcv.e(c0877Qo, "");
            c0869Qj.c = c0877Qo;
            C0877Qo c0877Qo2 = bhn.a.c;
            C14957gcv.e("", "");
            c0877Qo2.c = "";
            bhn.a.f = false;
            interfaceC9360diK.e(0);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    public static /* synthetic */ void l(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        bhn.a.a = !r0.a;
        if (bhn.a.a) {
            C0877Qo c0877Qo = bhn.a.c;
            C14957gcv.e("", "");
            c0877Qo.c = "";
            bhn.a.f = false;
            interfaceC9360diK.e(2);
        }
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }

    static /* synthetic */ void f(bHN bhn) {
        if (bhn.f != 0) {
            bhn.f.ar_();
        }
    }

    static /* synthetic */ void i(bHN bhn) {
        if (bhn.f != 0) {
            bhn.f.ar_();
        }
    }

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

    static /* synthetic */ void e(bHN bhn, Throwable th) {
        if (bhn.b(th)) {
            bhn.d(bhn.j.e(th));
        }
    }

    static /* synthetic */ void d(bHN bhn, Throwable th) {
        if (bhn.b(th)) {
            bhn.d(bhn.j.e(th));
        }
    }

    static /* synthetic */ void b(bHN bhn, Throwable th) {
        if (bhn.b(th)) {
            bhn.d(bhn.j.e(th));
        }
    }

    public static /* synthetic */ void k(bHN bhn, InterfaceC9360diK interfaceC9360diK) {
        interfaceC9360diK.c(bhn.a);
        interfaceC9360diK.e(bhn.a);
        interfaceC9360diK.j(bhn.a);
        interfaceC9360diK.a(bhn.a);
        interfaceC9360diK.b(bhn.a);
        interfaceC9360diK.d(bhn.a);
        interfaceC9360diK.f(bhn.a);
        interfaceC9360diK.i(bhn.a);
    }

    static /* synthetic */ void c(bHN bhn) {
        bHX bhx = new bHX(bhn);
        if (bhn.f != 0) {
            bhx.e(bhn.f);
        }
    }
}