package o;

import java.util.List;
import o.C5975cEs;
import o.InterfaceC8929daC;
import o.ZI;
import o.wRi;

/* renamed from: o.cEs, reason: case insensitive filesystem */
/* loaded from: classes4.dex */
public class C5975cEs extends ZI<InterfaceC8929daC.IeS> {
    public int a;
    public int b;
    public final mSw c;
    public final C8238dFW d;
    public final BE e;
    private BD h;

    @InterfaceC13391fZD
    public C5975cEs(C16903sI c16903sI, mSw msw, BE be, BD bd, C8238dFW c8238dFW) {
        super(c16903sI);
        this.e = be;
        this.h = bd;
        this.c = msw;
        this.d = c8238dFW;
        this.b = 1;
        this.a = 1;
    }

    @Override // o.ZI
    public final void w_() {
        super.w_();
        C8238dFW c8238dFW = this.d;
        if (c8238dFW.h.isDisposed()) {
            return;
        }
        c8238dFW.h.dispose();
    }

    /* renamed from: o.cEs$Sts */
    /* loaded from: classes4.dex */
    public final class Sts extends wRi.LWm<C8987dbH> {
        private C5975cEs b;

        private Sts(C5975cEs c5975cEs) {
            this.b = c5975cEs;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            C8987dbH c8987dbH = (C8987dbH) obj;
            if (this.b.f != 0) {
                final List list = (List) C16157lj.c(new Object[]{c8987dbH.c, new BG(this.b.h, this.b.c.b.T())}, -1846295624, 1846295631, (int) System.currentTimeMillis());
                C5975cEs c5975cEs = this.b;
                ZI.IeS ieS = new ZI.IeS(list) { // from class: o.cEt
                    private List d;

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

                    {
                        this.d = list;
                    }
                };
                if (c5975cEs.f != 0) {
                    ieS.e(c5975cEs.f);
                }
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(Throwable th) {
            if (this.b.i(th) || this.b.f == 0) {
                return;
            }
            C5975cEs c5975cEs = this.b;
            c5975cEs.d(c5975cEs.j.e(th));
        }

        public /* synthetic */ Sts(C5975cEs c5975cEs, byte b) {
            this(c5975cEs);
        }
    }

    /* renamed from: o.cEs$IeS */
    /* loaded from: classes4.dex */
    public final class IeS extends wRi.LWm<WZW> {
        private C5975cEs e;

        private IeS(C5975cEs c5975cEs) {
            this.e = c5975cEs;
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final /* synthetic */ void onNext(Object obj) {
            int i;
            int i2;
            final WZW wzw = (WZW) obj;
            if (this.e.f != 0) {
                if (wzw.a > 0) {
                    i2 = wzw.a;
                    i = wzw.b + 1;
                } else {
                    i = wzw.b;
                    i2 = 1;
                }
                if (this.e.b == 1) {
                    C5975cEs c5975cEs = this.e;
                    ZI.IeS ieS = new ZI.IeS(this, wzw) { // from class: o.cEv
                        private WZW b;
                        private C5975cEs.IeS d;

                        @Override // o.ZI.IeS
                        public final void e(Object obj2) {
                            ((InterfaceC8929daC.IeS) obj2).b(true, (List) C16157lj.c(new Object[]{r1.c, new C16164ln(r0.e.e, this.d.e.c.b.T())}, -1846295624, 1846295631, (int) System.currentTimeMillis()), this.b.a);
                        }

                        {
                            this.d = this;
                            this.b = wzw;
                        }
                    };
                    if (c5975cEs.f != 0) {
                        ieS.e(c5975cEs.f);
                    }
                    this.e.b = i;
                    this.e.a = i2;
                } else if (this.e.b <= wzw.b && this.e.b <= wzw.a) {
                    C5975cEs c5975cEs2 = this.e;
                    ZI.IeS ieS2 = new ZI.IeS(this, wzw) { // from class: o.cEu
                        private C5975cEs.IeS a;
                        private WZW e;

                        @Override // o.ZI.IeS
                        public final void e(Object obj2) {
                            ((InterfaceC8929daC.IeS) obj2).b(false, (List) C16157lj.c(new Object[]{r1.c, new C16164ln(r0.e.e, this.a.e.c.b.T())}, -1846295624, 1846295631, (int) System.currentTimeMillis()), this.e.a);
                        }

                        {
                            this.a = this;
                            this.e = wzw;
                        }
                    };
                    if (c5975cEs2.f != 0) {
                        ieS2.e(c5975cEs2.f);
                    }
                    this.e.b = i;
                    this.e.a = i2;
                } else {
                    C5975cEs c5975cEs3 = this.e;
                    ZI.IeS ieS3 = new ZI.IeS(wzw) { // from class: o.cEA
                        private WZW c;

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

                        {
                            this.c = wzw;
                        }
                    };
                    if (c5975cEs3.f != 0) {
                        ieS3.e(c5975cEs3.f);
                    }
                    this.e.a = 1;
                }
                C5975cEs.f(this.e);
            }
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onComplete() {
            C5975cEs.i(this.e);
        }

        @Override // o.wRi.LWm, o.InterfaceC13174fSv
        public final void onError(final Throwable th) {
            if (this.e.i(th) || this.e.f == 0) {
                return;
            }
            C5975cEs c5975cEs = this.e;
            ZI.IeS ieS = new ZI.IeS(this, th) { // from class: o.cEw
                private Throwable b;
                private C5975cEs.IeS c;

                @Override // o.ZI.IeS
                public final void e(Object obj) {
                    InterfaceC8929daC.IeS ieS2 = (InterfaceC8929daC.IeS) obj;
                    ieS2.c(this.c.e.j.e(this.b));
                }

                {
                    this.c = this;
                    this.b = th;
                }
            };
            if (c5975cEs.f != 0) {
                ieS.e(c5975cEs.f);
            }
        }

        public /* synthetic */ IeS(C5975cEs c5975cEs, byte b) {
            this(c5975cEs);
        }
    }

    static /* synthetic */ void i(C5975cEs c5975cEs) {
        if (c5975cEs.f != 0) {
            c5975cEs.f.aq_();
        }
    }

    static /* synthetic */ void f(C5975cEs c5975cEs) {
        if (c5975cEs.f != 0) {
            c5975cEs.f.aq_();
        }
    }
}