in my code I have

fun foo(): Flow<Foo> = flow {
        while (context.isActive) {
            // ... process and emit ...
            delay(someMutableDelay) // wait until doing this again
        }
    }

someMutableDelay

is a mutable

var

in the same class as

fun foo()

- when it is changed I want the current running

delay

to be cancelled and the next iteration of the loop to start immediately. any suggestions for how to achieve this?

create a channel for var updates, select on receive or timeout instead of just delay

thanks - hadn’t thought of that 🙂

If

someMutableDelay

is a

MutableStateFlow<Long>

, this could work:

someMutableDelay
    .withIndex()
    .transformLatest { (i, d) ->
        if (i == 0) {
            delay(d)
        }
        emit(Unit)
    }
    .first()

ah, that's pretty elegant, and you could even do something like

private val delayStateFlow = MutableStateFlow(0L)
public var delay: Long by delayStateFlow::value

to hide the MutableStateFlow as an internal implementation detail

good idea as well