CooldownStateFlow.kt

private class CooldownStateFlow<T>(
    initialValue: T,
    private val coroutineScope: CoroutineScope,
    dispatcher: CoroutineDispatcher,
    private val cooldownMillis: Long = 50L,
) {
    private val singleThreadDispatcher = dispatcher.limitedParallelism(1)
    private val _events =
        MutableSharedFlow<T>().also {
            coroutineScope.launch(singleThreadDispatcher) {
                it.collect { value -> 
                    _stateFlow.update { value }
                    delay(cooldownMillis)
                }
            }
        }
    private val _stateFlow = MutableStateFlow(initialValue)
    val stateFlow = _stateFlow.asStateFlow()

    fun update(value: T) {
        coroutineScope.launch(singleThreadDispatcher) {
            _events.emit(value)
        }
    }
}