Simple store

SimpleStore.kt

class Store<S : State>(
    initialState: S,
    reduce: (Action, S) -> S,
    val scope: CoroutineScope,
) {

    private val inputActionsChannel: Channel<Action> = 
        Channel(capacity = Channel.UNLIMITED)

    private val outputChannel: Channel<S> = Channel()

    private val publishActions: MutableSharedFlow<Action> = MutableSharedFlow()
    private val outputStateFlow: MutableStateFlow<S> = MutableStateFlow(initialState)

    val actions: Flow<Action> = publishActions
    val states: Flow<S> = outputStateFlow

    init {
        scope.stateMachine(
            initialState = initialState,
            inputActionsChannel = inputActionsChannel,
            outputChannel = outputChannel,
            publishActions = publishActions,
            outputStateFlow = outputStateFlow,
            reduce = reduce,
        )
    }

    fun dispatch(action: Action) {
        inputActionsChannel.trySend(action)
    }

    suspend fun getState(): S {
        inputActionsChannel.send(RequestStateAction)
        return outputChannel.receive()
    }

    fun terminate() {
        scope.cancel()
    }
}