3pp-mirror/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-05-04 13:15:53 +02:00
Code Issues Projects Releases Packages Wiki Activity

💄 Fix internal naming for make code more self-explanatory

Browse source
This commit is contained in:
Andrey Antukh 2024-06-10 18:56:59 +02:00
parent 3c1086dfcc
commit e4e56828f6
1 changed files with 5 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
frontend/src/app/main/data/persistence.cljs
View file

@ -182,7 +182,7 @@
(log/debug :hint "initialize persistence") (log/debug :hint "initialize persistence")
(let [stoper-s (rx/filter (ptk/type? ::initialize-persistence) stream) (let [stoper-s (rx/filter (ptk/type? ::initialize-persistence) stream)
commits-s local-commits-s
(->> stream (->> stream
(rx/filter dch/commit?) (rx/filter dch/commit?)
(rx/map deref) (rx/map deref)
@ -192,20 +192,20 @@
notifier-s notifier-s
(rx/merge (rx/merge
(->> commits-s (->> local-commits-s
(rx/debounce 3000) (rx/debounce 3000)
(rx/tap #(log/trc :hint "persistence beat"))) (rx/tap #(log/trc :hint "persistence beat")))
(->> stream (->> stream
(rx/filter #(= % ::force-persist))))] (rx/filter #(= % ::force-persist))))]
(rx/merge (rx/merge
(->> commits-s (->> local-commits-s
(rx/debounce 200) (rx/debounce 200)
(rx/map (fn [_] (rx/map (fn [_]
(update-status :pending))) (update-status :pending)))
(rx/take-until stoper-s)) (rx/take-until stoper-s))
(->> commits-s (->> local-commits-s
(rx/buffer-time 200) (rx/buffer-time 200)
(rx/mapcat merge-commit) (rx/mapcat merge-commit)
(rx/map dch/update-indexes) (rx/map dch/update-indexes)
@ -216,7 +216,7 @@
;; Here we watch for local commits, buffer them in a small ;; Here we watch for local commits, buffer them in a small
;; chunks (very near in time commits) and append them to the ;; chunks (very near in time commits) and append them to the
;; persistence queue ;; persistence queue
(->> commits-s (->> local-commits-s
(rx/buffer-until notifier-s) (rx/buffer-until notifier-s)
(rx/mapcat merge-commit) (rx/mapcat merge-commit)
(rx/map append-commit) (rx/map append-commit)