package o;

import java.util.ArrayList;
import java.util.List;
import o.C6387cRd;
import o.InterfaceC9010dbe;
import o.ZI;
import o.wRi;

/* renamed from: o.cRd, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public class C6387cRd extends ZI<InterfaceC9010dbe.dAO> {
    private final REU a;
    public List<XB> b;
    private final DN c;
    private final String d;
    private boolean e;
    private int g;
    private boolean h;
    private String i;
    private int k;

    @InterfaceC13391fZD
    public C6387cRd(DN dn, REU reu, C16903sI c16903sI, String str) {
        super(c16903sI);
        this.c = dn;
        this.a = reu;
        this.i = str;
        this.d = reu.c.m();
        this.g = 1;
        this.k = 1;
        this.e = false;
        this.h = false;
    }

    public final void e(final XB xb) {
        if (xb != null && "RTP".equals(xb.l)) {
            ZI.IeS ieS = new ZI.IeS(xb) { // from class: o.cRf
                private XB e;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    ((InterfaceC9010dbe.dAO) obj).e(this.e);
                }

                {
                    this.e = xb;
                }
            };
            if (this.f != 0) {
                ieS.e(this.f);
                return;
            }
            return;
        }
        ZI.IeS ieS2 = new ZI.IeS(xb) { // from class: o.cRc
            private XB d;

            @Override // o.ZI.IeS
            public final void e(Object obj) {
                ((InterfaceC9010dbe.dAO) obj).c(this.d);
            }

            {
                this.d = xb;
            }
        };
        if (this.f != 0) {
            ieS2.e(this.f);
        }
    }

    /* renamed from: o.cRd$RVV */
    /* loaded from: classes4.dex */
    final class RVV extends wRi.LWm<IeT> {
        private C6387cRd b;

        private RVV(C6387cRd c6387cRd) {
            this.b = c6387cRd;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            IeT ieT = (IeT) obj;
            if (this.b.f != 0) {
                if (ieT.d != null) {
                    this.b.k = ieT.d.a;
                    this.b.g = ieT.d.b;
                    this.b.e = false;
                    if (this.b.k != this.b.g) {
                        this.b.g++;
                    } else {
                        this.b.e = true;
                    }
                }
                if (ieT.d.c == null || ieT.d.c.isEmpty()) {
                    if (this.b.b == null || this.b.b.isEmpty()) {
                        C6387cRd c6387cRd = this.b;
                        ZI.IeS ieS = new ZI.IeS() { // from class: o.cRh
                            @Override // o.ZI.IeS
                            public final void e(Object obj2) {
                                ((InterfaceC9010dbe.dAO) obj2).d();
                            }
                        };
                        if (c6387cRd.f != 0) {
                            ieS.e(c6387cRd.f);
                            return;
                        }
                        return;
                    }
                    return;
                }
                if (this.b.d != null) {
                    final XB c = this.b.c.c(ieT.d.c, ieT.e, this.b.d);
                    if (c == null) {
                        C6387cRd c6387cRd2 = this.b;
                        C6385cRb c6385cRb = new C6385cRb();
                        if (c6387cRd2.f != 0) {
                            c6385cRb.e(c6387cRd2.f);
                            return;
                        }
                        return;
                    }
                    final String str = c.i;
                    C6387cRd c6387cRd3 = this.b;
                    ZI.IeS ieS2 = new ZI.IeS(str, c) { // from class: o.cRk
                        private String b;
                        private XB d;

                        @Override // o.ZI.IeS
                        public final void e(Object obj2) {
                            C6387cRd.RVV.e(this.b, this.d, (InterfaceC9010dbe.dAO) obj2);
                        }

                        {
                            this.b = str;
                            this.d = c;
                        }
                    };
                    if (c6387cRd3.f != 0) {
                        ieS2.e(c6387cRd3.f);
                        return;
                    }
                    return;
                }
                final List<XB> c2 = this.b.c.c(ieT.d.c, ieT.e);
                C6387cRd c6387cRd4 = this.b;
                ZI.IeS ieS3 = new ZI.IeS(c2) { // from class: o.cRj
                    private List c;

                    @Override // o.ZI.IeS
                    public final void e(Object obj2) {
                        ((InterfaceC9010dbe.dAO) obj2).c((List<XB>) this.c);
                    }

                    {
                        this.c = c2;
                    }
                };
                if (c6387cRd4.f != 0) {
                    ieS3.e(c6387cRd4.f);
                }
                if (this.b.b == null) {
                    this.b.b = new ArrayList();
                }
                this.b.b.addAll(c2);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onComplete() {
            this.b.h = false;
            C6387cRd.h(this.b);
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            this.b.h = false;
            C6387cRd.j(this.b);
            if (this.b.i(th)) {
                return;
            }
            C6387cRd c6387cRd = this.b;
            C6385cRb c6385cRb = new C6385cRb();
            if (c6387cRd.f != 0) {
                c6385cRb.e(c6387cRd.f);
            }
        }

        /* JADX INFO: Access modifiers changed from: package-private */
        public static /* synthetic */ void e(String str, XB xb, InterfaceC9010dbe.dAO dao) {
            if (str != null && !kcz.c(str)) {
                dao.e(str);
            } else {
                dao.d(xb);
            }
        }

        /* synthetic */ RVV(C6387cRd c6387cRd, byte b) {
            this(c6387cRd);
        }
    }

    static /* synthetic */ void h(C6387cRd c6387cRd) {
        if (c6387cRd.f != 0) {
            c6387cRd.f.aq_();
        }
    }

    static /* synthetic */ void j(C6387cRd c6387cRd) {
        if (c6387cRd.f != 0) {
            c6387cRd.f.aq_();
        }
    }

    public final void d(boolean z) {
        byte b = 0;
        if (z) {
            this.g = 1;
            this.k = 1;
            this.e = false;
        }
        if (this.g > this.k || this.e || this.h) {
            return;
        }
        this.h = true;
        if (this.f != 0) {
            this.f.v();
        }
        this.a.d(this.g, this.i);
        REU reu = this.a;
        reu.d(reu.i, new RVV(this, b));
    }
}