package f.a.n.e.b;

import f.a.g;
import f.a.h;
import f.a.i;
import f.a.k.b;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: SingleTimer.java */
/* JADX INFO: loaded from: classes.dex */
public final class a extends h<Long> {
    final long a;
    final TimeUnit b;

    /* JADX INFO: renamed from: c, reason: collision with root package name */
    final g f862c;

    /* JADX INFO: renamed from: f.a.n.e.b.a$a, reason: collision with other inner class name */
    /* JADX INFO: compiled from: SingleTimer.java */
    static final class RunnableC0052a extends AtomicReference<b> implements b, Runnable {
        final i<? super Long> b;

        RunnableC0052a(i<? super Long> iVar) {
            this.b = iVar;
        }

        void a(b bVar) {
            f.a.n.a.b.replace(this, bVar);
        }

        @Override // f.a.k.b
        public void dispose() {
            f.a.n.a.b.dispose(this);
        }

        @Override // java.lang.Runnable
        public void run() {
            this.b.b(0L);
        }
    }

    public a(long j2, TimeUnit timeUnit, g gVar) {
        this.a = j2;
        this.b = timeUnit;
        this.f862c = gVar;
    }

    @Override // f.a.h
    protected void d(i<? super Long> iVar) {
        RunnableC0052a runnableC0052a = new RunnableC0052a(iVar);
        iVar.c(runnableC0052a);
        runnableC0052a.a(this.f862c.c(runnableC0052a, this.a, this.b));
    }
}