ConcurrentStrategyWithTag

open class ConcurrentStrategyWithTag(private val tag: Any) : ConcurrentStrategy() {

    override fun shouldAddToPendingActions(
        pendingActionCommands: RemoveOnlyList<ActionCommand<*, *>>,
        runningActionCommands: List<ActionCommand<*, *>>
    ): Boolean {
        pendingActionCommands.removeAll { command ->
            command.strategy.let { it is ConcurrentStrategyWithTag && it.tag == tag }
        }
        return true
    }

    override fun shouldExecuteAction(
        pendingActionCommands: RemoveOnlyList<ActionCommand<*, *>>,
        runningActionCommands: List<ActionCommand<*, *>>
    ): Boolean =
        !runningActionCommands.any { command ->
            command.strategy.let { it is ConcurrentStrategyWithTag && it.tag == tag }
        }
}