add Rx boolean ops toggle and negated

cornerman · Oct 24, 2022 · 7b0fda5 · 7b0fda5
1 parent f26a9dc
commit 7b0fda5
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/reactive/src/main/scala/colibri/reactive/Reactive.scala b/reactive/src/main/scala/colibri/reactive/Reactive.scala
@@ -1,5 +1,6 @@
 package colibri.reactive
 
+import cats.Monoid
 import colibri._
 import colibri.effect._
 import monocle.{Iso, Lens, Prism}
@@ -69,6 +70,17 @@ object Rx extends RxPlatform {
     def filter(f: A => Boolean)(seed: => A)(implicit owner: Owner): Rx[A] = self.transformRx(_.filter(f))(seed)
   }
 
+  @inline implicit class RxBooleanOps(private val source: Rx[Boolean]) extends AnyVal {
+    @inline def toggle[A](ifTrue: => A, ifFalse: A)(implicit owner: Owner): Rx[A] = source.map {
+      case true  => ifTrue
+      case false => ifFalse
+    }
+
+    @inline def toggle[A: Monoid](ifTrue: => A)(implicit owner: Owner): Rx[A] = toggle(ifTrue, Monoid[A].empty)
+
+    @inline def negated(implicit owner: Owner): Rx[Boolean] = source.map(x => !x)
+  }
+
   implicit object source extends Source[Rx] {
     def unsafeSubscribe[A](source: Rx[A])(sink: Observer[A]): Cancelable = source.observable.unsafeSubscribe(sink)
   }