package f.a.w.e.d;

import f.a.o;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.atomic.AtomicReference;

/* JADX INFO: compiled from: ObservableInterval.java */
/* JADX INFO: loaded from: classes.dex */
public final class q extends f.a.i<Long> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final f.a.o f3861b;

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

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

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

    /* JADX INFO: compiled from: ObservableInterval.java */
    public static final class a extends AtomicReference<f.a.t.b> implements f.a.t.b, Runnable {

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

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

        public a(f.a.n<? super Long> nVar) {
            this.f3865b = nVar;
        }

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

        @Override // java.lang.Runnable
        public void run() {
            if (get() != f.a.w.a.b.DISPOSED) {
                f.a.n<? super Long> nVar = this.f3865b;
                long j2 = this.f3866e;
                this.f3866e = 1 + j2;
                nVar.c(Long.valueOf(j2));
            }
        }
    }

    public q(long j2, long j3, TimeUnit timeUnit, f.a.o oVar) {
        this.f3862e = j2;
        this.f3863f = j3;
        this.f3864g = timeUnit;
        this.f3861b = oVar;
    }

    @Override // f.a.i
    public void v(f.a.n<? super Long> nVar) {
        a aVar = new a(nVar);
        nVar.b(aVar);
        f.a.o oVar = this.f3861b;
        if (!(oVar instanceof f.a.w.g.o)) {
            f.a.w.a.b.setOnce(aVar, oVar.d(aVar, this.f3862e, this.f3863f, this.f3864g));
            return;
        }
        o.c cVarA = oVar.a();
        f.a.w.a.b.setOnce(aVar, cVarA);
        cVarA.d(aVar, this.f3862e, this.f3863f, this.f3864g);
    }
}