Add an automated subscription lifecycle trigger

Signed-off-by: Alex Saveau <saveau.alexandre@gmail.com>

Author: SUPERCILEX

src/main/java/org/sert2521/gamename/util/SwitchUtils.kt

@@ -4,6 +4,7 @@ import org.strongback.SwitchReactor
 import org.strongback.command.Command
 import org.strongback.command.Requirable
 import org.strongback.components.Switch
+import java.util.concurrent.atomic.AtomicBoolean
 import java.util.function.Supplier
 
 fun SwitchReactor.whileTriggeredSubmit(switch: Switch, supplier: Supplier<Command>) {
@@ -25,6 +26,24 @@ fun SwitchReactor.whileTriggeredSubmit(switch: Switch, supplier: Supplier<Comman
     })
 }
 
+fun SwitchReactor.onTriggeredLifecycleSubmit(
+        switch: Switch,
+        supplier: Supplier<Command>
+) = onTriggeredSubmit(switch, object : Supplier<Command> {
+    private val cancelRequireable = object : Requirable {}
+    private val isRunning = AtomicBoolean()
+    private val requirements: Set<Requirable> =
+            supplier.get().requirements.toMutableSet().apply {
+                add(cancelRequireable)
+            }
+
+    override fun get(): Command = if (isRunning.getAndSet(!isRunning.get())) {
+        Command.cancel(cancelRequireable)
+    } else {
+        CommandWrapper(supplier.get(), overrideRequirements = requirements)
+    }
+})
+
 private class CommandWrapper(
         private val original: Command,
         overrideTimeoutInSeconds: Double = original.timeoutInSeconds,