package o;

/* loaded from: classes3.dex */
public final class kOa extends wRi {
    final InterfaceC15060gft d;

    /* JADX INFO: Access modifiers changed from: package-private */
    @InterfaceC13391fZD
    public kOa(yRw yrw, yRw yrw2, InterfaceC15060gft interfaceC15060gft) {
        super(yrw, yrw2);
        this.d = interfaceC15060gft;
    }

    public final void e(final String str, final IJa iJa) {
        if (iJa.j == null) {
            e(AbstractC13163fSk.error(new Throwable("Invalid request UUID.")));
        } else {
            e(this.d.e(new SEg(str, iJa.j)).doOnNext(new fSQ(this, str, iJa) { // from class: o.giK
                private String b;
                private kOa c;
                private IJa e;

                @Override // o.fSQ
                public final void c(Object obj) {
                    this.c.d.c(new Gfp(this.b, this.e, (C0731Nfa) obj));
                }

                {
                    this.c = this;
                    this.b = str;
                    this.e = iJa;
                }
            }));
        }
    }
}