add Var.none/some/subjectSync

cornerman · Jan 9, 2023 · 5dba05e · 5dba05e
1 parent 29e1ffe
commit 5dba05e
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/reactive/src/main/scala/colibri/reactive/Reactive.scala b/reactive/src/main/scala/colibri/reactive/Reactive.scala
@@ -178,6 +178,11 @@ trait Var[A] extends RxWriter[A] with Rx[A] {
 object Var {
   def apply[A](seed: A): Var[A] = new VarSubject(seed)
 
+  def none[A](): Var[Option[A]] = new VarSubject(None)
+  def some[A](seed: A): Var[Option[A]] = new VarSubject(Some(seed))
+
+  def subjectSync[A](read: Subject[A]): Var[A] = combine(Rx.observableSync(read), RxWriter.observer(read))
+
   def combine[A](read: Rx[A], write: RxWriter[A]): Var[A] = new VarCombine(read, write)
 
   @inline implicit class SeqVarOperations[A](rxvar: Var[Seq[A]]) {