package o;

import o.GJE;

/* loaded from: classes3.dex */
public final class OQD extends wRi {
    final InterfaceC0773Ogw e;

    /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
    @InterfaceC13391fZD
    public OQD(yRw yrw, yRw yrw2, InterfaceC0773Ogw interfaceC0773Ogw) {
        super(yrw, yrw2);
        C14957gcv.e(yrw, "");
        C14957gcv.e(yrw2, "");
        C14957gcv.e(interfaceC0773Ogw, "");
        this.e = interfaceC0773Ogw;
    }

    /* JADX INFO: Access modifiers changed from: package-private */
    /* loaded from: classes3.dex */
    public static final class HBt extends AbstractC14961gcz implements InterfaceC14894gbR<Bpv, C14866gag> {
        private OQD b;

        @Override // o.InterfaceC14894gbR
        public final /* synthetic */ C14866gag invoke(Bpv bpv) {
            GJE gje;
            GJE gje2;
            Bpv bpv2 = bpv;
            if (bpv2 != null && (gje2 = bpv2.j) != null) {
                this.b.e.a(gje2, GJE.Sts.HOME);
                C14866gag c14866gag = C14866gag.c;
            }
            OQD oqd = this.b;
            if (bpv2 != null && (gje = bpv2.h) != null) {
                oqd.e.a(gje, GJE.Sts.MAILING);
            }
            return C14866gag.c;
        }

        /* JADX WARN: 'super' call moved to the top of the method (can break code semantics) */
        HBt(OQD oqd) {
            super(1);
            this.b = oqd;
        }
    }

    public final AbstractC13163fSk<Bpv> e() {
        AbstractC13163fSk<Bpv> D = this.e.D();
        final HBt hBt = new HBt(this);
        AbstractC13163fSk<Bpv> doOnNext = D.doOnNext(new fSQ(hBt) { // from class: o.IWX
            private InterfaceC14894gbR e;

            @Override // o.fSQ
            public final void c(Object obj) {
                InterfaceC14894gbR interfaceC14894gbR = this.e;
                C14957gcv.e(interfaceC14894gbR, "");
                interfaceC14894gbR.invoke(obj);
            }

            {
                this.e = hBt;
            }
        });
        e(doOnNext);
        C14957gcv.c(doOnNext, "");
        return doOnNext;
    }
}