github/penpot
1
0
Fork 0
mirror of https://github.com/penpot/penpot.git synced 2026-09-13 07:30:24 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add default error handler for watch and update events on rstore.

Browse Source
This commit is contained in:
Andrey Antukh 2016-03-19 14:53:51 +02:00
parent 32dfaebbb9
commit a70ebcab44
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/uxbox/rstore.cljs
View File

@ -86,6 +86,12 @@
(enable-console-print!) (enable-console-print!)
(defn- on-error
"A default error handler."
[e]
(println "Unexpected error: " e)
(rx/empty))
(defn init (defn init
"Initializes the stream event loop and "Initializes the stream event loop and
return a stream with model changes." return a stream with model changes."
@ -95,6 +101,7 @@
update-s (rx/filter update? stream) update-s (rx/filter update? stream)
state-s (->> update-s state-s (->> update-s
(rx/scan #(-apply-update %2 %1) state) (rx/scan #(-apply-update %2 %1) state)
(rx/catch on-error)
(rx/share))] (rx/share))]
;; Process event sources: combine with the latest model and the result will be ;; Process event sources: combine with the latest model and the result will be
@ -102,6 +109,7 @@
(as-> watch-s $ (as-> watch-s $
(rx/with-latest-from vector state-s $) (rx/with-latest-from vector state-s $)
(rx/flat-map (fn [[event model]] (-apply-watch event model stream)) $) (rx/flat-map (fn [[event model]] (-apply-watch event model stream)) $)
(rx/catch on-error $)
(rx/on-value $ emit!)) (rx/on-value $ emit!))
;; Process effects: combine with the latest model to process the new effect ;; Process effects: combine with the latest model to process the new effect