RxJava Auto retry with attempt limit

RxRetry.kt

fun main() {

    Observable.create<String> {
        while (true) {
            if (it.isDisposed) break
            val input = readLine()
            if (input == null || input == "e") {
                it.onError(Exception())
                continue
            }
            it.onNext(input)
        }
    }.retryWhen {
        it.map { 1L }
                .scan { a, b -> a + b }
                .flatMap { errorCount ->
                    if (errorCount < 3) Observable.timer(errorCount, TimeUnit.SECONDS)
                    else Observable.error(Exception("No more retries"))
                }
    }
            .subscribeOn(Schedulers.io())
            .observeOn(Schedulers.trampoline())
            .blockingSubscribe(
                    {
                        println(it)
                    },
                    {
                        println("completed")
                    })
}