Penpot/penpot
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2025-01-24 07:29:08 -05:00
Code Issues Activity

Add cosmetic changes to rstore stream loop impl.

Browse source
This commit is contained in:
Andrey Antukh 2016-02-24 17:20:58 +02:00
parent 2fd5760aeb
commit 3ed3219c7f
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/uxbox/rstore.cljs
View file

@ -81,23 +81,25 @@
"Initializes the stream event loop and
return a stream with model changes."
[state]
(let [update-s (rx/filter update? bus)
watch-s (rx/filter watch? bus)
(let [watch-s (rx/filter watch? bus)
effect-s (rx/filter effect? bus)
update-s (rx/filter update? bus)
state-s (->> update-s
(rx/scan #(-apply-update %2 %1) state)
(rx/share))]
;; Process effects: combine with the latest model to process the new effect
(-> (rx/with-latest-from vector state-s effect-s)
(rx/subscribe (fn [[event model]] (-apply-effect event model))))
;; Process event sources: combine with the latest model and the result will be
;; pushed to the event-stream bus
(as-> (rx/with-latest-from vector state-s watch-s) $
(as-> watch-s $
(rx/with-latest-from vector state-s $)
(rx/flat-map (fn [[event model]] (-apply-watch event model)) $)
(rx/on-value $ emit!))
;; Process effects: combine with the latest model to process the new effect
(as-> effect-s $
(rx/with-latest-from vector state-s $)
(rx/subscribe $ (fn [[event model]] (-apply-effect event model))))
;; Initialize the stream machinary with initial state.
(emit! (swap-state (fn [s] (merge s state))))
state-s))