package o;

/* loaded from: classes6.dex */
public final class fWP extends AbstractC13163fSk<Long> {
    private final long c;
    private final long e;

    public fWP(long j, long j2) {
        this.e = j;
        this.c = j2;
    }

    @Override // o.AbstractC13163fSk
    public final void subscribeActual(InterfaceC13174fSv<? super Long> interfaceC13174fSv) {
        long j = this.e;
        IeS ieS = new IeS(interfaceC13174fSv, j, j + this.c);
        interfaceC13174fSv.onSubscribe(ieS);
        if (ieS.a) {
            return;
        }
        InterfaceC13174fSv<? super Long> interfaceC13174fSv2 = ieS.e;
        long j2 = ieS.b;
        for (long j3 = ieS.c; j3 != j2 && ieS.get() == 0; j3++) {
            interfaceC13174fSv2.onNext(Long.valueOf(j3));
        }
        if (ieS.get() == 0) {
            ieS.lazySet(1);
            interfaceC13174fSv2.onComplete();
        }
    }

    /* loaded from: classes6.dex */
    static final class IeS extends AbstractC13183fTH<Long> {
        boolean a;
        final long b;
        long c;
        final InterfaceC13174fSv<? super Long> e;

        @Override // o.InterfaceC13414fZq
        public final /* synthetic */ Object b() throws Throwable {
            long j = this.c;
            if (j != this.b) {
                this.c = 1 + j;
                return Long.valueOf(j);
            }
            lazySet(1);
            return null;
        }

        IeS(InterfaceC13174fSv<? super Long> interfaceC13174fSv, long j, long j2) {
            this.e = interfaceC13174fSv;
            this.c = j;
            this.b = j2;
        }

        @Override // o.InterfaceC13414fZq
        public final void e() {
            this.c = this.b;
            lazySet(1);
        }

        @Override // o.fSJ
        public final void dispose() {
            set(1);
        }

        @Override // o.fSJ
        public final boolean isDisposed() {
            return get() != 0;
        }

        @Override // o.InterfaceC13413fZp
        public final int b(int i) {
            if ((i & 1) == 0) {
                return 0;
            }
            this.a = true;
            return 1;
        }

        @Override // o.InterfaceC13414fZq
        public final boolean c() {
            return this.c == this.b;
        }
    }
}