Hmm, I've fixed it by: ```source .retryWhen { ...

# rx

[vaskir]

Hmm, I've fixed it by:

source
    .retryWhen {
        it.flatMap {
            rxFlowable {
                println("pause...")
                delay(1000)
                send(0)
            }
        }
    }
    .forEach { println(it) }