 #_(clojure.pprint/pprint @stage-log)
 #_(let [in (debug/chan stage-log [:stage :in])
       out (debug/chan stage-log [:stage :out])]
-  (go (<! (wire peer [in out]))
+  (go (<! (wire peer [in (async/pub out :type)]))
       (>! out {:type :meta-sub :metas {"john" #{1}}})
 ;      (<! in)
       (<! (timeout 1000))

              [clojure.core.async :as async
               :refer [<! >! timeout chan alt! go put! filter< map< go-loop]]))


(declare wire)
(defn client-peer

                    :ip ip
                    :port port})]
    (go-loop [[in out] (<! new-conns)]
             (wire peer [out (async/pub in :type)])
             (recur (<! new-conns)))
    peer))

