package d.f.a.r2.k3;

import android.util.Log;
import com.cvte.vman.impl.FwUpgradeManager;
import f.a.i;
import f.a.v.d;
import f.a.w.b.a;
import f.a.w.e.d.j;
import java.util.Objects;
import java.util.concurrent.TimeUnit;

/* JADX INFO: compiled from: RetryWithDelay.java */
/* JADX INFO: loaded from: classes.dex */
public class b implements d<i<? extends Throwable>, i<?>> {

    /* JADX INFO: renamed from: b, reason: collision with root package name */
    public final int f3256b;

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

    public b(int i2, int i3) {
        this.f3256b = i2;
    }

    @Override // f.a.v.d
    public i<?> apply(i<? extends Throwable> iVar) throws Exception {
        return iVar.k(new d() { // from class: d.f.a.r2.k3.a
            @Override // f.a.v.d
            public final Object apply(Object obj) {
                b bVar = this.f3255b;
                Throwable th = (Throwable) obj;
                int i2 = bVar.f3257e + 1;
                bVar.f3257e = i2;
                if (i2 > bVar.f3256b) {
                    Objects.requireNonNull(th, "exception is null");
                    return new j(new a.e(th));
                }
                StringBuilder sbC = d.b.a.a.a.C("get error, it will try after ", FwUpgradeManager.TYPE_FW_CVTE_CAMERA, " millisecond, retry count ");
                sbC.append(bVar.f3257e);
                Log.i("", sbC.toString());
                return i.B(FwUpgradeManager.TYPE_FW_CVTE_CAMERA, TimeUnit.MILLISECONDS);
            }
        });
    }
}