mirror of
https://github.com/penpot/penpot.git
synced 2025-12-11 22:14:05 +01:00
Update with upstream
This commit is contained in:
@@ -48,21 +48,22 @@
|
||||
([store done events completed-cb]
|
||||
(run-store store done events completed-cb nil))
|
||||
([store done events completed-cb stopper]
|
||||
(let [stream (ptk/input-stream store)]
|
||||
(let [stream (ptk/input-stream store)
|
||||
stopper-s (if (fn? stopper)
|
||||
(stopper stream)
|
||||
(rx/filter #(= :the/end %) stream))]
|
||||
(->> stream
|
||||
(rx/take-until (if stopper
|
||||
(stopper stream)
|
||||
(rx/filter #(= :the/end %) stream)))
|
||||
(rx/take-until stopper-s)
|
||||
(rx/last)
|
||||
(rx/tap (fn []
|
||||
(rx/tap (fn [_]
|
||||
(completed-cb @store)))
|
||||
(rx/subs! (fn [_] (done))
|
||||
(fn [cause]
|
||||
(js/console.log "[error]:" cause))
|
||||
(fn [_]
|
||||
#_(js/console.log "[complete]"))))
|
||||
(doall (for [event (concat events [(end+)])]
|
||||
(ptk/emit! store event)))
|
||||
(doseq [event (concat events [(end+)])]
|
||||
(ptk/emit! store event))
|
||||
(ptk/emit! store :the/end))))
|
||||
|
||||
(defn run-store-async
|
||||
|
||||
Reference in New Issue
Block a user