diff --git a/reactive/src/main/scala/colibri/reactive/Owner.scala b/reactive/src/main/scala/colibri/reactive/Owner.scala
index 01f48534..07a179ae 100644
--- 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()
     }
   }