michael/grub-fork
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Rename handle-message -> handle-event

Browse source
This commit is contained in:
Nicholas Kariniemi 2014-10-10 19:41:52 +03:00
parent e833a48034
commit af7c9535df
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
src/cljx/grub/state.cljx
View file

@ -7,9 +7,9 @@
#+cljs (:require-macros [grub.macros :refer [log logs]] #+cljs (:require-macros [grub.macros :refer [log logs]]
[cljs.core.async.macros :refer [go]])) [cljs.core.async.macros :refer [go]]))
(defmulti handle-message (fn [event] (:type event))) (defmulti handle-event (fn [event] (:type event)))
(defmethod handle-message :diff [{:keys [hash diff >remote states shadow client?] :as msg}] (defmethod handle-event :diff [{:keys [hash diff >remote states shadow client?] :as msg}]
(let [states* @states (let [states* @states
shadow (sync/get-history-state states* hash)] shadow (sync/get-history-state states* hash)]
(if shadow (if shadow
@ -30,16 +30,16 @@
(a/put! >remote (message/full-sync state)) (a/put! >remote (message/full-sync state))
state))))), state))))),
(defmethod handle-message :full-sync-request [{:keys [states >remote]}] (defmethod handle-event :full-sync-request [{:keys [states >remote]}]
(let [state (sync/get-current-state @states)] (let [state (sync/get-current-state @states)]
(a/put! >remote (message/full-sync state)) (a/put! >remote (message/full-sync state))
state)) state))
(defmethod handle-message :full-sync [{:keys [state states]}] (defmethod handle-event :full-sync [{:keys [state states]}]
(reset! states (sync/new-state state)) (reset! states (sync/new-state state))
state) state)
(defmethod handle-message :new-state [{:keys [state states shadow >remote]}] (defmethod handle-event :new-state [{:keys [state states shadow >remote]}]
(let [{:keys [diff hash]} (sync/diff-states state shadow)] (let [{:keys [diff hash]} (sync/diff-states state shadow)]
(when-not (sync/empty-diff? diff) (when-not (sync/empty-diff? diff)
(a/put! >remote (message/diff-msg diff hash))) (a/put! >remote (message/diff-msg diff hash)))
@ -55,7 +55,7 @@
(go (loop [shadow initial-shadow] (go (loop [shadow initial-shadow]
(when-let [msg (<! <remote)] (when-let [msg (<! <remote)]
(let [event (msg->event msg shadow)] (let [event (msg->event msg shadow)]
(recur (handle-message event))))))))) (recur (handle-event event)))))))))
(defn make-server-agent (defn make-server-agent
([in out states] (make-agent false in out states)) ([in out states] (make-agent false in out states))