@@ -8,12 +8,12 @@ import java.util.concurrent.atomic.AtomicBoolean
8
8
import java.util.function.Supplier
9
9
10
10
fun SwitchReactor.whileTriggeredSubmit (switch : Switch , supplier : Supplier <Command >) {
11
- val cancelRequireable = object : Requirable {}
11
+ val cancelRequirable = object : Requirable {}
12
12
13
13
onTriggeredSubmit(switch, object : Supplier <Command > {
14
14
private val requirements: Set <Requirable > =
15
15
supplier.get().requirements.toMutableSet().apply {
16
- add(cancelRequireable )
16
+ add(cancelRequirable )
17
17
}
18
18
19
19
override fun get (): Command = CommandWrapper (
@@ -22,23 +22,23 @@ fun SwitchReactor.whileTriggeredSubmit(switch: Switch, supplier: Supplier<Comman
22
22
)
23
23
})
24
24
onUntriggeredSubmit(switch, Supplier {
25
- Command .cancel(cancelRequireable )
25
+ Command .cancel(cancelRequirable )
26
26
})
27
27
}
28
28
29
29
fun SwitchReactor.onTriggeredLifecycleSubmit (
30
30
switch : Switch ,
31
31
supplier : Supplier <Command >
32
32
) = onTriggeredSubmit(switch, object : Supplier <Command > {
33
- private val cancelRequireable = object : Requirable {}
33
+ private val cancelRequirable = object : Requirable {}
34
34
private val isRunning = AtomicBoolean ()
35
35
private val requirements: Set <Requirable > =
36
36
supplier.get().requirements.toMutableSet().apply {
37
- add(cancelRequireable )
37
+ add(cancelRequirable )
38
38
}
39
39
40
40
override fun get (): Command = if (isRunning.getAndSet(! isRunning.get())) {
41
- Command .cancel(cancelRequireable )
41
+ Command .cancel(cancelRequirable )
42
42
} else {
43
43
CommandWrapper (supplier.get(), overrideRequirements = requirements)
44
44
}
0 commit comments