How to implement timer (looping call) in Kotlin coroutine like `rxJava` ```Single.timer(INTERVAL_SEC...

# coroutines

[Jason]

How to implement timer (looping call) in Kotlin coroutine like rxJava

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]

try this https://github.com/Kotlin/kotlinx.coroutines/issues/1186

[marstran]

There's Ticker-channels, but the API is currently marked with "ObsoleteCoroutinesApi" because they're not integrated with structured concurrency. https://kotlinlang.org/docs/reference/coroutines/channels.html#ticker-channels

[marstran]

So the API will change in the future.

[kevin.cianfarini]

fun buildTickerFlow(timeMillis: Long) = flow {
    while (true) {
        emit(Unit)
        delay(timeMillis)
    }
}

buildTickerFlow(1000).onEach { // do something }.launchIn(scope)

[Jason]

Ticker-channels ….hmmm

[Jason]

let me try