AbstractStateNotifier

AbstractStateNotifier.kt

abstract class AbstractStateNotifier<ACTION : Action, STATE : State, EFFECT : Effect, VM : MviViewModel<*, ACTION, STATE, EFFECT>>(
    uiContext: CoroutineContext
) : CoroutineScope {

    private val job = SupervisorJob()

    override val coroutineContext: CoroutineContext = job + uiContext

    fun stateChanged(vm: VM, state: (state: STATE) -> Unit): Job {
        return launch { vm.states.collect { state(it) } }
    }

    fun effectReceived(vm: VM, effect: (effect: EFFECT) -> Unit): Job {
        return launch { vm.effects.collectUnhandled { effect(it) } }
    }

    fun dispose() {
        job.cancel()
    }
}

DepositProductDetailVMStateNotifier.kt

class DepositProductDetailVMStateNotifier(uiContext: CoroutineContext) :
    AbstractStateNotifier<
        DepositProductDetailAction,
        DepositProductDetailState,
        DepositProductDetailEffect,
        DepositProductDetailViewModel>(uiContext)