package d.a.s.e.c;

import d.a.m;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;

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

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

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

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

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

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

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

        public a(d.a.l<? super Long> lVar) {
            this.f5732b = 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 (get() != d.a.s.a.b.DISPOSED) {
                d.a.l<? super Long> lVar = this.f5732b;
                long j2 = this.f5733c;
                this.f5733c = 1 + j2;
                lVar.d(Long.valueOf(j2));
            }
        }
    }

    public g(long j2, long j3, TimeUnit timeUnit, d.a.m mVar) {
        this.f5729c = j2;
        this.f5730d = j3;
        this.f5731e = timeUnit;
        this.f5728b = mVar;
    }

    @Override // d.a.h
    public void o(d.a.l<? super Long> lVar) {
        a aVar = new a(lVar);
        lVar.c(aVar);
        d.a.m mVar = this.f5728b;
        if (!(mVar instanceof d.a.s.g.m)) {
            d.a.s.a.b.setOnce(aVar, mVar.d(aVar, this.f5729c, this.f5730d, this.f5731e));
            return;
        }
        m.c cVarA = mVar.a();
        d.a.s.a.b.setOnce(aVar, cVarA);
        cVarA.d(aVar, this.f5729c, this.f5730d, this.f5731e);
    }
}