This should work: ``` source.retryWhen { errors -&...

# getting-started

[kingsley]

This should work:

source.retryWhen { errors ->  
  errors
    .zipWith(Observable.range(1, 3)) { n, i -> i }
    .flatMap { retryCount -> Observable.timer(Math.pow(5.0, retryCount.toDouble()).toLong(), TimeUnit.SECONDS) }
}

I suppose you're on RxJava1?

[robin]

Now you beat me to it xD

[robin]

Although you're now missing the Observable.timer part, am I missing something or did you just oversee that?

[rudolf.hladik]

.retryWhen {
it -> it.zipWith(Observable.range(1,3), { n, i -> i })
.flatMap { retryCount -> Observable.timer( Math.pow(5.toDouble(), retryCount.toDouble()).toLong(), TimeUnit.SECONDS) }
}

[rudolf.hladik]

yeah now its working

[rudolf.hladik]

thanks a lot

[kingsley]

Haha. Yea. Good catch @robin. I didn't attempt to see it compile 🙈