         source-chans     (call-drivers drivers sink-proxy-chans)
         sink-chans       (main source-chans)
         _                (weld-cycle! sink-chans sink-proxy-chans)]
-    (println "cycle running")))
+    (println "cycle running")
+    (->> sink-proxy-chans vals shutdown-channel)))

  [drivers]
  (->> drivers
       keys
       (map (fn [name] [name (chan)]))
       (into {})))

(defn call-drivers

(ns kierros.core
  "Cycle-flavoured core functions."
  (:require [cljs.core.async :as a :refer [<! chan close!]])
  (:require-macros [cljs.core.async.macros :refer [go]]))

(defn sink-proxies
  "Accepts a map of drivers. Returns a map of the equivalent of Rx.ReplaySubject instance
