package o; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicReference; /* loaded from: classes6.dex */ public final class fXB extends AbstractC13163fSk { private TimeUnit a; private long c; private AbstractC13173fSu d; public fXB(long j, TimeUnit timeUnit, AbstractC13173fSu abstractC13173fSu) { this.c = j; this.a = timeUnit; this.d = abstractC13173fSu; } @Override // o.AbstractC13163fSk public final void subscribeActual(InterfaceC13174fSv interfaceC13174fSv) { HBt hBt = new HBt(interfaceC13174fSv); interfaceC13174fSv.onSubscribe(hBt); EnumC13192fTf.b(hBt, this.d.d(hBt, this.c, this.a)); } /* loaded from: classes6.dex */ static final class HBt extends AtomicReference implements fSJ, Runnable { private InterfaceC13174fSv c; HBt(InterfaceC13174fSv interfaceC13174fSv) { this.c = 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 (isDisposed()) { return; } this.c.onNext(0L); lazySet(EnumC13195fTi.INSTANCE); this.c.onComplete(); } } }