gered/views
1
0
Fork 0
Code Issues Pull requests Packages Projects Releases Wiki Activity

Changed logging to debug level in router.

Browse source
This commit is contained in:
Alexander K. Hudek 2014-08-27 20:18:53 -04:00
parent 7ccaeceb93
commit 4d2da3f5a8
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
src/views/router.clj
View file

@ -2,27 +2,27 @@
(:require (:require
[views.subscribed-views :refer [subscribe-views unsubscribe-views disconnect]] [views.subscribed-views :refer [subscribe-views unsubscribe-views disconnect]]
[clojure.core.async :refer [go go-loop chan pub sub unsub close! >! >!! <! <!! filter<]] [clojure.core.async :refer [go go-loop chan pub sub unsub close! >! >!! <! <!! filter<]]
[clojure.tools.logging :refer [info debug]])) [clojure.tools.logging :refer [debug]]))
(defn handle-subscriptions! (defn handle-subscriptions!
[subscribed-views subscriptions] [subscribed-views subscriptions]
(go (while true (go (while true
(let [sub (<! subscriptions)] (let [sub (<! subscriptions)]
(info "Subscribing (in router): " sub) (debug "Subscribing (in router): " sub)
(subscribe-views subscribed-views sub))))) (subscribe-views subscribed-views sub)))))
(defn handle-unsubscriptions! (defn handle-unsubscriptions!
[subscribed-views unsubscriptions] [subscribed-views unsubscriptions]
(go (while true (go (while true
(let [unsub (<! unsubscriptions)] (let [unsub (<! unsubscriptions)]
(info "Unsubscribing (in router): " unsub) (debug "Unsubscribing (in router): " unsub)
(unsubscribe-views subscribed-views unsub))))) (unsubscribe-views subscribed-views unsub)))))
(defn handle-disconnects! (defn handle-disconnects!
[subscribed-views disconnects] [subscribed-views disconnects]
(go (while true (go (while true
(let [disc (<! disconnects)] (let [disc (<! disconnects)]
(info "Disconnecting (in router): " disc) (debug "Disconnecting (in router): " disc)
(disconnect subscribed-views disc))))) (disconnect subscribed-views disc)))))
(defn init! (defn init!