refactor: simplify by c.m/run-background-task

Bad3r · Dec 11, 2024 · 8327ad5 · 8327ad5
1 parent 6cc6a20
commit 8327ad5
Showing 1 changed file with 5 additions and 15 deletions.
diff --git a/src/main/frontend/worker/rtc/core.cljs b/src/main/frontend/worker/rtc/core.cljs
@@ -387,22 +387,12 @@
 ;;; ================ API (ends) ================
 
 ;;; subscribe state ;;;
+(c.m/run-background-task
+ :subscribe-state
+ (m/reduce
+  (fn [_ v] (worker-util/post-message :rtc-sync-state v))
+  create-get-state-flow))
 
-(defonce ^:private *last-subscribe-canceler (atom nil))
-(defn- subscribe-state
-  []
-  (when-let [canceler @*last-subscribe-canceler]
-    (canceler)
-    (reset! *last-subscribe-canceler nil))
-  (let [cancel (c.m/run-task
-                (m/reduce
-                 (fn [_ v] (worker-util/post-message :rtc-sync-state v))
-                 create-get-state-flow)
-                :subscribe-state)]
-    (reset! *last-subscribe-canceler cancel)
-    nil))
-
-(subscribe-state)
 
 (comment
   (do