CountProcessor.kt

class CounterProcessor : Processor<CounterAction>() {

    private fun processIncrementAction(action: DelayedIncrementAction) = launch {
        delay(1000)
        put(UpdateCountAction(action.count - 1))
    }

    override fun processAction(action: CounterAction) {
        when (action) {
            is IncrementAction -> processIncrementAction(action)
        }
    }
}