87 lines
2.2 KiB
Java
87 lines
2.2 KiB
Java
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;
|
|
}
|
|
}
|
|
}
|