             fetch-ch (debug/chan log [ip :fetch])
             fetched-ch (debug/chan log [ip :fetched])]
         (async/sub p :meta-sub sub-ch)
-        (subscribe peer sub-ch bus-out out)
+        (subscribe peer sub-ch out)
 
         (async/sub p :meta-pub pub-ch)
         (async/sub p :fetched fetched-ch)

  (let [{:keys [new-conns] :as server} (start-server! ip port)
        log (atom {})
        in (debug/chan log [ip :in])
        out (async/pub in (fn [{:keys [user meta]}] [user (:id meta)]))
        peer (atom {:volatile (merge server
                                     {:store store
                                      :log log

(defn wire-stage [peer {:keys [chans] :as stage}]
  (go (if chans stage
          (let [log (atom {})
                in (debug/chan log ["STAGE" :in] 10)
                out (debug/chan log ["STAGE" :out])]
            (<! (wire peer [in (async/pub out :topic)]))
            (assoc stage :chans [(async/pub in :topic) out])))))


;; push perspective
