package o;

import java.util.Objects;

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

    @InterfaceC13391fZD
    public CLj(yRw yrw, yRw yrw2, InterfaceC0773Ogw interfaceC0773Ogw, tQD tqd) {
        super(yrw, yrw2);
        this.e = interfaceC0773Ogw;
        this.a = tqd;
    }

    public final AbstractC13163fSk<Boolean> a(final String str, final String str2) {
        fUY fuy;
        AbstractC13175fSw<String> n = this.e.n();
        if (this.a.f() == bTI.BUSINESS_OWNER) {
            fuy = new fUY(n, new fSS(this, str, str2) { // from class: o.HSW
                private String a;
                private String b;
                private CLj e;

                @Override // o.fSS
                public final Object a(Object obj) {
                    fRY b = this.e.a.b(new YpA((String) obj, this.a, this.b));
                    AbstractC13163fSk just = AbstractC13163fSk.just(Boolean.TRUE);
                    Objects.requireNonNull(just, "next is null");
                    return new fUK(b, just);
                }

                {
                    this.e = this;
                    this.a = str;
                    this.b = str2;
                }
            });
        } else {
            fuy = new fUY(n, new fSS(this, str, str2) { // from class: o.aTe
                private String b;
                private String c;
                private CLj d;

                @Override // o.fSS
                public final Object a(Object obj) {
                    fRY e = this.d.e.e(new YpA((String) obj, this.c, this.b));
                    AbstractC13163fSk just = AbstractC13163fSk.just(Boolean.TRUE);
                    Objects.requireNonNull(just, "next is null");
                    return new fUK(e, just);
                }

                {
                    this.d = this;
                    this.c = str;
                    this.b = str2;
                }
            });
        }
        e(fuy);
        return fuy;
    }
}