deprecate Observable#to

cornerman · Dec 16, 2022 · a8ef066 · a8ef066
1 parent 93f7829
commit a8ef066
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/reactive/src/main/scala/colibri/reactive/Owner.scala b/reactive/src/main/scala/colibri/reactive/Owner.scala
@@ -38,7 +38,7 @@ object LiveOwner extends LiveOwnerPlatform {
     }
 
     def unsafeLive[A](rx: Rx[A]): A = {
-      ref.unsafeAdd(() => rx.observable.to(subject).unsafeSubscribe())
+      ref.unsafeAdd(() => rx.observable.via(subject).unsafeSubscribe())
       rx.nowGet()
     }
   }