Store.kt

abstract class Store(private val storeThread: ThreadExecutor? = null) {

  private var actions = LinkedBlockingQueue<Action>()
  val stateHandlers: CopyOnWriteArrayList<StateHandler> = CopyOnWriteArrayList()
  val sideEffects: CopyOnWriteArrayList<SideEffect> = CopyOnWriteArrayList()

    var state = State()
        protected set

    @Synchronized
    fun dispatch(action: Action) {
        actions.offer(action)
        when {
            storeThread != null -> storeThread.execute { handle(actions.poll()) }
            else -> handle(actions.poll())
        }
    }

    private fun handle(action: Action) {
        val newState = reduce(action, state)
        dispatch(newState)
        sideEffects.dispatch(action)
    }    
  
    private fun dispatch(state: State) {
       this.state = state      
       stateHandlers.dispatch(state)
    }
  
  // --- The Reducer will be here but we see it in the next section, when we talk about it --- //
}