ControllerView.kt

abstract class ControllerView(
        protected val actionDispatcher: ActionDispatcher,
        protected val stateDispatcher: StateDispatcher,
        private val handleStateDifferentThread: ThreadExecutor? = null)
    : LifecycleCallbacks, Subscriber<State> { 
      
    protected fun <T : Action> dispatch(action: T) {
        actionDispatcher.dispatch(action)
    }

    override fun onNext(data: State) {
         handleStateDifferentThread?.let { it.execute { handleState(state) } }
              ?: handleState(state)
    }

    abstract fun handleState(state: State)
}