67 lines
2.1 KiB
Java
67 lines
2.1 KiB
Java
|
package o;
|
||
|
|
|
||
|
|
import java.util.concurrent.TimeUnit;
|
||
|
|
import java.util.concurrent.atomic.AtomicReference;
|
||
|
|
import o.AbstractC13173fSu;
|
||
|
|
|
||
|
|
/* renamed from: o.fWu, reason: case insensitive filesystem */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
public final class C13312fWu extends AbstractC13163fSk<Long> {
|
||
|
|
private AbstractC13173fSu a;
|
||
|
|
private long c;
|
||
|
|
private long d;
|
||
|
|
private TimeUnit e;
|
||
|
|
|
||
|
|
public C13312fWu(long j, long j2, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) {
|
||
|
|
this.c = j;
|
||
|
|
this.d = j2;
|
||
|
|
this.e = timeUnit;
|
||
|
|
this.a = abstractC13173fSu;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.AbstractC13163fSk
|
||
|
|
public final void subscribeActual(InterfaceC13174fSv<? super Long> interfaceC13174fSv) {
|
||
|
|
RVV rvv = new RVV(interfaceC13174fSv);
|
||
|
|
interfaceC13174fSv.onSubscribe(rvv);
|
||
|
|
AbstractC13173fSu abstractC13173fSu = this.a;
|
||
|
|
if (abstractC13173fSu instanceof fYE) {
|
||
|
|
AbstractC13173fSu.Sts c = abstractC13173fSu.c();
|
||
|
|
EnumC13192fTf.a(rvv, c);
|
||
|
|
c.a(rvv, this.c, this.d, this.e);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
EnumC13192fTf.a(rvv, abstractC13173fSu.d(rvv, this.c, this.d, this.e));
|
||
|
|
}
|
||
|
|
|
||
|
|
/* renamed from: o.fWu$RVV */
|
||
|
|
/* loaded from: classes6.dex */
|
||
|
|
static final class RVV extends AtomicReference<fSJ> implements fSJ, Runnable {
|
||
|
|
private long b;
|
||
|
|
private InterfaceC13174fSv<? super Long> d;
|
||
|
|
|
||
|
|
RVV(InterfaceC13174fSv<? super Long> interfaceC13174fSv) {
|
||
|
|
this.d = interfaceC13174fSv;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final void dispose() {
|
||
|
|
EnumC13192fTf.e(this);
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // o.fSJ
|
||
|
|
public final boolean isDisposed() {
|
||
|
|
return get() == EnumC13192fTf.DISPOSED;
|
||
|
|
}
|
||
|
|
|
||
|
|
@Override // java.lang.Runnable
|
||
|
|
public final void run() {
|
||
|
|
if (get() != EnumC13192fTf.DISPOSED) {
|
||
|
|
InterfaceC13174fSv<? super Long> interfaceC13174fSv = this.d;
|
||
|
|
long j = this.b;
|
||
|
|
this.b = 1 + j;
|
||
|
|
interfaceC13174fSv.onNext(Long.valueOf(j));
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|