Simplify debuging information used on commit-changes.

This commit is contained in:
Andrey Antukh 2021-12-09 16:50:15 +01:00 committed by Andrés Moya
parent 7874971550
commit 06d41c552b

View file

@ -24,18 +24,26 @@
(ptk/input-stream state)) (ptk/input-stream state))
(defonce last-events (defonce last-events
(let [buffer (atom #queue []) (let [buffer (atom [])
remove #{:potok.core/undefined allowed #{:app.main.data.workspace/initialize-page
:app.main.data.workspace.notifications/handle-pointer-update}] :app.main.data.workspace/finalize-page
:app.main.data.workspace/initialize-file
:app.main.data.workspace/finalize-file}]
(->> (rx/merge
(->> stream
(rx/filter (ptk/type? :app.main.data.workspace.changes/commit-changes))
(rx/map #(-> % deref :hint-origin str))
(rx/dedupe))
(->> stream (->> stream
(rx/filter ptk/event?)
(rx/map ptk/type) (rx/map ptk/type)
(rx/filter (complement remove)) (rx/filter #(contains? allowed %))
(rx/map str) (rx/map str)))
(rx/dedupe) (rx/scan (fn [buffer event]
(rx/buffer 20 1) (cond-> (conj buffer event)
(rx/subs #(reset! buffer %))) (> (count buffer) 20)
(pop)))
#queue [])
(rx/subs #(reset! buffer (vec %))))
buffer)) buffer))
(defn emit! (defn emit!