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 f5747b;

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

    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> f5749b;

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

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

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

        public a(d.a.l<? super Integer> lVar, long j2, long j3) {
            this.f5749b = lVar;
            this.f5751d = j2;
            this.f5750c = j3;
        }

        @Override // d.a.s.c.d
        public void clear() {
            this.f5751d = this.f5750c;
            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.f5751d == this.f5750c;
        }

        @Override // d.a.s.c.d
        public Object poll() {
            long j2 = this.f5751d;
            if (j2 != this.f5750c) {
                this.f5751d = 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.f5752e = true;
            return 1;
        }
    }

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

    @Override // d.a.h
    public void o(d.a.l<? super Integer> lVar) {
        a aVar = new a(lVar, this.f5747b, this.f5748c);
        lVar.c(aVar);
        if (aVar.f5752e) {
            return;
        }
        d.a.l<? super Integer> lVar2 = aVar.f5749b;
        long j2 = aVar.f5750c;
        for (long j3 = aVar.f5751d; j3 != j2 && aVar.get() == 0; j3++) {
            lVar2.d(Integer.valueOf((int) j3));
        }
        if (aVar.get() == 0) {
            aVar.lazySet(1);
            lVar2.b();
        }
    }
}