From 75b58d58a37833a1c5093c9a42d59f4827663609 Mon Sep 17 00:00:00 2001
From: Nicholas Kariniemi <nicholas.kariniemi@gmail.com>
Date: Fri, 10 Oct 2014 22:15:49 +0300
Subject: [PATCH] Add thread-safe printer

---
 src/cljx/grub/util.cljx | 17 ++++++++++++++++-
 1 file changed, 16 insertions(+), 1 deletion(-)

diff --git a/src/cljx/grub/util.cljx b/src/cljx/grub/util.cljx
index 861229a..0b97ae7 100644
--- a/src/cljx/grub/util.cljx
+++ b/src/cljx/grub/util.cljx
@@ -1,7 +1,22 @@
-(ns grub.util)
+(ns grub.util
+  (:require [grub.diff :as diff]
+            #+clj [clojure.core.async :as a :refer [<! >! chan go]]
+            #+cljs [cljs.core.async :as a :refer [<! >! chan]])
+  #+cljs (:require-macros [grub.macros :refer [log logs]]
+                          [cljs.core.async.macros :refer [go]]))
 
 (defn map-by-key [key coll]
   (->> coll
        (map (fn [a] [(get a key) a]))
        (into {})))
 
+(defn printer []
+  (let [in (chan)]
+    (go (loop [] 
+          (when-let [msg (<! printer)]
+            #+clj (clojure.pprint/pprint msg)
+            #+clj (println "-------")
+            #+cljs (logs msg)
+            #+cljs (log "-------")
+            (recur))))))
+