update outwatch

Author: cornerman

project/Deps.scala

@@ -56,7 +56,7 @@ object Deps {
   val scalarx = dep("com.github.cornerman.scalarx" %%% "scalarx" % "7daef55")
   // val scalarx = dep("com.github.fdietze.duality" %%% "scalarx" % "fc761c9")
   val outwatch = new {
-    private val version = "eb744f78"
+    private val version = "2a6a06aa"
     // val core = dep("io.github.outwatch" %%% "outwatch" % "0.11.1-SNAPSHOT")
     val core = dep("com.github.cornerman.outwatch" %%% "outwatch" % version)
     // val monix = dep("io.github.outwatch" %%% "outwatch-monix" % "0.11.1-SNAPSHOT")

webApp/src/main/scala/wust/webApp/state/GlobalState.scala

@@ -27,11 +27,9 @@ import scala.util.Try
 object GlobalState {
   implicit val ctx: Ctx.Owner = Ctx.Owner.safe()
 
-  val isClientOnline = SourceStream.merge(Client.observable.connected.map(_ => true), Client.observable.closed.map(_ => false))
-    .shareWithLatestSeed(false)
+  val isClientOnline = SourceStream.merge(Client.observable.connected.map(_ => true), Client.observable.closed.map(_ => false)).behavior(false)
   //TODO: is browser does not trigger?!
-  val isBrowserOnline = SourceStream.merge(events.window.onOffline.map(_ => false), events.window.onOnline.map(_ => true))
-    .shareWithLatestSeed(false)
+  val isBrowserOnline = SourceStream.merge(events.window.onOffline.map(_ => false), events.window.onOnline.map(_ => true)).behavior(false)
 
   // register the serviceworker and get an update observable when serviceworker updates are available.
   val serviceWorkerIsActivated: SourceStream[Unit] = if (LinkingInfo.productionMode) ServiceWorker.register(WoostConfig.value.urls.serviceworker) else SourceStream.empty

webApp/src/main/scala/wust/webApp/views/Components.scala

@@ -628,7 +628,7 @@ object Components {
         implicit ctx => handler => searchAndSelectNodeApplied[Handler](
           ProHandler(
             handler.edit.contramap[Option[NodeId]](EditInteraction.fromOption(_)),
-            handler.edit.collect[Option[NodeId]] { case EditInteraction.Input(id) => Some(id) }.prepend(Some(node.id)).shareWithLatest,
+            handler.edit.collect[Option[NodeId]] { case EditInteraction.Input(id) => Some(id) }.prepend(Some(node.id)).replayLatest
           ),
           filter = (_:Node) => true
         ),

webApp/src/main/scala/wust/webApp/views/EditableContent.scala

@@ -213,7 +213,7 @@ object EditableContent {
   private def commonEditStructure[T](initial: Option[T], current: Handler[EditInteraction[T]], config: Config, handle: EditInteraction[T] => EditInteraction[T])(modifier: CommonEditHandler[T] => VDomModifier) = {
     val handledCurrent = ProHandler(
       current.contramap[EditInteraction[T]](handleEditInteraction[T](initial, config) andThen handle),
-      current.filter(uniqueEditInteraction[T](initial)).shareWithLatest
+      current.filter(uniqueEditInteraction[T](initial)).replayLatest
     )
 
     val saveHandler = Handler.publish.unsafe[Unit]

webApp/src/main/scala/wust/webApp/views/FormView.scala

@@ -171,7 +171,7 @@ object FormView {
       implicit ctx => handler => searchAndSelectNodeApplied[Handler](
         ProHandler(
           handler.edit.contramap[Option[NodeId]](EditInteraction.fromOption(_)),
-          handler.edit.collect[Option[NodeId]] { case EditInteraction.Input(id) => Some(id) }.prepend(Some(node.id)).shareWithLatest,
+          handler.edit.collect[Option[NodeId]] { case EditInteraction.Input(id) => Some(id) }.prepend(Some(node.id)).replayLatest
         ),
         filter = (n:Node) => true,
       ),

webApp/src/main/scala/wust/webApp/views/LeftSidebar.scala

@@ -262,7 +262,7 @@ object LeftSidebar {
       val isSynced = Rx {
         GlobalState.isSynced() && !GlobalState.isLoading()
       }
-      SourceStream.combineLatest(GlobalState.isClientOnline.distinctOnEquals)(isSynced)
+      SourceStream.combineLatest(GlobalState.isClientOnline.distinctOnEquals, isSynced)
     }
 
     val syncStatusIcon = status.map { status =>