package d.a.s.e.c;

/* JADX INFO: loaded from: classes.dex */
public final class j extends d.a.h<Integer> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final int f5762b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    public final long f5763c;

    public static final class a extends d.a.s.d.a<Integer> {

        /* JADX INFO: renamed from: b, reason: collision with root package name */
        public final d.a.l<? super Integer> f5764b;

        /* JADX INFO: renamed from: c, reason: collision with root package name */
        public final long f5765c;

        /* JADX INFO: renamed from: d, reason: collision with root package name */
        public long f5766d;

        /* JADX INFO: renamed from: e, reason: collision with root package name */
        public boolean f5767e;

        public a(d.a.l<? super Integer> lVar, long j2, long j3) {
            this.f5764b = lVar;
            this.f5766d = j2;
            this.f5765c = j3;
        }

        @Override // d.a.s.c.d
        public void clear() {
            this.f5766d = this.f5765c;
            lazySet(1);
        }

        @Override // d.a.p.b
        public void dispose() {
            set(1);
        }

        @Override // d.a.p.b
        public boolean isDisposed() {
            return get() != 0;
        }

        @Override // d.a.s.c.d
        public boolean isEmpty() {
            return this.f5766d == this.f5765c;
        }

        @Override // d.a.s.c.d
        public Object poll() {
            long j2 = this.f5766d;
            if (j2 != this.f5765c) {
                this.f5766d = 1 + j2;
                return Integer.valueOf((int) j2);
            }
            lazySet(1);
            return null;
        }

        @Override // d.a.s.c.a
        public int requestFusion(int i2) {
            if ((i2 & 1) == 0) {
                return 0;
            }
            this.f5767e = true;
            return 1;
        }
    }

    public j(int i2, int i3) {
        this.f5762b = i2;
        this.f5763c = ((long) i2) + ((long) i3);
    }

    @Override // d.a.h
    public void o(d.a.l<? super Integer> lVar) {
        a aVar = new a(lVar, this.f5762b, this.f5763c);
        lVar.c(aVar);
        if (aVar.f5767e) {
            return;
        }
        d.a.l<? super Integer> lVar2 = aVar.f5764b;
        long j2 = aVar.f5765c;
        for (long j3 = aVar.f5766d; j3 != j2 && aVar.get() == 0; j3++) {
            lVar2.d(Integer.valueOf((int) j3));
        }
        if (aVar.get() == 0) {
            aVar.lazySet(1);
            lVar2.b();
        }
    }
}