nitrog42
03/23/2017, 5:16 PMbamdmux
03/24/2017, 8:29 AMbamdmux
03/24/2017, 8:30 AMbamdmux
03/24/2017, 8:31 AMbamdmux
03/24/2017, 8:32 AMfun now() = System.currentTimeMillis().toString().takeLast(5)
instead of Date() for timestamps to see it clearernitrog42
03/24/2017, 8:32 AMnitrog42
03/24/2017, 8:34 AMnitrog42
03/24/2017, 8:35 AMbamdmux
03/24/2017, 8:37 AMbamdmux
03/24/2017, 8:38 AMObservable
.fromCallable { nbTries++ >= 2 }
.delay(1, TimeUnit.SECONDS)
.doOnNext { println("Trying value ${now()}") }
.repeatWhen { it.delay(2, TimeUnit.SECONDS) }
.filter { it }
.timeout(5, TimeUnit.SECONDS)
.firstOrError()
.doOnSubscribe { println("Start ${now()}") }
.subscribe({ println("$nbTries $it ${now()}") }
,
{ println("Timeout ${now()}") })