BaseMVIViewModel.kt

typealias Producer<T> = suspend (Flow<T>) -> Unit

abstract class BaseMVIViewModel<State, Intent>(
    initialState: State
) : ViewModel(){
    private val intentChannel = Channel<Intent>(Channel.UNLIMITED)

    private var _state = MutableStateFlow(initialState)
    open val state: StateFlow<State>
        get() = _state

    abstract suspend fun onCollect(intent: Intent, producer: Producer<State>)
    
    abstract val tagLogger: String

    fun perform(intent: Intent){
        intentChannel.offer(intent)
    }

    init {
        viewModelScope.launch {
            handleIntents()
        }
    }

    private suspend fun handleIntents(){
        intentChannel.consumeAsFlow().collect { intent ->
            log("ViewModel", "$tagLogger.handleIntent($intent)")
            onCollect(intent){ flow ->
                flow.collect { newState ->
                    log("ViewModel", "$tagLogger.collect($newState)")
                    _state.value = newState
                }
            }
        }
    }
}