Jason
02/26/2020, 10:33 AMrxJava
Single.timer(INTERVAL_SECONDS, TimeUnit.SECONDS)
.flatMap{ // call API }
.repeat()
.subscribeOn(<http://Schedules.io|Schedules.io>())
I heard someone mentioned using flow
. It look likes
while(true){
// call
// delay(intervalMili)
}
So I think it’s not looking good .camkadev
02/26/2020, 10:53 AMmarstran
02/26/2020, 1:16 PMmarstran
02/26/2020, 1:17 PMkevin.cianfarini
02/26/2020, 8:38 PMfun buildTickerFlow(timeMillis: Long) = flow {
while (true) {
emit(Unit)
delay(timeMillis)
}
}
buildTickerFlow(1000).onEach { // do something }.launchIn(scope)
Jason
02/28/2020, 2:27 AMJason
02/28/2020, 2:28 AM