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

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

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

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

        public a(d.a.l<? super Long> lVar) {
            this.f5814b = 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.f5814b.d(0L);
            lazySet(d.a.s.a.c.INSTANCE);
            this.f5814b.b();
        }
    }

    public r(long j2, TimeUnit timeUnit, d.a.m mVar) {
        this.f5812c = j2;
        this.f5813d = timeUnit;
        this.f5811b = 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.f5811b.c(aVar, this.f5812c, this.f5813d));
    }
}