package o;

import java.util.concurrent.atomic.AtomicBoolean;
import o.C3244atp;
import o.ZI;
import o.wRi;

/* renamed from: o.atp, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public class C3244atp extends ZI<InterfaceC9045dcM> {
    public AtomicBoolean a;
    private C16319nT b;
    private InterfaceC9045dcM c;
    public ZBH d;
    public C16334nZ e;

    @Override // o.ZI
    public final /* bridge */ /* synthetic */ void e(InterfaceC9045dcM interfaceC9045dcM) {
        InterfaceC9045dcM interfaceC9045dcM2 = interfaceC9045dcM;
        super.e((C3244atp) interfaceC9045dcM2);
        this.c = interfaceC9045dcM2;
    }

    @InterfaceC13391fZD
    public C3244atp(C16903sI c16903sI, ZBH zbh, C16319nT c16319nT, C16334nZ c16334nZ) {
        super(c16903sI);
        this.d = zbh;
        this.b = c16319nT;
        this.e = c16334nZ;
        this.a = new AtomicBoolean(false);
    }

    /* renamed from: o.atp$Sts */
    /* loaded from: classes4.dex */
    public class Sts extends wRi.LWm<rYB> {
        private C3244atp d;

        public Sts(C3244atp c3244atp) {
            this.d = c3244atp;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final rYB ryb = (rYB) obj;
            this.d.a.set(false);
            if (this.d.c.e()) {
                C3244atp c3244atp = this.d;
                C3203atA c3203atA = new C3203atA();
                if (c3244atp.f != 0) {
                    c3203atA.e(c3244atp.f);
                }
                final C0470Hg d = this.d.b.d(ryb);
                if (d.d.isEmpty()) {
                    C3244atp c3244atp2 = this.d;
                    C3206atD c3206atD = new C3206atD();
                    if (c3244atp2.f != 0) {
                        c3206atD.e(c3244atp2.f);
                    }
                } else {
                    C3244atp c3244atp3 = this.d;
                    ZI.IeS ieS = new ZI.IeS(d) { // from class: o.atE
                        private C0470Hg d;

                        @Override // o.ZI.IeS
                        public final void e(Object obj2) {
                            ((InterfaceC9045dcM) obj2).a(this.d);
                        }

                        {
                            this.d = d;
                        }
                    };
                    if (c3244atp3.f != 0) {
                        ieS.e(c3244atp3.f);
                    }
                }
                C3244atp c3244atp4 = this.d;
                ZI.IeS ieS2 = new ZI.IeS(ryb) { // from class: o.atJ
                    private rYB a;

                    @Override // o.ZI.IeS
                    public final void e(Object obj2) {
                        ((InterfaceC9045dcM) obj2).a(this.a.b);
                    }

                    {
                        this.a = ryb;
                    }
                };
                if (c3244atp4.f != 0) {
                    ieS2.e(c3244atp4.f);
                }
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            this.d.a.set(false);
            if (this.d.c.e()) {
                C3244atp c3244atp = this.d;
                C3203atA c3203atA = new C3203atA();
                if (c3244atp.f != 0) {
                    c3203atA.e(c3244atp.f);
                }
                if (this.d.i(th)) {
                    return;
                }
                C3244atp c3244atp2 = this.d;
                C3206atD c3206atD = new C3206atD();
                if (c3244atp2.f != 0) {
                    c3206atD.e(c3244atp2.f);
                }
            }
        }
    }

    public final void a(InterfaceC9045dcM interfaceC9045dcM) {
        super.e((C3244atp) interfaceC9045dcM);
        this.c = interfaceC9045dcM;
    }

    /* renamed from: o.atp$RVV */
    /* loaded from: classes4.dex */
    public class RVV extends wRi.LWm<rYB> {
        private C3244atp a;

        public RVV(C3244atp c3244atp) {
            this.a = c3244atp;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            final rYB ryb = (rYB) obj;
            this.a.a.set(false);
            if (this.a.c == null || !this.a.c.e()) {
                return;
            }
            C3244atp c3244atp = this.a;
            C3252atx c3252atx = new C3252atx();
            if (c3244atp.f != 0) {
                c3252atx.e(c3244atp.f);
            }
            C3244atp c3244atp2 = this.a;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.atu
                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    ((InterfaceC9045dcM) obj2).a();
                }
            };
            if (c3244atp2.f != 0) {
                ieS.e(c3244atp2.f);
            }
            C3244atp c3244atp3 = this.a;
            ZI.IeS ieS2 = new ZI.IeS(this, ryb) { // from class: o.atw
                private C3244atp.RVV d;
                private rYB e;

                @Override // o.ZI.IeS
                public final void e(Object obj2) {
                    InterfaceC9045dcM interfaceC9045dcM = (InterfaceC9045dcM) obj2;
                    interfaceC9045dcM.d(this.d.a.b.d(this.e));
                }

                {
                    this.d = this;
                    this.e = ryb;
                }
            };
            if (c3244atp3.f != 0) {
                ieS2.e(c3244atp3.f);
            }
            if (ryb != null) {
                C3244atp c3244atp4 = this.a;
                ZI.IeS ieS3 = new ZI.IeS(ryb) { // from class: o.atB
                    private rYB c;

                    @Override // o.ZI.IeS
                    public final void e(Object obj2) {
                        ((InterfaceC9045dcM) obj2).a(this.c.b);
                    }

                    {
                        this.c = ryb;
                    }
                };
                if (c3244atp4.f != 0) {
                    ieS3.e(c3244atp4.f);
                }
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            this.a.a.set(false);
            if (!this.a.c.e() || this.a.i(th)) {
                return;
            }
            C3244atp c3244atp = this.a;
            C3252atx c3252atx = new C3252atx();
            if (c3244atp.f != 0) {
                c3252atx.e(c3244atp.f);
            }
            C3244atp c3244atp2 = this.a;
            ZI.IeS ieS = new ZI.IeS() { // from class: o.atz
                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    ((InterfaceC9045dcM) obj).i();
                }
            };
            if (c3244atp2.f != 0) {
                ieS.e(c3244atp2.f);
            }
        }
    }

    public final void a(HA ha, tPx tpx) {
        if (tpx == null || !tpx.c || this.a.get()) {
            return;
        }
        this.a.set(true);
        ZI.IeS ieS = new ZI.IeS() { // from class: o.atv
            @Override // o.ZI.IeS
            public final void e(Object obj) {
                ((InterfaceC9045dcM) obj).j();
            }
        };
        if (this.f != 0) {
            ieS.e(this.f);
        }
        this.d.c(new rOI(Integer.valueOf(ha.e), tpx.a + 1), true);
        ZBH zbh = this.d;
        zbh.d(zbh.i, new RVV(this));
    }
}