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

Rename in, out -> <remote, >remote

Browse source
This commit is contained in:
Nicholas Kariniemi 2014-10-10 19:06:28 +03:00
parent bef0e8d4e7
commit 88d1a0db1a
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
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 [msg out states shadow client?] (:type msg))) (defmulti handle-message (fn [msg >remote states shadow client?] (:type msg)))
(defmethod handle-message :diff [msg out states shadow client?] (defmethod handle-message :diff [msg >remote states shadow client?]
(let [states* @states (let [states* @states
shadow (sync/get-history-state states* (:hash msg))] shadow (sync/get-history-state states* (:hash msg))]
(if shadow (if shadow
@ -21,15 +21,15 @@
(when-not (= states* new-states) (when-not (= states* new-states)
(reset! states new-states))) (reset! states new-states)))
(when-not (or client? (sync/empty-diff? (:diff msg))) (when-not (or client? (sync/empty-diff? (:diff msg)))
(a/put! out (message/diff-msg diff hash))) (a/put! >remote (message/diff-msg diff hash)))
(if client? (if client?
new-shadow new-shadow
(sync/get-current-state new-states))) (sync/get-current-state new-states)))
(if client? (if client?
(do (a/put! out message/full-sync-request) (do (a/put! >remote message/full-sync-request)
shadow) shadow)
(let [state (sync/get-current-state states*)] (let [state (sync/get-current-state states*)]
(a/put! out (message/full-sync state)) (a/put! >remote (message/full-sync state))
state))))) state)))))
(defmethod handle-message :full-sync-request [msg out states shadow client?] (defmethod handle-message :full-sync-request [msg out states shadow client?]
@ -49,11 +49,11 @@
shadow)) shadow))
(defn make-agent (defn make-agent
([client? in out states] (make-agent client? in out states sync/empty-state)) ([client? <remote >remote states] (make-agent client? <remote >remote states sync/empty-state))
([client? in out states initial-shadow] ([client? <remote >remote states initial-shadow]
(go (loop [shadow initial-shadow] (go (loop [shadow initial-shadow]
(when-let [msg (<! in)] (when-let [msg (<! <remote)]
(recur (handle-message msg out states shadow client?))))))) (recur (handle-message msg >remote states shadow client?)))))))
(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))