add toSubject to VarSource

cornerman · Jun 26, 2024 · 9a782dd · 9a782dd
1 parent 73395fa
commit 9a782dd
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/reactive/src/main/scala/colibri/reactive/Reactive.scala b/reactive/src/main/scala/colibri/reactive/Reactive.scala
@@ -253,7 +253,9 @@ object RxWriter {
   }
 }
 
-trait VarSource[A] extends RxWriter[A] with RxSource[A]
+trait VarSource[A] extends RxWriter[A] with RxSource[A] {
+  final def subject: Subject[A] = Subject.from(observer, observable)
+}
 
 trait VarEvent[A] extends VarSource[A] with RxEvent[A] {
   final def transformVar[A2](f: RxWriter[A] => RxWriter[A2])(g: RxEvent[A] => RxEvent[A2]): VarEvent[A2] = VarEvent.create(f(this), g(this))