I need a flow builder that emits `Unit` every `X` milliseconds while it has a subscriber. What’s the...

# coroutines

[zak.taccardi]

I need a flow builder that emits Unit every X milliseconds while it has a subscriber. What’s the idiomatic approach for this?

[streetsofboston]

val flow = flow {
    while (isActive) {
        emit(Unit)
        delay(period)
    }
}

[streetsofboston]

^^^ This is a cold timer; each flow collector/subscriber (re-)starts the flow.

[zak.taccardi]

yeah, would need to add .shareIn(..)

[gildor]

Why do you need shareIn for this? It's indeed will work too, but looks that for this use case cold version also works just fine