package d.a.s.e.c;

import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;

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

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final d.a.m f5796b;

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

    /* JADX INFO: renamed from: d, reason: collision with root package name */
    public final TimeUnit f5798d;

    public static final class a extends AtomicReference<d.a.p.b> implements d.a.p.b, Runnable {

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

        public a(d.a.l<? super Long> lVar) {
            this.f5799b = lVar;
        }

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

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

        @Override // java.lang.Runnable
        public void run() {
            if (isDisposed()) {
                return;
            }
            this.f5799b.d(0L);
            lazySet(d.a.s.a.c.INSTANCE);
            this.f5799b.b();
        }
    }

    public r(long j2, TimeUnit timeUnit, d.a.m mVar) {
        this.f5797c = j2;
        this.f5798d = timeUnit;
        this.f5796b = mVar;
    }

    @Override // d.a.h
    public void o(d.a.l<? super Long> lVar) {
        a aVar = new a(lVar);
        lVar.c(aVar);
        d.a.s.a.b.trySet(aVar, this.f5796b.c(aVar, this.f5797c, this.f5798d));
    }
}