Simple example how events can be debounced on StateMachine side

StateMachineDebounceExample.kt

// Keep in mind this is just simplified example
class Example {

    private val scope = CoroutineScope(Job())

    private val debouncingChannel = Channel<UserEvent>(
        capacity = RENDEZVOUS,
        onBufferOverflow = BufferOverflow.DROP_OLDEST,
    )

    val stateMachine = StateMachine(
        initialState = Unit,
        reduceState = ::reduceState
    )

    init {
        // You can have more sophisticated debouncing logic here
        debouncingChannel.receiveAsFlow()
            .debounce(timeoutMillis = 200)
            .onEach { stateMachine.handleEvent(DebouncedUserEvent) }
            .launchIn(scope)
    }


    private fun reduceState(
        currentState: Unit,
        event: Event
    ) {
        when (event) {
            is UserEvent -> {
                debouncingChannel.trySend(event)
            }
            is DebouncedUserEvent -> {
                // modify state here
            }
        }
    }

    interface Event {
        object UserEvent : Event
        object DebouncedUserEvent : Event
    }
}