package o;

import o.ZI;
import o.cIZ;
import o.wRi;

/* loaded from: classes4.dex */
public class cIZ extends ZI<InterfaceC8974dav> {
    private final CC a;
    public final Jur b;
    private final CD c;
    private final C16010kTB d;
    public final gHy e;
    private final LVB g;
    private final iEy h;
    private final gHd i;
    private final C0952SdK k;
    private final Oqm m;

    /* renamed from: o, reason: collision with root package name */
    private final FHl f8606o;

    @InterfaceC13391fZD
    public cIZ(iEy iey, C16010kTB c16010kTB, C0952SdK c0952SdK, Jur jur, CC cc, FHl fHl, Oqm oqm, gHy ghy, CD cd, gHd ghd, LVB lvb, C16903sI c16903sI) {
        super(c16903sI);
        this.h = iey;
        this.d = c16010kTB;
        this.k = c0952SdK;
        this.b = jur;
        this.f8606o = fHl;
        this.m = oqm;
        this.a = cc;
        this.e = ghy;
        this.c = cd;
        this.i = ghd;
        this.g = lvb;
    }

    /* loaded from: classes4.dex */
    public class RVV extends wRi.LWm<C16573pSL> {
        private cIZ e;

        private RVV(cIZ ciz) {
            this.e = ciz;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final C16573pSL c16573pSL = (C16573pSL) obj;
            cIZ.i(this.e);
            this.e.i.b.c(c16573pSL);
            final ES b = this.e.a.b(this.e.h.c.e(), this.e.k.b.L(), this.e.d.d.d(), this.e.m.c.M(), this.e.b.a.c(), this.e.g.d.g().c.get(0), true, true);
            cIZ ciz = this.e;
            ZI.IeS ieS = new ZI.IeS(this, c16573pSL, b) { // from class: o.cJi
                private ES a;
                private C16573pSL c;
                private cIZ.RVV d;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    InterfaceC8974dav interfaceC8974dav = (InterfaceC8974dav) obj2;
                    interfaceC8974dav.e(this.d.e.c.a(this.c, this.a));
                }

                {
                    this.d = this;
                    this.c = c16573pSL;
                    this.a = b;
                }
            };
            if (ciz.f != 0) {
                ieS.e(ciz.f);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            cIZ.c(this.e, th, new Runnable(this) { // from class: o.cJf
                private cIZ.RVV d;

                @Override // java.lang.Runnable
                public final void run() {
                    cIZ.RVV.c(this.d);
                }

                {
                    this.d = this;
                }
            });
        }

        public static /* synthetic */ void c(RVV rvv) {
            cIZ ciz = rvv.e;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.cJh
                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    ((InterfaceC8974dav) obj).b();
                }
            };
            if (ciz.f != 0) {
                ieS.e(ciz.f);
            }
        }

        public /* synthetic */ RVV(cIZ ciz, byte b) {
            this(ciz);
        }
    }

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

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